IKafkaMessageListener

Defines a Kafka message listerner.

Description

The IKafkaMessageListener interface defines a Kafka message listener.

Instance methods

on_message

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

on_message(topic: str, partition: int, message: Message)

  • topic: str - topic
  • partition: int - partition
  • message: Message - message