13 Ekim 2020 Salı

Apache Kafka API

Giriş 
Kafka API'si başlıklara ayrılmış. Başlıklar şöyle.
Producer API
Consumer API
Streams API
Connector API
API'lerin açıklaması şöyle
1) Producer API: It provides permission to the application to publish the stream of records.
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.
Producer API
Kafka Producer API yazısına taşıdım

Consumer API
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