Receive data from Kafka topics on an insecure broker.
Metadata
Property
Value
Type
source
Group
Kafka
Namespace
Kafka
Support Level
Stable
Provider
Apache Software Foundation
Properties
Name
Type
Required
Default
Description
topic
string
✓
Comma separated list of Kafka topic names
bootstrapServers
string
✓
Comma separated list of Kafka Broker URLs
autoCommitEnable
boolean
true
If true, periodically commit to ZooKeeper the offset of messages already fetched by the consumer
allowManualCommit
boolean
false
Whether to allow doing manual commits
pollOnError
string
ERROR_HANDLER
What to do if kafka threw an exception while polling for new messages. There are 5 enums and the value can be one of DISCARD, ERROR_HANDLER, RECONNECT, RETRY, STOP
autoOffsetReset
string
latest
What to do when there is no initial offset. There are 3 enums and the value can be one of latest, earliest, none
consumerGroup
string
A string that uniquely identifies the group of consumers to which this source belongs
deserializeHeaders
boolean
true
When enabled the Kamelet source will deserialize all message headers to String representation.
topicIsPattern
boolean
false
Whether the topic is a pattern (regular expression). This can be used to subscribe to dynamic number of topics matching the pattern.
Dependencies
camel:kafka
camel:core
camel:kamelet
Delete Page
Deleting the wiki page "Home" cannot be undone. Continue?