Class KafkaDefaultMessageReceiver

java.lang.Object
com.technia.tif.enovia.kafka.KafkaDefaultMessageReceiver
All Implemented Interfaces:
KafkaMessageReceiver

@API public class KafkaDefaultMessageReceiver extends Object implements KafkaMessageReceiver
Default no-op implementation of KafkaMessageReceiver.

KafkaDefaultMessageReceiver provides a minimal implementation of the KafkaMessageReceiver interface where incoming messages are intentionally ignored.

This class can be used as a placeholder or base implementation when no message handling logic is required, or as a starting point for custom receivers that override the onMessage(KafkaMessageContext) method.

By default, the onMessage method performs no action.

Since:
2026.2.0
  • Constructor Details

    • KafkaDefaultMessageReceiver

      public KafkaDefaultMessageReceiver()
  • Method Details

    • onMessage

      public void onMessage(KafkaMessageContext ctx)
      Handles an incoming Kafka message.

      This default implementation performs no processing. Subclasses may override this method to implement custom message handling logic.

      Specified by:
      onMessage in interface KafkaMessageReceiver
      Parameters:
      ctx - the KafkaMessageContext associated with the message
    • onException

      public void onException(KafkaMessageContext ctx)
      Handles an exception occurred while processing the message.

      This default implementation performs nothing. Subclasses may override this method to implement custom logic.

      Specified by:
      onException in interface KafkaMessageReceiver
      Parameters:
      ctx - the KafkaMessageContext associated with the message and exception