Interface KafkaToMqttInput
-
@Immutable @DoNotImplement public interface KafkaToMqttInput
The input parameter of theKafkaToMqttTransformer
. It contains the information of the to be transformedKafkaRecord
.Additionally, the KafkaToMqttInput allows access to the
KafkaCluster
.- Since:
- 4.5.0
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description @NotNull KafkaCluster
getKafkaCluster()
@NotNull KafkaRecord
getKafkaRecord()
-
-
-
Method Detail
-
getKafkaRecord
@NotNull @NotNull KafkaRecord getKafkaRecord()
- Returns:
- The
KafkaRecord
that triggered this transformer call. - Since:
- 4.5.0
-
getKafkaCluster
@NotNull @NotNull KafkaCluster getKafkaCluster()
- Returns:
- The
KafkaCluster
the transformer is associated with. - Since:
- 4.5.0
-
-