0

나는 두 개의 응용 프로그램을했습니다 spring.cloud.stream.kafka.binder.defaultBrokerPort. 모든 것이 잘 작동합니다. 문서에서 스프링 클라우드 스트림과 사육사

가 나는 카프카의 바인더가 연결할 수있는 사육사 노드의 목록을 정의 할 spring.cloud.stream.kafka.binder.zkNodesspring.cloud.stream.kafka.binder.defaultZkPort 를 참조하십시오.

내 이해에서, 나는 단지 kafka에 내 응용 프로그램을 연결해야합니다. 그렇다면 사용법을 설명해 주시겠습니까? 아니면 사육사 상대 속성을 정의해야하는 유스 케이스를 줄 수 있습니까?

답변

2

Zookeeper는 Kafka 바인더가 파티션 수 또는 동시 인스턴스 수와 같은 바인더 옵션을 사용하여 항목을 자동으로 만들 수 있도록하기 위해 사용됩니다 (브로커를 만드는 데 의존하지 않고). 이 기능이 필요하지 않은 경우 주제 자동 생성을 비활성화 할 수 있습니다. 여기에서 토론 내용보기 : https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/37.

이 기능은 1.1부터 사용할 수 있습니다. 1.0에서 Zookeeper는 0.8 SimpleConsumer 클라이언트에 필요했습니다.

관련 문제