0
우리의 설치에는 한 명의 사육사와 여러 명의 독립적 인 카프카 중개인이 있습니다. 특정 브로커에 대한 주제를 프로그래밍 방식으로 작성해야합니다.한 명의 사육사, 여러 카프카 중개인 - 특정 중개인에 대해 프로그래밍 방식으로 주제를 만드는 방법은 무엇입니까?
주제가 이미 존재하는지 확인한 후 AdminUtils를 사용하여 주제를 만듭니다. 전화 번호는 다음과 같습니다.
AdminUtils.createTopic(zkUtils, topic, partitions = 1, replicationFactor = 1, properties)
"속성"에는 cleanup.policy에 대한 항목이 하나만 있습니다. 이 호출의 문제점은 주제가 생성되기를 원하는 Kafka 중개인을 지정하지 않아도되므로 사육사가 임의로 선택합니다.
주제를 작성해야하는 브로커를 어떻게 지정할 수 있습니까?
화제가 특정 브로커에 생성 될 수있는 그런 개념이 없다. 게다가 Properties 클래스는 사용자가 여러 KV 쌍을 연결할 수있는 'setProperty'메소드를 제공하는 Hashtable을 확장합니다. – amethystic
다른 말로하면, 내가 분리 된 중개인을 원한다면, 그들은 모두 사육사의 다른 인스턴스와 연관 되어야만합니까? 그것은 바르게 들리지 않습니다 ... –