public class Utils extends Object
Modifier and Type | Field and Description |
---|---|
static String |
EVENTS_METADATA_HEADER_KEY |
static String |
SEQUENCE_ID_STRING_HEADER_KEY |
Constructor and Description |
---|
Utils() |
Modifier and Type | Method and Description |
---|---|
static org.apache.kafka.clients.admin.AdminClient |
createAdminClient(String endpoint) |
static org.apache.kafka.clients.admin.ConfluentAdmin |
createConfluentAdmin(String endpoint) |
public static final String SEQUENCE_ID_STRING_HEADER_KEY
public static final String EVENTS_METADATA_HEADER_KEY