All Classes

Class	Description
DefaultKafkaClientFactory
DefaultKafkaHeaderDeserializer
DefaultKafkaHeaderSerializer
DefaultKafkaManualCommit
DefaultKafkaManualCommitFactory
DefaultPollExceptionStrategy
KafkaClientFactory	Factory to create a new KafkaConsumer and KafkaProducer instances.
KafkaComponent
KafkaComponentConfigurer	Generated by camel build tools - do NOT edit this file!
KafkaConfiguration
KafkaConstants
KafkaConsumer
KafkaEndpoint	Sent and receive messages to/from an Apache Kafka broker.
KafkaEndpointConfigurer	Generated by camel build tools - do NOT edit this file!
KafkaEndpointUriFactory	Generated by camel build tools - do NOT edit this file!
KafkaHeaderDeserializer	Deserializer for kafka header value.
KafkaHeaderFilterStrategy
KafkaHeaderSerializer	Serializer for kafka header value.
KafkaIdempotentRepository	A Kafka topic-based implementation of IdempotentRepository.
KafkaManualCommit	Can be used for forcing manual offset commit when using Kafka consumer.
KafkaManualCommitFactory	Factory to create a new KafkaManualCommit to store on the Exchange.
KafkaProducer
KafkaSendDynamicAware	Kafka based SendDynamicAware which allows to optimise Kafka components with the toD (dynamic to) DSL in Camel.
PollExceptionStrategy	Strategy to decide when a Kafka exception was thrown during polling, how to handle this.
PollOnError	DISCARD will discard the message and continue to poll next message.