Modifier and Type |
Method and Description |
Map<String,Object> |
buildProperties() |
Duration |
getAutoCommitInterval() |
String |
getAutoOffsetReset() |
List<String> |
getBootstrapServers() |
String |
getClientId() |
Boolean |
getEnableAutoCommit() |
Duration |
getFetchMaxWait() |
DataSize |
getFetchMinSize() |
String |
getGroupId() |
Duration |
getHeartbeatInterval() |
KafkaProperties.IsolationLevel |
getIsolationLevel() |
Class<?> |
getKeyDeserializer() |
Integer |
getMaxPollRecords() |
Map<String,String> |
getProperties() |
KafkaProperties.Security |
getSecurity() |
KafkaProperties.Ssl |
getSsl() |
Class<?> |
getValueDeserializer() |
void |
setAutoCommitInterval(Duration autoCommitInterval) |
void |
setAutoOffsetReset(String autoOffsetReset) |
void |
setBootstrapServers(List<String> bootstrapServers) |
void |
setClientId(String clientId) |
void |
setEnableAutoCommit(Boolean enableAutoCommit) |
void |
setFetchMaxWait(Duration fetchMaxWait) |
void |
setFetchMinSize(DataSize fetchMinSize) |
void |
setGroupId(String groupId) |
void |
setHeartbeatInterval(Duration heartbeatInterval) |
void |
setIsolationLevel(KafkaProperties.IsolationLevel isolationLevel) |
void |
setKeyDeserializer(Class<?> keyDeserializer) |
void |
setMaxPollRecords(Integer maxPollRecords) |
void |
setValueDeserializer(Class<?> valueDeserializer) |