초코chip의 코딩 생활

들어가며..해당 스크립트는 카프카 Topic에서 메시지를 가져오거나(fetch) 표시(display)할때 주로 사용할 수 있는 작업오직 새 메시지만 읽는 작업모든 메시지를 읽는 작업 모든 메시지 수신./kafka-console-consumer.sh --topic studytopic2 --from-beginning --bootstrap-server localhost:9092,localhost:9094명령어를 실행시키면 해당 topic의 모든 메시지를 출력한 후명령어를 종료하지 않고 대기하며, 새로운 메시지가 수신되면 출력  새로운 메시지 수신./kafka-console-consumer.sh --topic studytopic2 --bootstrap-server localhost:9092,localhost:9..

들어가며...해당 스크립트는 카프카 Topic에게 메시지를 전송할때 주로 사용할 수 있는 작업Key를 포함/포함하지 않고 메시지 전송하나의 파일에서 여러개의 메시지 전송  메시지 전송 without key./kafka-console-producer.sh --bootstrap-server localhost:9092,localhost:9094 --topic studytopic2만약 존재하지 않는 topic으로 전송을 하면, kafka에서 자동으로 기본 구성으로 해당 topic을 생성 (이게 기본설정)메시지 종료를 하고 싶으면 control + c   메시지 전송 with key./kafka-console-producer.sh --bootstrap-server localhost:9092,localhost:90..

들어가며..카프카 클러스터 내의 Topic들을 관리하고 상호작용하는데 사용java 코드를 이용하거나 CLI 스크립트를 사용하여 작업할 수 있음할 수 있는 작업들새로운 Topic Create, Delete기존의 Topic들을 나열(list)해당 Topic의 세부 정보 확인(describe) Topic 생성 (create)./kafka-topics.sh --create --topic studytopic2 --partitions 3 --replication-factor 3 --bootstrap-server localhost:9092, localhost:9094 단, 파티션의 개수는 소비자 수 이상이여야함그러면 그 이상의 소비자를 사용하고 싶다면 어떻게 해야하는가? -> 복제를 사용 (replication-fa..