Skip to content

Kafka message fetcher

KafkaMessage(data)

An internal representation of a Kafka message

PARAMETER DESCRIPTION
data

The received Kafka message as byte array

KafkaMessageFetcher(consumer)

Fetches the next message from Kafka

PARAMETER DESCRIPTION
consumer

The Kafka consumer

TYPE: Consumer