WSO2 Complex Event Processor is succeeded by WSO2 Stream Processor. To view the latest documentation for WSO2 SP, see WSO2 Stream Processor Documentation.

Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Adapter Property
Description
Configuration file propertyExample

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 Kafka properties, go to Apache Kafka Documentation.

optional.configurationzk.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

...