pip_services3_kafka.connect.IKafkaMessageListener module

class pip_services3_kafka.connect.IKafkaMessageListener.IKafkaMessageListener

Bases: abc.ABC

The IKafkaMessageListener interface defines a Kafka message listener.

abstract on_message(topic: str, partition: int, message: cimpl.Message)

Defines the actions to be done after a message is received.

Parameters

• topic – topic

• partition – partition

• message – message