Apache Kafka 2.x
This protocol binding for Apache Kafka 2.x supports sending and receiving messages from and to a Kafka system.
How it works:
- It supports command messages for
create
,retrieve
,modify
anddelete
. - It also supports
response
,events
, andannouncements
for these operations. - A reactive-streams protocol for
search
is supported. - Messages not matching the protocol specification are ignored.
Find a description on how to create a connection at Manage your connections UI.
Find the complete documentation at Eclipse Ditto.
Currently consuming from Kafka is only supported with at-most-once semantics (QoS 0). We are working on to also support at-least-once semantics (QoS 1).