MqttToKafkaInitInput (HiveMQ Kafka Extension Customization SDK 4.28.1 API)

All Superinterfaces:

TransformerInitInput
```
@Immutable
@DoNotImplement
public interface MqttToKafkaInitInput
extends TransformerInitInput
```
Provides context for the setup of a MqttToKafkaTransformer.

Since:

4.4.0

- Method Summary
  
  All Methods Instance Methods Abstract Methods
  Modifier and Type Method Description
  
  @NotNull KafkaCluster getKafkaCluster()
  
  @NotNull KafkaTopicService getKafkaTopicService()
  - Methods inherited from interface com.hivemq.extensions.kafka.api.transformers.TransformerInitInput
    getMetricRegistry

- Method Detail
  - getKafkaCluster
```
@NotNull
@NotNull KafkaCluster getKafkaCluster()
```
    Returns:
    
    The KafkaCluster this transformer is associated with.
    
    Since:
    
    4.4.0
  - getKafkaTopicService
```
@NotNull
@NotNull KafkaTopicService getKafkaTopicService()
```
    Returns:
    
    The KafkaTopicService to interact with topics on the Kafka cluster.
    
    Since:
    
    4.4.0