Kafka Route
EC uses Apache Camel to route messages to an external Kafka destination.
| Parameter Name | Description | Default |
|---|---|---|
| Kafka Brokers | Comma separated list of Kafka brokers in the format host:port (or ip:port) | 127.0.0.1:9092 |
| Header Property | Header property name in the Camel message where Camel Kafka component will find the composed URL representing the endpoint to invoke. For most of the use cases the default configuration works good and should not to be changed. | evaluatedKafkaEndPoint |
| Original Topic | The name of the topic where the message was originally sent to by the device. By default it is read from the originalTopic property of the Camel message. It is used by Kafka to calculate the partition key. For most of the use cases the default configuration works good and should not to be changed. | $simple{in.header.originalTopic} |
| Header Topic value | The Kafka topic where the message will be published. The string enclosed within the brackets must be a variable recognized by the routing service. Currently ACCOUNT variable is supported. At runtime it is evaluated with the account name. Optionally a string literal can be specified (like for example "mytopic" or "baseName.${ACCOUNT}"). The literal must be a valid name for a Kafka topic. By default the topic name is the name of the account. | ${ACCOUNT} |
| Key Serializer | Kafka key serializer. For the serializers provided by Kafka please refer to the Kafka documentation. | org.apache.kafka.common.serialization.StringSerializer |
| Serializer | Kafka message serializer. For the serializers provided by Kafka please refer to the Kafka documentation. | org.apache.kafka.common.serialization.StringSerializer |
| Url Options | Additional Kafka endpoint options. This field allows to specify more parameters to be used by the Kafka client. The options are added to the composed URL. For the available client parameters please refer to the Kafka client documentation. | Example: to enable the SASL authentication this field should be set as follow: "&securityProtocol=SASL_PLAINTEXT&saslMechanism=PLAIN". For more details regarding security configuration refer to section Kafka Integration |
Supported Kafka Clients
The currently supported Kafka client version is 0.10.2.0
Topic Names
Kafka allows only few characters in the topic (regex coming from the Kafka source code "[a-zA-Z0-9._-]"). Please take care of this limitation while setting the topic name route field.
Updated over 6 years ago