The Apache Kafka event receiver reads the tail of a given file and inputs that to the WSO2 product engine. This feature is donated by Andres Gomez Ferrer . For more information, go to Apache Kafka documentation.
...
Creating an Kafka event receiver
For instructions on creating an Apache Kafka event an Apache Kafka event receiver, see Receiving Events Configuring Event Receivers.
Configuring adapter properties
...
Adapter Property | Description | Configuration file property | Example |
|---|---|---|---|
Server Zookeeper IP | IP address of the Zookeeper Server | zookeeper.connect | 127.0.0.1 |
Group ID Kafka | Kafka consumer group id which uniquely identifies a set of consumers within the same consumer group | group.id | groupid |
Threads | Number of consumer threads | threads | 4 |
| Optional Configuration Properties | Valid property and value pairs to denote optional configuration properties for Apache Kafka. (E.g. "property1: value1, property2: value2") For more information on Axis2 JMS properties, go to Apache Kafka Documentation. | optional.configuration | zk.sessiontimeout.ms:6000 |
| Topic Kafka | Name of the Kafka topic to which, input messages are published | topic | test_topic |
| Is events duplicated in cluster | In a cluster whether the same event can reach two receiver nodes | events.duplicated.in.cluster | true/false |
...