Kafka 상용 명령 의 kafka-console-producer.sh

kafka-console-producer.sh 스 크 립 트 는 kafka.tools.ConsoleProducer 류 에서 명령 행 인 자 를 불 러 오 는 방식 으로 콘 솔 에서 메 시 지 를 생산 하 는 스 크 립 트 입 니 다.
본 고 는 Kafka 에 기초 하고 있 습 니 다.2.12-2.5.0 버 전이 작 성 된 것 입 니 다.-boottstrap-server 인 자 는 이 버 전에 서 사용 되 기 시 작 했 습 니 다.-broker-list 도 이 버 전에 서 유행 이 지 났 지만 속성 값 은 변 하지 않 습 니 다.오래된 버 전 을 사용 할 때 차이 점 을 주의 하고 맹목적 으로 복사 하여 붙 여 넣 지 마 십시오.
1.키 없 는 메시지
 기본 적 인 상황 에서 생산 된 정 보 는 key 가 없습니다.명령 은 다음 과 같 습 니 다.

bin/kafka-console-producer.sh --bootstrap-server localhsot:9092 --topic topicName

*8195:상기 명령 을 실행 하면 콘 솔 에서 메시지 체 를 입력 하 기 를 기다 리 고 메시지 값(value)을 직접 입력 하면 됩 니 다.줄 마다(줄 바 꿈 문자 로 구분)메 시 지 를 표시 합 니 다.다음 과 같 습 니 다.

>Hello Kafka!
>   kafka!

 정상 적 인 상황 에서 매번 리 턴 할 때마다"발송"작업 을 촉발 하고 리 턴 후"Ctrl+c"를 사용 하여 생산자 콘 솔 을 종료 한 다음 에 kafka-console-consumer.sh 스 크 립 트 를 사용 하여 이번 생산 상황 을 검증 할 수 있 습 니 다.
2.key 형 메시지 가 있 습 니 다.
 메시지 에 key 를 지정 해 야 할 때 다음 명령 을 사용 할 수 있 습 니 다.

bin/kafka-console-producer.sh --bootstrap-server localhsot:9092 --topic topicName --property parse.key=true

기본 메시지 키 와 메시지 값 사이 에"Tab 키"를 사용 하여 구분 합 니 다.전의 문자(\t)를 사용 하지 마 십시오.다음 과 같 습 니 다.

>Lei Li    Hello Kafka!
>Meimei Han       kafka!

 상기 정 보 를 입력 하면 생산 된 메시지 인'Lei Li'를 메시지 키 로 하고'Hello Kafka'를 메시지 값 으로 표시 합 니 다.
별표 속성 목록
『8195』아래 표 는 현재 버 전이 지원 하 는 모든 매개 변수 용법 을 열거 하 였 으 니 참고 하 시기 바 랍 니 다.
매개 변수
값 형식
설명 하 다.
유효 치
--bootstrap-server
String
연결 할 서버 가 필요 합 니 다(지정 하지 않 은 경우--broker-list)
host 1:prot 1,host 2:prot 2
--topic
String
메시지 받 을 테마 이름
--broker-list
String
연결 할 서버
host 1:prot 1,host 2:prot 2
--batch-size
Integer
단일 일괄 처리 중 보 낸 메시지 수
200(기본 값)
--compression-codec
String
압축 디코더
none,gzip(기본 값)snappy,lz4,zstd
--max-block-ms
Long
요청 을 보 내 는 동안 생산 자 는 가장 오래 막 을 것 이다.
60000(기본 값)
--max-memory-bytes
Long
생산 자 는 서버 에 보 낼 총 메모 리 를 버퍼 링 하 는 데 사용 합 니 다.
33554432(기본 값)
--max-partition-memory-bytes
Long
파 티 션 에 할당 할 버퍼 크기
16384
--message-send-max-retries
Integer
최대 재 시도 발송 횟수
3
--metadata-expiry-ms
Long
메타 데 이 터 를 강제로 업데이트 하 는 시간 한도 값(ms)
300000
--producer-property
String
사용자 정의 속성 을 생 성기 에 전달 하 는 메커니즘
key=value
--producer.config
String
생산자 설정 속성 파일[--producer-property]이 설정 보다 우선 합 니 다.
파일 전체 경로 설정
--property
String
사용자 정의 메시지 리더
parse.key=true|falsekey.separator=ignore.error=true|false
--request-required-acks
String
생산자 요청 확인 방식
0,1(기본 값),all
--request-timeout-ms
Integer
생산자 가 요청 한 확인 시간 초과
1500(기본 값)
--retry-backoff-ms
Integer
생산자 가 다시 시도 하기 전에 메타 데이터 의 대기 시간 한도 값 을 새로 고 칩 니 다.
100(기본 값)
--socket-buffer-size
Integer
TCP 수신 버퍼 크기
102400(기본 값)
--timeout
Integer
메시지 대기 비동기 대기 처리 시간 한도 값
1000(기본 값)
--sync
메시지 동기 화
--version
Kafka 버 전이 다른 인자 와 맞지 않 을 때 로 컬 Kafka 버 전 으로 표 시 됩 니 다.
--help
도움말 정보 인쇄