개발자의 개발괴발

이전 글에서 topic에 메세지를 produce 해보았다.topic에 저장된 message에 대해 살펴보자토픽을 조회해보자.$ kafka-topics.sh --list --bootstrap-server=localhost:9092__consumer_offsetsmyTopic__consumer_offsets와 myTopic 두개의 토픽이 보인다.__consumer_offsets 토픽은 자동으로 생성된 토픽이다.우리가 생성한 myTopic에 저장된 내용을 보자.kafka console consumer를 통해 내용을 확인해보면 아래와 같다.$ kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic myTopic --from-beginningWel..

현재 myTopic이라는 topic 하나밖에 없다.I have no name!@bitnami-kafka-controller-0:/$ kafka-topics.sh --list --bootstrap-server=localhost:9092myTopic 이 토픽의 data를 조회하면 현재 아무것도 없다.아래 명령어를 입력하고 기다려도 아무런 값도 나오지 않는다.I have no name!@bitnami-kafka-controller-0:/$ kafka-console-consumer.sh --bootstrap-server localhost:9092 \ --topic myTopic --from-beginning이제 producer를 이용해 데이터를 topic에 넣어보자. package mainimpor..

이전의 설정으로 잘 되는줄 알았는데 잘 되지 않았다.이전 글에선 LoadBalancer type으로 동작을 시켰는데 이번엔 nodePort type으로 동작시켰다. 아래 명령어를 통해 얻은 values.yaml 파일을 다시 변경했다.helm show values bitnami/kafka > values.yaml전체 변경사항을 보여주자면listeners: client: containerPort: 9092 protocol: PLAINTEXT ## 여기 변경 name: CLIENT sslClientAuth: "" controller: name: CONTROLLER containerPort: 9093 protocol: PLAINTEXT ## 여기 변경 sslCl..