ACKNOWLEDGMENT: 'kafka_acknowledgment'
|
|
BATCH_CONVERTED_HEADERS: 'kafka_batchConvertedHeaders'
|
|
CONSUMER: 'kafka_consumer'
|
|
CORRELATION_ID: 'kafka_correlationId'
|
|
DELIVERY_ATTEMPT: 'kafka_deliveryAttempt'
|
|
DLT_EXCEPTION_FQCN: 'kafka_dlt-exception-fqcn'
|
|
DLT_EXCEPTION_MESSAGE: 'kafka_dlt-exception-message'
|
|
DLT_EXCEPTION_STACKTRACE: 'kafka_dlt-exception-stacktrace'
|
|
DLT_ORIGINAL_OFFSET: 'kafka_dlt-original-offset'
|
|
DLT_ORIGINAL_PARTITION: 'kafka_dlt-original-partition'
|
|
DLT_ORIGINAL_TIMESTAMP: 'kafka_dlt-original-timestamp'
|
|
DLT_ORIGINAL_TIMESTAMP_TYPE: 'kafka_dlt-original-timestamp-type'
|
|
DLT_ORIGINAL_TOPIC: 'kafka_dlt-original-topic'
|
|
GROUP_ID: 'kafka_groupId'
|
|
MESSAGE_KEY: 'kafka_messageKey'
|
|
NATIVE_HEADERS: 'kafka_nativeHeaders'
|
|
OFFSET: 'kafka_offset'
|
|
PARTITION_ID: 'kafka_partitionId'
|
|
PREFIX: 'kafka_'
|
|
RAW_DATA: 'kafka_data'
|
|
RECEIVED: 'kafka_received'
|
|
RECEIVED_MESSAGE_KEY: 'kafka_receivedMessageKey'
|
|
RECEIVED_PARTITION_ID: 'kafka_receivedPartitionId'
|
|
RECEIVED_TIMESTAMP: 'kafka_receivedTimestamp'
|
|
RECEIVED_TOPIC: 'kafka_receivedTopic'
|
|
RECORD_METADATA: 'kafka_recordMetadata'
|
|
REPLY_PARTITION: 'kafka_replyPartition'
|
|
REPLY_TOPIC: 'kafka_replyTopic'
|
|
TIMESTAMP: 'kafka_timestamp'
|
|
TIMESTAMP_TYPE: 'kafka_timestampType'
|
|
TOPIC: 'kafka_topic'
|
|
NEST_ERR: 'kafka_nest-err'
|
|
NEST_IS_DISPOSED: 'kafka_nest-is-disposed'
|
|
