나는 인증 중에 Zookeeper에 연결되는 (동일하게 실행중인) AuthenticationProvider을 만들고이 사용자가 올바른 암호를 주었으면 노드를 체크인합니다. 기본적 흐름은 다음과 같이 떨어지게 같습니다 @Override
public KeeperException.Code handleAuthentication(ServerCnxn cnxn, by
누군가 Tomcat에서 zookeeper/kafka를 embeded 사용했는지 궁금 해서요. 카프카에게 사육사가 필요하다는 것을 압니다.하지만 카프카와 사육사를 별도의 인스턴스로 실행해야한다는 의미입니까? 지금까지 나는 모든 것이 볼트로 연결되어있는 사용 사례를 볼 수 없습니다. 아무도 조언 할 수 있습니까? 제 질문은 동물원과 카프카를 동일한 tomcat
누군가가 내가 사육사에게 SSL 연결을 정렬 도와 드릴까요, 내 질문은 어떻게 창에서 zkCli.cmd 파일에 CLIENT_JVMFLAGS를 구성하는 것입니다. 참조 : 수출 정확한 (zkCli를 시작하기 전에) 해당 웹 사이트에 언급하여 터미널에서 https://cwiki.apache.org/confluence/display/ZOOKEEPER/ZooKee
시나리오 : 큐레이터를 사용하여 분산 뮤텍스를 구현합니다. 이미 뮤텍스를 획득 한 클라이언트가 네트워크 장애로 인해 zk 서버와 연결이 끊어지면 큐레이터는 다시 연결을 시도합니다. 마지막으로 성공적으로 다시 연결되었다고 가정 해 봅시다.하지만 마지막 세션이 만료되고 뮤텍스에 사용 된 임시 잠금 노드가 사라지면이 뮤텍스가 다시 작동하지 않습니다! 그래서 큐레
Ubuntu에 kafka 서버를 실행하려고합니다. 내가이 명령을 실행하고 때 :이 오류를 얻고있다 > bin/kafka-server-start.sh config/server.properties
: > bin/zookeeper-server-start.sh config/zookeeper.properties
를 내가이 명령에 의해 카프카 서버를 실행하려고
solrJ를 사용하여 solr 데이터 [solr cloud 6.5 - 3 machines]를 삽입/쿼리합니다. 이전에 SolrClient를 생성하기 위해 아래 코드를 사용했습니다. - HttpSolrClient server;
server = new HttpSolrClient.Builder("").build();
server.setSoTimeout(200
Apache Curator의 create() 메소드가 원래 Zookeeper 작성 메소드를 재시도 논리로 래핑하는지 여부를 알고 싶습니다. ZNode를 만드는 코드를 작성했으며 기본적으로 다시 시도하고 싶습니다. 재시도 기능으로 작성 기능을 작성하는 가장 좋은 방법은 무엇이겠습니까? CuratorFramework client = CuratorFramewor