All Classes
-
All Classes Interface Summary Enum Summary Class Description KafkaCluster This interface provides information about a<kafka-cluster>
as it is configured in thekafka-extension.xml
.KafkaHeader Represents the header of a Kafka record, that was either read from or should be written to a Kafka cluster.KafkaHeaders This interface contains allKafkaHeader
s belonging to a singleKafkaRecord
.KafkaRecord Represents a Kafka record, that was either read from or should be written to a Kafka cluster.KafkaRecordBuilder The KafkaRecordBuilder enables the creation ofKafkaRecord
s via its fluent API.KafkaToMqttInitInput Provides context for the setup of aKafkaToMqttTransformer
.KafkaToMqttInput The input parameter of theKafkaToMqttTransformer
.KafkaToMqttOutput The output parameter of theKafkaToMqttTransformer
.KafkaToMqttTransformer Implement this transformer for the programmatic creation ofPublishes
fromKafkaRecords
.KafkaTopicService The KafkaTopicService enables the programmatic interaction with Kafka topics.KafkaTopicService.KafkaTopicState KafkaTopicState encodes the current known state of a Kafka topic on the associated cluster.MqttToKafkaInitInput Provides context for the setup of aMqttToKafkaTransformer
.MqttToKafkaInput The input parameter of theMqttToKafkaTransformer
.MqttToKafkaOutput The output parameter of theMqttToKafkaTransformer
.MqttToKafkaTransformer Implement this transformer for the programmatic creation ofKafkaRecord
s fromPublishPacket
s.Transformer<I extends TransformerInitInput> This is the base interface for all "HiveMQ Enterprise Extension for Kafka" transformer.TransformerInitInput A marker interface for the input object of theTransformer.init(TransformerInitInput)
method.