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 and delete.
  • It also supports response, events, and announcements for these operations.
  • A reactive-streams protocol for search is supported.
  • Messages not matching the protocol specification are ignored.

tip Find a description on how to create a connection at Manage your connections UI.

Find the complete documentation at Eclipse Ditto.

note 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).

Corporate information Data protection notice Legal information Support Free plans