[Kafka] Producing messages inside a docker container(bitnami/kafka)
·
개발 (Development)/Kafka
Bitnami Kafka 컨테이너에서 메시지를 프로듀스하는 방법Kafka를 학습하거나 테스트할 때, Bitnami Kafka 컨테이너에 직접 접속하여 메시지를 프로듀스(produce)하는 방법은 매우 유용합니다. 아래는 이를 수행하는 단계별 가이드입니다.1. Kafka 컨테이너에 접속Bitnami Kafka 컨테이너에 접속하려면 다음 명령어를 사용합니다:docker exec -it /bin/bash컨테이너 이름을 모를 경우, 다음 명령어로 실행 중인 Kafka 컨테이너를 확인하세요:docker ps예시:docker exec -it kafka-container /bin/bash2. Kafka CLI 도구 사용Kafka 컨테이너 내부에는 CLI 도구가 포함되어 있습니다. 이를 활용하여 메시지를 프로듀스할 ..
[Kafka] Linux 운영체제에서 Kafka 특정 Topic 메시지 확인
·
개발 (Development)/Kafka
카프카 토픽의 메시지를 확인하려면 kafka-console-consumer 명령어를 사용할 수 있습니다. 이 명령어를 사용하여 특정 토픽의 메시지를 구독하고 표시할 수 있습니다. 다음은 kafka-console-consumer를 사용하여 test 토픽의 메시지를 확인하는 명령어입니다.kafka-console-consumer.sh --bootstrap-server --topic test 여기서 는 카프카 클러스터의 부트스트랩 서버 목록입니다. 위 명령어를 실행하면 해당 토픽에서 생성된 메시지를 실시간으로 표시할 수 있습니다. 만약 모든 메시지를 한 번에 표시하고 싶다면 --from-beginning 옵션을 추가할 수 있습니다.kafka-console-consumer.sh --bootstrap-server..
[Kafka] Linux 운영체제에서 Kafka Topic 리스트 확인
·
개발 (Development)/Kafka
카프카의 토픽을 확인하는 방법은 kafka-topics 명령어를 사용하여 가능하다. 이 명령어를 사용하여 현재 카프카 클러스터에 정의된 토픽을 나열할 수 있다. 다음은 카프카 토픽을 확인하는 명령어다.kafka-topics.sh --list --zookeeper : 위 명령어에서 를 카프카 클러스터의 Zookeeper 호스트로 대체해야 한다. 만약 카프카 클러스터가 별도의 Zookeeper를 사용하지 않는다면, 최신 버전의 카프카에서는 --zookeeper 옵션 대신 --bootstrap-server 옵션을 사용할 수 있다.kafka-topics.sh --list --bootstrap-server  여기서 는 카프카 클러스터의 부트스트랩 서버 목록이다.위 명령어를 실행하면 현재 카프카 클러스터에 정의된 ..
[Kafka] 오류: 기본 클래스 {경로명 일부}\kafka_2.13-2.8.0\libs\activation-1.1.1.jar;C:\{경로명 일부}을(를) 찾거나 로드할 수 없습니다.
·
개발 (Development)/Kafka
문제점 Kafka zookeeper 실행 시 오류 bin\windows\zookeeper-server-start.bat config\zookeeper.properties 상위 경로명이 "Program Files" 라면 오류: 기본 클래스 Files\kafka_2.13-2.8.0\libs\activation-1.1.1.jar;C:\Program을(를) 찾거나 로드할 수 없습니다. 라고 뜬다. 해결 방법 kafka_2.13-2.8.0 폴더가 위치한 디렉토리 명에 공백이 들어가 있어서 오류 발생. 공백 제거 후 해결