Cloud Subscriber Configuration
Version: 1.0.0
The com.eurotech.framework.kafka.client.cloudconnection.subscriber.KafkaClientSubscriber allows interaction with the KafkaConsumer instance of the Cloud Connection. The configuration properties for the subscriber are detailed below.
Events received by the underlying KafkaConsumer are of type ProducerRecord. Such records have a fixed type for the key and the value and are deserialized as follows:
- value: is of type
byte[]and is deserialized using the defaultorg.apache.kafka.common.serialization.ByteArrayDeserializer. - key: is of type
java.lang.Stringand is deserialized using the defaultorg.apache.kafka.common.serialization.StringDeserializer.
Topic
Required field, sets the topic to which subscribe. Valid characters for Kafka topics match the following pattern:
[a-zA-Z0-9\._\-]
.) or underscore (_) could collide. To avoid issues it is best to use either, but not both.