홈>
Java API를 사용하여 Zookeeper를 실행하려고하는데 여러 파티션으로 주제를 시작할 수 있습니다. 이 답변 트릭을 수행합니다. 그러나이 코드를 실행하려고하면 오류가 발생합니다.
Unable to connect to zookeeper server 'localhost:2181' with timeout of 8000 ms
이 컴퓨터에서 동물원 관리자 서버가 실행되고 있지 않습니다. 그러나 Java에서 인스턴스를 시작하고 싶습니다 (현재 ZooKeeperServerMain () 클래스를 사용할 수 있습니다). 아마도 같은 작업을 수행해야하지만 주제에 여러 파티션을 추가 할 가능성이있는 첫 번째 답변과 어떻게 결합해야합니까?
그만한 가치를 위해 이 답변 은 주제에 대해 하나의 파티션 만 생성하므로 정확히 내가 원하는 것은 아닙니다.
본질적으로 Zookeeper (두 번째 링크를 사용하여 수행 할 수 있음)를 시작하고 Kafka를 로컬로 시작하고 (또한 할 수 있음) 생산자를 시작하여 단일 주제로 생성하지만 세 개의 다른 파티션을 만들고 싶습니다. , 3 개의 다른 소비자, 즉 각 파티션에서 하나씩 메시지를 읽습니다 (Kafka를 올바르게 이해하면 3 개의 소비자가 시작되면 3 개의 파티션이 균등하게 분할됩니다). 이 모든 것은 Java API를 사용하여 수행됩니다 (Kafka 스크립트 등을 실행하지 않습니다). 그러나 세 개의 파티션으로 주제를 만드는 데 어려움이 있습니다. 이것이 제 질문입니다.- 답변 # 1
- 답변 # 2
앞으로 카프카에서 주제를 만들거나 관리하기 위해 사육사와 직접 대화해서는 안됩니다. Kafka 0.11에 도입 된 새로운 AdminClient API를 사용해야합니다.
https://kafka.apache.org/0110/javadoc/index.html?org/apache/kafka/clients/admin/AdminClient.html
관련 자료
- Node.js Clusters - nodejs 클러스터 - 명백한 이유없이 스크립트가 여러 번 실행되는 이유는 무엇입니까?
- bash - 출력 파일이 다른 여러 파일에서 어레이 실행
- Kafka Connect S3 소스 커넥터를 실행하는 ClassNotFound 예외
- java - 브로커 용 여러 웹 콘솔을 실행하는 ActiveMQ Artemis
- python - Flask 애플리케이션과 상호 작용하는 Kafka 소비자 실행
- Ansible은 Docker가 여러 호스트에서 실행될 때까지 확인하고 기다리는 방법은 무엇입니까?
- javascript - Jest가 동일한 테스트를 여러 번 실행했지만 후속 실행시 충돌
- android sdcard - Arduino에서 여러 스케치 실행
- bash - || 조건이 거짓입니다
- kubernetes - 팟 (Pod)에서 동일한 이미지의 여러 컨테이너 실행 및 여러 팟 (Pod) 실행 및 여러 노드에서 실행
- macos - bash를 사용하여 프로세서의 여러 코어에서 동일한 프로그램 실행
- 날짜 선택 도구를 실행할 때 다중 선택이 작동하지 않고 Excel에서 VBA로 자동 맞춤
- python - 여러 프로세스를 동시에 실행하고 결과 반환
- python - 여러 코드를 실행하는 것이 하나만 실행하는 것보다 빠르나요?
관련 질문
- java : Bazel에서 ReuseForks=false에 해당하는 것은 무엇입니까?
- java : 어떤 종속성이 전이 종속성의 버전을 재정의하는지(Maven)
- java : 속성 파일을 공유하고 여러 스프링 부트 프로젝트 간에 확장
- java : 422 Unprocessable Entity에서 사용자 정의 응답 JSON 가져오기
- java : 리소스에서 config.yaml로 Dropwizard 시작
- java : 하나의 Maven 프로젝트에서 다른 리소스 파일을 사용하여 두 개의 항아리를 만드는 방법
- "[오류] {생략} 모듈 jdk.compiler는 EclIpse에서 Maven을 사용하는 동안 이름이 지정되지 않은 모듈 @73ad993b에 대해 "com.sun.tools.javac.processing을 열지" 않습니다.
- java : 요청된 대상에 대한 유효한 인증 경로를 찾을 수 없음 -github에 대한 링크
- java : Maven이 로컬 리포지토리를 자동으로 업데이트하지 못하도록 하려면 어떻게 해야 합니까?
- java : git-push 명령이 실패했습니다.
브로커의
num.partitions
구성은 자동으로 생성 된 주제 (생산자 또는 소비자가 만든)에 대해 파티션 수를 적용하는 데 사용할 수 있습니다. 이 구성을 적용하려면 이미 작성된 주제를 먼저 제거해야합니다. 이 구성이 변경된 후 자동으로 작성된 주제 만 영향을받습니다.