하나의 토픽에 다양한 파티션을 정의할 수 있음

컨슈머가 레코드를 병렬 처리 할 수 있게 하려면 컨슈머를 스케일 아웃하면 됨

컨슈머 개수를 늘리고 파티션의 개수도 늘리면 처리량이 증가하는 효과 볼 수 있음

카프카 클라이언트

프로듀서 API

key 정의 없이 간단한 프로듀서 API 구현

• SimpleProducer

⚠️ 에러 발생

처음 SimpleProducer 실행시 에러

private final static String BOOTSTRAP_SERVERS = "my-kafka:9092";

설정한 url을 읽지 못했음

wsl 환경에서는 hosts 파일에 해당 url을 추가해 놓았지만 내 intellij는 로컬 윈도우 환경이기 때문에 따로 추가를 했어야 함

C:\Windows\System32\drivers\etc 을 가서 hosts 파일을 관리자 권한으로 수정하여 url 추가

• 콘솔 출력
• 카프카 프로듀서 구동 시 설정한 옵션들 출력
• 카프카 클라이언트 버전 출력