Kafka API'si başlıklara ayrılmış. Başlıklar şöyle.
Producer APIAPI'lerin açıklaması şöyle
Consumer API
Streams API
Connector API
1) Producer API: It provides permission to the application to publish the stream of records.Producer API
2) Consumer API: This API is being used to subscribe to the topics.
3) Stream API: This Stream provides the result after converting the input stream into the output stream.
4) Connector API: This links the topics with existing applications.
Kafka Producer API yazısına taşıdım
Consumer API
Açıklaması şöyle.
Açıklaması şöyle.
The Consumer API allows an application to subscribe to one or more topics and process the stream of records produced to them.
Java örneklerini Kafka Consumer API yazısına taşıdım
Subscribe ve Self Assign Farkı
Consumer API iki farklı şekilde kullanılabilir.
1. Subscribe Olarak
2. Self Assign'ı seçip partition 'a direkt gidip okuyarak
Subscribe yönteminde Rebalance sorumluluğu Kafka üzerinde.
Self Assign yönteminde Rebalance sorumluluğu uygulamanın üzerinde
Consumer Config Parametreleri
Consumer Config Parametreleri yazısına taşıdım.
Streams API
Kafka Streams API yazısına taşıdım
Hiç yorum yok:
Yorum Gönder