public static class KafkaProperties.Admin extends Object
Constructor and Description |
---|
Admin() |
Modifier and Type | Method and Description |
---|---|
Map<String,Object> |
buildProperties() |
String |
getClientId() |
Map<String,String> |
getProperties() |
KafkaProperties.Security |
getSecurity() |
KafkaProperties.Ssl |
getSsl() |
boolean |
isFailFast() |
void |
setClientId(String clientId) |
void |
setFailFast(boolean failFast) |
public KafkaProperties.Ssl getSsl()
public KafkaProperties.Security getSecurity()
public String getClientId()
public void setClientId(String clientId)
public boolean isFailFast()
public void setFailFast(boolean failFast)