Windows 10 Kafka 군집 구축

Kafka 다운로드
1. Kafka 다운로드:http://mirror.bit.edu.cn/apache/kafka/2.3.0/kafka_2.12-2.3.0.tgz
2. 압축 을 푼 후 Kafka 폴 더 를 복사 하여 각각 kafka 1, kafka 2, kafka 3 라 고 명명 합 니 다.
프로필 수정
  • config 폴 더 의 server. properties 를 수정 합 니 다. 그 중에서 brokerId 는 유일한 것 입 니 다. 클 러 스 터 에서 kafka 서버 가 설정 한 brokerId 는 같 을 수 없습니다. zookeeper 의 my id
  • 에 해당 합 니 다.
  • zookeeper.connect=127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183/kafka

  • 설명: 이것 은 zookeeper 클 라 이언 트 의 서버 포트 번호 입 니 다. / kafka 는 zookeeper 에서 마 운 트 한 폴 더 입 니 다. zookeeper 클 라 이언 트 명령 create / kafka 를 직접 만 듭 니 다.
    Kafka 조작
    테마 만 들 기kafka-topics.bat –create –zookeeper 127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183/kafka –replication-factor 1 –partitions 1 –topic test
    명령 설명: – create 지정 생 성 topic 동작 – zookeeper 지정 kafka 연결 zk 의 연결 url, 이 값 은 server. properties 파일 의 설정 항목 {zookeeper. connect} 과 같 습 니 다 – replication - factor: 각 파 티 션 의 복사 인자 개 수 를 지정 합 니 다. 기본 1 개 – paritions: 현재 생 성 된 kafka 파 티 션 수 를 지정 합 니 다. 기본 값 은 1 개 – topic: 테마 이름 설정
    테마 상태 보기kafka-topics.bat –describe –zookeeper 127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183/kafka –topic test
    결과 정보 필드 의 의미: 1 Partition: 파 티 션 2 Leader: 지정 한 파 티 션 의 노드 를 읽 고 쓰 는 역할 3 Replicas: 이 파 티 션 log 의 노드 목록 4 Isr: "in - sync" replicas, 현재 활성 화 된 던 전 목록 (키 집합) 을 복사 하고 Leader 가 될 수 있 습 니 다.
    kafka 생산자 생산 소식kafka-console-producer.bat –broker-list 127.0.0.1:9092 –topic test
    소비자 가 소식 을 받아들이다.kafka-console-consumer.bat --bootstrap-server 127.0.0.1:9092 --topic test --from-beginning

    좋은 웹페이지 즐겨찾기