public abstract class KafkaHeaders
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
static java.lang.String |
ACKNOWLEDGMENT |
static java.lang.String |
MESSAGE_KEY |
static java.lang.String |
NEXT_OFFSET |
static java.lang.String |
OFFSET |
static java.lang.String |
PARTITION_ID |
static java.lang.String |
TOPIC |
| Constructor and Description |
|---|
KafkaHeaders() |
public static final java.lang.String TOPIC
public static final java.lang.String MESSAGE_KEY
public static final java.lang.String PARTITION_ID
public static final java.lang.String OFFSET
public static final java.lang.String NEXT_OFFSET
public static final java.lang.String ACKNOWLEDGMENT