Interface MqttToKafkaInput
-
@Immutable @DoNotImplement public interface MqttToKafkaInput
The input parameter of theMqttToKafkaTransformer
. It contains the information of the to be transformedPublishPacket
.Additionally, the MqttToKafkaInput allows access to the
KafkaCluster
and theKafkaTopicService
for this cluster.- Since:
- 4.4.0
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description @NotNull KafkaCluster
getKafkaCluster()
@NotNull KafkaTopicService
getKafkaTopicService()
@NotNull PublishPacket
getPublishPacket()
-
-
-
Method Detail
-
getPublishPacket
@NotNull @NotNull PublishPacket getPublishPacket()
- Returns:
- The
PublishPacket
that triggered this transformer call. - Since:
- 4.4.0
-
getKafkaTopicService
@NotNull @NotNull KafkaTopicService getKafkaTopicService()
- Returns:
- The
KafkaTopicService
to interact with topics on the Kafka cluster. - Since:
- 4.4.0
-
getKafkaCluster
@NotNull @NotNull KafkaCluster getKafkaCluster()
- Returns:
- The
KafkaCluster
this transformer is associated with. - Since:
- 4.4.0
-
-