File tree Expand file tree Collapse file tree 2 files changed +3
-3
lines changed
src/main/java/com/hivemq/extensions/kafka/api Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change 23
23
import java .nio .charset .Charset ;
24
24
25
25
/**
26
- * * Represents the header of a Kafka record, that was either read from or should be written to a Kafka cluster.
26
+ * Represents the header of a Kafka record, that was either read from or should be written to a Kafka cluster.
27
27
* <p>
28
28
* The internal state of this interface is completely immutable. All returned {@link ByteBuffer}s are read only and a
29
29
* deep copy of any {@code byte[]} is made for every method call returning one.
Original file line number Diff line number Diff line change 24
24
* Implement this transformer for the programmatic creation of {@link com.hivemq.extensions.kafka.api.model.KafkaRecord}s
25
25
* from {@link com.hivemq.extension.sdk.api.packets.publish.PublishPacket}s.
26
26
* <p>
27
- * Your implementation of the MqttToKafkaTransformer must be placed in a java archive (.jar) together with all its
27
+ * Your implementation of the MqttToKafkaTransformer must be placed in a java archive (.jar) together with all its
28
28
* dependencies in the {@code extensions} folder of the HiveMQ Enterprise Extension for Kafka. In addition a {@code
29
29
* <mqtt-to-kafka-transformer>} referencing the implementing class via its canonical name must be configured in the
30
30
* {@code kafka-extension.xml} file.
36
36
public interface MqttToKafkaTransformer extends Transformer <MqttToKafkaInitInput > {
37
37
38
38
/**
39
- * This callback is executed for every mqtt PUBLISH that arrives at your HiveMQ cluster matching the in the {@code
39
+ * This callback is executed for every MQTT PUBLISH that arrives at your HiveMQ cluster matching the in the {@code
40
40
* <mqtt-to-kafka-transformer>} tag configured {@code <mqtt-topic-filters>}. It allows the publication of any number
41
41
* of {@link com.hivemq.extensions.kafka.api.model.KafkaRecord}s via the {@link MqttToKafkaOutput} object.
42
42
*
You can’t perform that action at this time.
0 commit comments