로컬에서 카프카 구축 후 토픽 발행, 구독 테스트를 진행했다.
토픽 생성, 메세지 전송은 성공적으로 이루어지나 구독하여 메세지를 받아올 때 오류가 발생했다.
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
해당 명령어 실행 후 구독한 토픽의 메세지가 뜨지 않고 가만히.. 있었다.
강제 종료 후에는 Processed a total of 0 messages 문구가 나타났다.
카프카 실행창을 보니 Unexpected error handling request RequestHeader 라는 에러 로그를 확인할 수 있었다.
해결 방법은 구독 명령어에 --partition 0 을 붙여 파티션의 개수를 지정해주는 것이다.
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning --partition 0
왜 꼭 지정을 해줘야 하는지는 알 수 없지만, 해당 방법으로 해결했다.
파티션의 개수도 영향을 미치는 것 같은데, 0이 아니라 1로 했더니 같은 오류가 발생했다.
이유는 모르겠으나 ..