KAFKA2 [kafka] 자주 사용하는 kafka 명령어 topic별 발행된 데이터 개수를 확인kubectl exec -n namespace kafka-0 -- kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic [topic name]// 출력 결과는 $TOPIC_NAME:$PARTITION_ID:$OFFSET 형식 값 확인kubectl exec -n [namespace] kafka-0 -- kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic [topic name] --property print.key=true --property key.separator="-" --from-beginning c.. 2022. 9. 29. [kafka] NotLeaderForPartitionException 해결 방법 카프카를 외부에서 접근할 수 있도록 설정 한 뒤, 접근하려고 할 때 아래와 같은 이슈가 발생했습니다. Received invalid metadata error in produce request on partition ${TOPIC} due to org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition.. Going to request metadata update now Kafka 에서 각 토픽은 여러 브로커에 의해 제공이 되는데, 한 브로커는 리더이고 나머지는 팔로워가 됩니다. producer 의 경우, 내부적으로 모든 팔로워에게 데이터를 복제하는 리더.. 2022. 8. 6. 이전 1 다음
