public class Utils extends Object
Constructor and Description |
---|
Utils() |
Modifier and Type | Method and Description |
---|---|
static org.apache.kafka.clients.admin.AdminClient |
createAdminClient(String endpoint) |
static String |
getBrokerSessionUuid(Map<String,?> configs) |
static String |
requireNonEmpty(String value,
String argName) |