A B C E F G H I K M N P S T V
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 the kafka-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 KafkaHeaders belonging to a single KafkaRecord.

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 KafkaRecords 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 from KafkaRecords.

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 KafkaRecords from PublishPackets.

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 KafkaRecords, that will be pushed to the associated Kafka cluster after the MqttToKafkaTransformer.transformMqttToKafka(MqttToKafkaInput, MqttToKafkaOutput) call returns.

setPublishes(List<Publish>) - Method in interface com.hivemq.extensions.kafka.api.transformers.kafkatomqtt.KafkaToMqttOutput

Sets the Publishes, that will be published by HiveMQ after the KafkaToMqttTransformer.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.

A B C E F G H I K M N P S T V
All Classes All Packages