Constant Field Values

org.apache.*

org.apache.camel.component.kafka.KafkaConstants

Modifier and Type	Constant Field	Value
public static final String	HEADERS	"CamelKafkaHeaders"
public static final String	KAFKA_DEFAULT_DESERIALIZER	"org.apache.kafka.common.serialization.StringDeserializer"
public static final String	KAFKA_DEFAULT_ENCODER	"kafka.serializer.DefaultEncoder"
public static final String	KAFKA_DEFAULT_SERIALIZER	"org.apache.kafka.common.serialization.StringSerializer"
public static final String	KAFKA_RECORD_META	"CamelKafkaRecordMeta"
public static final String	KAFKA_STRING_ENCODER	"kafka.serializer.StringEncoder"
public static final String	KAFKA_SUBSCRIBE_ADAPTER	"subscribeAdapter"
public static final String	KEY	"CamelKafkaKey"
public static final String	LAST_POLL_RECORD	"CamelKafkaLastPollRecord"
public static final String	LAST_RECORD_BEFORE_COMMIT	"CamelKafkaLastRecordBeforeCommit"
public static final String	MANUAL_COMMIT	"CamelKafkaManualCommit"
public static final String	OFFSET	"CamelKafkaOffset"
public static final String	OVERRIDE_TIMESTAMP	"CamelKafkaOverrideTimestamp"
public static final String	OVERRIDE_TOPIC	"CamelKafkaOverrideTopic"
public static final String	PARTITION	"CamelKafkaPartition"
public static final String	PARTITION_KEY	"CamelKafkaPartitionKey"
public static final String	PARTITIONER_RANGE_ASSIGNOR	"org.apache.kafka.clients.consumer.RangeAssignor"
public static final String	TIMESTAMP	"CamelKafkaTimestamp"
public static final String	TOPIC	"CamelKafkaTopic"

org.apache.camel.component.kafka.KafkaDevConsole

Modifier and Type	Constant Field	Value
public static final String	COMMITTED	"committed"

org.apache.camel.component.kafka.consumer.AbstractCommitManager

Modifier and Type	Constant Field	Value
public static final long	NON_PARTITION	-1L
public static final long	START_OFFSET	-1L