PublishKafka_2_6
📜 Property
⚙ Kafka Brokers
-
Kafka의 접속 주소 정보와 포트를 “,” 를 기준으로 입력
-
kafka1:9092,kafka2:9092,kafka3:9092
⚙ Security Protocol
- PLAINTEXT로 설정
⚙ SASL Mechanism
- PLAIN 으로 설정
⚙ Username
- 아이디 입력
⚙ Password
- 패스워드 입력
⚙ Topic Name
- 사용하고자 하는 토픽명을 입력
📜 Property
⚙ Delivery Guarantee
- 데이터가 전송됨을 어떻게 보장할지 방법을 정합니다. 해당 보장방법에 위배되는 메시지는 Fail 처리 !
Processing guarantees in Kafka 참고
ConsumeKafka_2_6
📜 Property
⚙ Kafka Brokers
-
Kafka의 접속 주소 정보와 포트를 “,” 를 기준으로 입력
-
kafka1:9092,kafka2:9092,kafka3:9092
⚙ Topic Name(s)
- 메시지를 받을 토픽의 이름들을 지정
⚙ Group ID
- 메시지를 받을 그룹의 이름을 지정
⚙ Max Poll Records
- 카프카가 단일 폴링에서 리턴해야하는 최대 레코드 수를 지정
⚙ Max Uncommited Time
- 오프셋을 적용하기 전에 허용되는 최대 시간을 지정합니다. 이 값은 오프셋이 커밋되는 빈도에 영향을 줌
