diff --git a/.DS_Store b/.DS_Store
index 89b2089..3333a8d 100644
Binary files a/.DS_Store and b/.DS_Store differ
diff --git a/.github/workflows/cd.yml b/.github/workflows/cd.yml
index e7ca47e..2a22e68 100644
--- a/.github/workflows/cd.yml
+++ b/.github/workflows/cd.yml
@@ -3,8 +3,7 @@ name: CD - Build & Deploy
 on:
   push:
     branches:
-      - feature/bulk-v3
-      - feat/producer-rps-optimization
+      - main
   workflow_dispatch:
 
 env:
diff --git a/README.md b/README.md
deleted file mode 100644
index c18ac47..0000000
--- a/README.md
+++ /dev/null
@@ -1,44 +0,0 @@
-# 👀 Panopticon
-
-“모든 서비스의 로그를 한눈에 관찰하다.”
-
-## 🌿 Branch Naming
-
-| 타입          | 예시                    | 설명                                                  |
-| ------------- | ----------------------- | ----------------------------------------------------- |
-| **feature/**  | `feature/signup-ui`     | 새로운 기능 개발                                      |
-| **fix/**      | `fix/post-api-error`    | 오류 수정 (일반 + 긴급)                               |
-| **refactor/** | `refactor/comment-hook` | 리팩토링 (기능 변화 없고 코드 구조 개선과 관련)       |
-| **test/**     | `test/routing-next`     | 테스트 (기능 개발과 관계없이 테스트가 필요할때)       |
-| **...**       | `...`                   | 코드 구현과 관련없는 이외의 작업들은 바로 Main에 커밋 |
-
----
-
-> 각 브랜치는 **작업 목적이 명확하게 드러나도록** 이름을 붙이세요
-> 예: `feature/login-api`, `fix/user-auth-bug`, `refactor/dashboard-layout`
-
----
-
-## 💬 Conventional Commits
-
-```
-<type>(<scope>): <subject>
-```
-
-- **type**: 커밋의 유형 (예: `feat`, `fix`, `docs` 등)
-- **scope**: 변경된 범위나 영역 (선택 사항)
-- **subject**: 간단한 변경 내용 설명
-
----
-
-| 타입                | 설명                                                              | 예시                                          |
-| ------------------- | ----------------------------------------------------------------- | --------------------------------------------- |
-| **feat**            | 새로운 기능을 추가할 때 사용                                      | `[feat(auth)]: 소셜 로그인 기능 추가`         |
-| **refactor**        | 코드 리팩토링, 기능 추가나 버그 수정 아님                         | `[refactor(user-service)]: 로직 최적화`       |
-| **fix**             | 버그 수정 시 사용                                                 | `[fix(api)]: 로그인 오류 수정`                |
-| **docs**            | 문서 수정 (코드 변경 없음)                                        | `[docs(readme)]: 설치 가이드 업데이트`        |
-| **style**           | 코드 형식이나 포맷 변경 (기능 변화 없음)                          | `[style(global)]: 들여쓰기 규칙 통일`         |
-| **test**            | 테스트 코드 추가 또는 수정                                        | `[test(api)]: 인증 기능 테스트 추가`          |
-| **chore**           | 빌드 프로세스 변경, 패키지 업데이트 등 코드와 직접 관련 없는 작업 | `[chore(build)]: 의존성 패키지 업데이트`      |
-| **perf**            | 성능을 개선하기 위한 코드 변경                                    | `[perf(images)]: 이미지 로딩 속도 개선`       |
-| **BREAKING CHANGE** | 호환성을 깨는 변경 사항을 설명할 때 사용                          | `[BREAKING CHANGE]: 스키마가 변경되었습니다.` |
\ No newline at end of file
diff --git a/backend/src/shared/common/kafka/kafka.config.ts b/backend/src/shared/common/kafka/kafka.config.ts
index 956d5eb..caf0b73 100644
--- a/backend/src/shared/common/kafka/kafka.config.ts
+++ b/backend/src/shared/common/kafka/kafka.config.ts
@@ -60,6 +60,18 @@ interface KafkaMicroserviceParams {
 
 type KafkaSecurityOverrides = Pick<KafkaConfig, "ssl" | "sasl">;
 
+// fetch 옵션 기본값 (환경 변수가 없을 때 사용)
+const DEFAULT_FETCH_MAX_BYTES = 50 * 1024 * 1024; // 50MB
+const DEFAULT_FETCH_MAX_BYTES_PER_PARTITION = 10 * 1024 * 1024; // 10MB
+const DEFAULT_FETCH_MIN_BYTES = 1 * 1024 * 1024; // 1MB
+const DEFAULT_FETCH_MAX_WAIT_MS = 50;
+
+// 양수인 정수 환경 변수만 추출해 Kafka fetch 옵션에 안전하게 반영한다.
+function parsePositiveInt(value: string | undefined): number | undefined {
+  const parsed = Number.parseInt(value ?? "", 10);
+  return Number.isFinite(parsed) && parsed > 0 ? parsed : undefined;
+}
+
 function buildKafkaSecurityConfig(): KafkaSecurityOverrides {
   const sslEnabled = process.env.KAFKA_SSL === "true";
   const sslRejectUnauthorized =
@@ -147,6 +159,19 @@ export function createKafkaMicroserviceOptions(
           process.env.KAFKA_CONCURRENT_PARTITIONS ?? "3",
           10,
         ),
+        // fetch 용량/대기 시간을 환경 변수로 조절해 한 번에 더 많은 레코드를 끌어올 수 있다.
+        maxBytes:
+          parsePositiveInt(process.env.KAFKA_FETCH_MAX_BYTES) ??
+          DEFAULT_FETCH_MAX_BYTES,
+        maxBytesPerPartition:
+          parsePositiveInt(process.env.KAFKA_FETCH_MAX_BYTES_PER_PARTITION) ??
+          DEFAULT_FETCH_MAX_BYTES_PER_PARTITION,
+        minBytes:
+          parsePositiveInt(process.env.KAFKA_FETCH_MIN_BYTES) ??
+          DEFAULT_FETCH_MIN_BYTES,
+        maxWaitTimeInMs:
+          parsePositiveInt(process.env.KAFKA_FETCH_MAX_WAIT_MS) ??
+          DEFAULT_FETCH_MAX_WAIT_MS,
       },
     },
   };
diff --git a/backend/src/stream-processor/common/bulk-indexer.service.ts b/backend/src/stream-processor/common/bulk-indexer.service.ts
index 7df3c9b..f26f480 100644
--- a/backend/src/stream-processor/common/bulk-indexer.service.ts
+++ b/backend/src/stream-processor/common/bulk-indexer.service.ts
@@ -37,10 +37,10 @@ export class BulkIndexerService implements OnModuleDestroy {
     this.client = this.storage.getClient();
     this.maxBatchSize = Math.max(
       1,
-      Number.parseInt(process.env.BULK_BATCH_SIZE ?? "1000", 10),
+      Number.parseInt(process.env.BULK_BATCH_SIZE ?? "6000", 10),
     );
     const byteLimitMb = Number.parseFloat(
-      process.env.BULK_BATCH_BYTES_MB ?? "10",
+      process.env.BULK_BATCH_BYTES_MB ?? "32",
     );
     this.maxBatchBytes = Math.max(1024, Math.floor(byteLimitMb * 1024 * 1024));
     this.flushIntervalMs = Math.max(
@@ -49,7 +49,7 @@ export class BulkIndexerService implements OnModuleDestroy {
     );
     this.maxParallelFlushes = Math.max(
       1,
-      Number.parseInt(process.env.BULK_MAX_PARALLEL_FLUSHES ?? "3", 10),
+      Number.parseInt(process.env.BULK_MAX_PARALLEL_FLUSHES ?? "6", 10),
     );
   }