A B C E F G H I K M N P S T V
All Classes All Packages
All Classes All Packages
All Classes All Packages
A
- asList() - Method in interface com.hivemq.extensions.kafka.api.model.KafkaHeaders
B
- build() - Method in interface com.hivemq.extensions.kafka.api.builders.KafkaRecordBuilder
-
Create a new
KafkaRecord
from the current state of this builder.
C
- com.hivemq.extensions.kafka.api.builders - package com.hivemq.extensions.kafka.api.builders
- com.hivemq.extensions.kafka.api.model - package com.hivemq.extensions.kafka.api.model
- com.hivemq.extensions.kafka.api.services - package com.hivemq.extensions.kafka.api.services
- com.hivemq.extensions.kafka.api.transformers - package com.hivemq.extensions.kafka.api.transformers
- com.hivemq.extensions.kafka.api.transformers.kafkatomqtt - package com.hivemq.extensions.kafka.api.transformers.kafkatomqtt
- com.hivemq.extensions.kafka.api.transformers.mqtttokafka - package com.hivemq.extensions.kafka.api.transformers.mqtttokafka
- CREATED - com.hivemq.extensions.kafka.api.services.KafkaTopicService.KafkaTopicState
-
This topic was created on the associated Kafka cluster.
- createKafkaTopic(String) - Method in interface com.hivemq.extensions.kafka.api.services.KafkaTopicService
-
Create a single Kafka topic on the associated cluster.
- createKafkaTopics(Set<String>) - Method in interface com.hivemq.extensions.kafka.api.services.KafkaTopicService
-
Create multiple Kafka topics on the associated cluster.
E
- EXISTS - com.hivemq.extensions.kafka.api.services.KafkaTopicService.KafkaTopicState
-
This topic already exists on the associated Kafka cluster.
F
- FAILURE - com.hivemq.extensions.kafka.api.services.KafkaTopicService.KafkaTopicState
-
FAILURE signals that the operation for the topic was not successful.
G
- getAllForName(String) - Method in interface com.hivemq.extensions.kafka.api.model.KafkaHeaders
- getBootstrapServers() - Method in interface com.hivemq.extensions.kafka.api.model.KafkaCluster
- getHeaders() - Method in interface com.hivemq.extensions.kafka.api.model.KafkaRecord
- getId() - Method in interface com.hivemq.extensions.kafka.api.model.KafkaCluster
- getKafkaCluster() - Method in interface com.hivemq.extensions.kafka.api.transformers.kafkatomqtt.KafkaToMqttInput
- getKafkaCluster() - Method in interface com.hivemq.extensions.kafka.api.transformers.mqtttokafka.MqttToKafkaInitInput
- getKafkaCluster() - Method in interface com.hivemq.extensions.kafka.api.transformers.mqtttokafka.MqttToKafkaInput
- getKafkaRecord() - Method in interface com.hivemq.extensions.kafka.api.transformers.kafkatomqtt.KafkaToMqttInput
- getKafkaTopicService() - Method in interface com.hivemq.extensions.kafka.api.transformers.mqtttokafka.MqttToKafkaInitInput
- getKafkaTopicService() - Method in interface com.hivemq.extensions.kafka.api.transformers.mqtttokafka.MqttToKafkaInput
- getKafkaTopicState(String) - Method in interface com.hivemq.extensions.kafka.api.services.KafkaTopicService
-
Query the state of a single Kafka topic on the associated cluster.
- getKafkaTopicStates(Set<String>) - Method in interface com.hivemq.extensions.kafka.api.services.KafkaTopicService
-
Query the states of multiple Kafka topics on the associated cluster.
- getKey() - Method in interface com.hivemq.extensions.kafka.api.model.KafkaHeader
- getKey() - Method in interface com.hivemq.extensions.kafka.api.model.KafkaRecord
- getKeyAsByteArray() - Method in interface com.hivemq.extensions.kafka.api.model.KafkaRecord
- getLast(String) - Method in interface com.hivemq.extensions.kafka.api.model.KafkaHeaders
- getMetricRegistry() - Method in interface com.hivemq.extensions.kafka.api.transformers.TransformerInitInput
-
Get the
MetricRegistry
of this HiveMQ node. - getOffset() - Method in interface com.hivemq.extensions.kafka.api.model.KafkaRecord
- getPartition() - Method in interface com.hivemq.extensions.kafka.api.model.KafkaRecord
- getPublishPacket() - Method in interface com.hivemq.extensions.kafka.api.transformers.mqtttokafka.MqttToKafkaInput
- getTimestamp() - Method in interface com.hivemq.extensions.kafka.api.model.KafkaRecord
- getTopic() - Method in interface com.hivemq.extensions.kafka.api.model.KafkaRecord
- getValue() - Method in interface com.hivemq.extensions.kafka.api.model.KafkaHeader
- getValue() - Method in interface com.hivemq.extensions.kafka.api.model.KafkaRecord
- getValueAsByteArray() - Method in interface com.hivemq.extensions.kafka.api.model.KafkaHeader
- getValueAsByteArray() - Method in interface com.hivemq.extensions.kafka.api.model.KafkaRecord
- getValueAsString() - Method in interface com.hivemq.extensions.kafka.api.model.KafkaHeader
- getValueAsString(Charset) - Method in interface com.hivemq.extensions.kafka.api.model.KafkaHeader
H
- header(String, byte[]) - Method in interface com.hivemq.extensions.kafka.api.builders.KafkaRecordBuilder
-
Add a header to the Kafka record.
- header(String, String) - Method in interface com.hivemq.extensions.kafka.api.builders.KafkaRecordBuilder
-
Add a header to the Kafka record.
- header(String, String, Charset) - Method in interface com.hivemq.extensions.kafka.api.builders.KafkaRecordBuilder
-
Add a header to the Kafka record.
- header(String, ByteBuffer) - Method in interface com.hivemq.extensions.kafka.api.builders.KafkaRecordBuilder
-
Add a header to the Kafka record.
I
- init(I) - Method in interface com.hivemq.extensions.kafka.api.transformers.Transformer
-
Use the init method to set up static runtime context for the execution of your transformer.
K
- KafkaCluster - Interface in com.hivemq.extensions.kafka.api.model
-
This interface provides information about a
<kafka-cluster>
as it is configured in thekafka-extension.xml
. - KafkaHeader - Interface in com.hivemq.extensions.kafka.api.model
-
Represents the header of a Kafka record, that was either read from or should be written to a Kafka cluster.
- KafkaHeaders - Interface in com.hivemq.extensions.kafka.api.model
-
This interface contains all
KafkaHeader
s belonging to a singleKafkaRecord
. - KafkaRecord - Interface in com.hivemq.extensions.kafka.api.model
-
Represents a Kafka record, that was either read from or should be written to a Kafka cluster.
- KafkaRecordBuilder - Interface in com.hivemq.extensions.kafka.api.builders
-
The KafkaRecordBuilder enables the creation of
KafkaRecord
s via its fluent API. - KafkaToMqttInitInput - Interface in com.hivemq.extensions.kafka.api.transformers.kafkatomqtt
-
Provides context for the setup of a
KafkaToMqttTransformer
. - KafkaToMqttInput - Interface in com.hivemq.extensions.kafka.api.transformers.kafkatomqtt
-
The input parameter of the
KafkaToMqttTransformer
. - KafkaToMqttOutput - Interface in com.hivemq.extensions.kafka.api.transformers.kafkatomqtt
-
The output parameter of the
KafkaToMqttTransformer
. - KafkaToMqttTransformer - Interface in com.hivemq.extensions.kafka.api.transformers.kafkatomqtt
-
Implement this transformer for the programmatic creation of
Publishes
fromKafkaRecords
. - KafkaTopicService - Interface in com.hivemq.extensions.kafka.api.services
-
The KafkaTopicService enables the programmatic interaction with Kafka topics.
- KafkaTopicService.KafkaTopicState - Enum in com.hivemq.extensions.kafka.api.services
-
KafkaTopicState encodes the current known state of a Kafka topic on the associated cluster.
- key(byte[]) - Method in interface com.hivemq.extensions.kafka.api.builders.KafkaRecordBuilder
-
Set the key of the Kafka record.
- key(String) - Method in interface com.hivemq.extensions.kafka.api.builders.KafkaRecordBuilder
-
Set the key of the Kafka record.
- key(String, Charset) - Method in interface com.hivemq.extensions.kafka.api.builders.KafkaRecordBuilder
-
Set the key of the Kafka record.
- key(ByteBuffer) - Method in interface com.hivemq.extensions.kafka.api.builders.KafkaRecordBuilder
-
Set the key of the Kafka record.
M
- MISSING - com.hivemq.extensions.kafka.api.services.KafkaTopicService.KafkaTopicState
-
This topic is missing from the associated Kafka cluster and may need to be created before a record can be published to it.
- MqttToKafkaInitInput - Interface in com.hivemq.extensions.kafka.api.transformers.mqtttokafka
-
Provides context for the setup of a
MqttToKafkaTransformer
. - MqttToKafkaInput - Interface in com.hivemq.extensions.kafka.api.transformers.mqtttokafka
-
The input parameter of the
MqttToKafkaTransformer
. - MqttToKafkaOutput - Interface in com.hivemq.extensions.kafka.api.transformers.mqtttokafka
-
The output parameter of the
MqttToKafkaTransformer
. - MqttToKafkaTransformer - Interface in com.hivemq.extensions.kafka.api.transformers.mqtttokafka
-
Implement this transformer for the programmatic creation of
KafkaRecord
s fromPublishPacket
s.
N
- newKafkaRecordBuilder() - Method in interface com.hivemq.extensions.kafka.api.transformers.mqtttokafka.MqttToKafkaOutput
-
Create a new
KafkaRecordBuilder
. - newPublishBuilder() - Method in interface com.hivemq.extensions.kafka.api.transformers.kafkatomqtt.KafkaToMqttOutput
P
- partition(int) - Method in interface com.hivemq.extensions.kafka.api.builders.KafkaRecordBuilder
-
Set the partition number of the Kafka record.
S
- setKafkaRecords(List<KafkaRecord>) - Method in interface com.hivemq.extensions.kafka.api.transformers.mqtttokafka.MqttToKafkaOutput
-
Sets the
KafkaRecord
s, that will be pushed to the associated Kafka cluster after theMqttToKafkaTransformer.transformMqttToKafka(MqttToKafkaInput, MqttToKafkaOutput)
call returns. - setPublishes(List<Publish>) - Method in interface com.hivemq.extensions.kafka.api.transformers.kafkatomqtt.KafkaToMqttOutput
-
Sets the
Publish
es, that will be published by HiveMQ after theKafkaToMqttTransformer.transformKafkaToMqtt(KafkaToMqttInput, KafkaToMqttOutput)
call returns.
T
- timestamp(long) - Method in interface com.hivemq.extensions.kafka.api.builders.KafkaRecordBuilder
-
Set the timestamp of the Kafka record.
- topic(String) - Method in interface com.hivemq.extensions.kafka.api.builders.KafkaRecordBuilder
-
Set the topic of the Kafka record.
- Transformer<I extends TransformerInitInput> - Interface in com.hivemq.extensions.kafka.api.transformers
-
This is the base interface for all "HiveMQ Enterprise Extension for Kafka" transformer.
- TransformerInitInput - Interface in com.hivemq.extensions.kafka.api.transformers
-
A marker interface for the input object of the
Transformer.init(TransformerInitInput)
method. - transformKafkaToMqtt(KafkaToMqttInput, KafkaToMqttOutput) - Method in interface com.hivemq.extensions.kafka.api.transformers.kafkatomqtt.KafkaToMqttTransformer
-
This callback is executed for every
KafkaRecord
that the "HiveMQ Enterprise Extension for Kafka" polls from Kafka according to the configured<kafka-topics>
in the<kafka-to-mqtt-transformer>
tag. - transformMqttToKafka(MqttToKafkaInput, MqttToKafkaOutput) - Method in interface com.hivemq.extensions.kafka.api.transformers.mqtttokafka.MqttToKafkaTransformer
-
This callback is executed for every MQTT PUBLISH that arrives at your HiveMQ cluster matching the in the
<mqtt-to-kafka-transformer>
tag configured<mqtt-topic-filters>
.
V
- value(byte[]) - Method in interface com.hivemq.extensions.kafka.api.builders.KafkaRecordBuilder
-
Set the value of the Kafka record.
- value(String) - Method in interface com.hivemq.extensions.kafka.api.builders.KafkaRecordBuilder
-
Set the value of the Kafka record.
- value(String, Charset) - Method in interface com.hivemq.extensions.kafka.api.builders.KafkaRecordBuilder
-
Set the value of the Kafka record.
- value(ByteBuffer) - Method in interface com.hivemq.extensions.kafka.api.builders.KafkaRecordBuilder
-
Set the value of the Kafka record.
- valueOf(String) - Static method in enum com.hivemq.extensions.kafka.api.services.KafkaTopicService.KafkaTopicState
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum com.hivemq.extensions.kafka.api.services.KafkaTopicService.KafkaTopicState
-
Returns an array containing the constants of this enum type, in the order they are declared.
All Classes All Packages