consumers
-
12 days of Apache Kafka - 7. ConsumersKafka 2021. 1. 17. 10:12
www.youtube.com/watch?v=Z9g4jMQwog0 KafkaConsumer 클러스터와 연결. 여러가지 설정을 map 으로 담는다. (몇몇 브로커들 주소, 보안 설정들... 등등) 위는 KafkaProducer 사용원칙과 같다. ConsumerRecords consumer 를 통해서 데이터를 읽어보고, 여러 가지 방식으로 우리가 원하는 메세지만 취할 수 있다. 해당 메세지를 consumerRecords 라는 곳에 받을 수 있다. 그리고 그 안에 consumerRecord 들이 들어있다. ConsumerRecord key-value pair 우리는 위 세가지를 이용하여 다루지만 Consumer 는 많은 일을 한다. connection 관리, 클러스터의 metadata 업데이트 등등... 그리고..