Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

The Kafka transport handler allows the reading and writing from/to Kafka.

Options

 Needs the feature de.uniol.inf.is.odysseus.wrapper.kafka.feature 

Options

Mandatory for reading and writing:

...

  • topic: String defining the kafka topic to read/write
  • messagetype: either 'string' or 'bytearray'; defines the type of values written to/read from Kafka

Mandatory for writing;

 

  • metadata.broker.list: comma separated list of Kafka brokers (host:port)

...

  • bootstrap.servers: comma separated list of Kafka brokers (host:port)

...

Optional:

  • All other properties possible for Kafka Producers and Consumers respectively (see Kafka documentation for possible properties)

...