public class KafkaConsumerProperties extends Object
Thanks to Laszlo Szabo for providing the initial patch for generic property support.
Modifier and Type | Class and Description |
---|---|
static class |
KafkaConsumerProperties.StartOffset |
Constructor and Description |
---|
KafkaConsumerProperties() |
Modifier and Type | Method and Description |
---|---|
Boolean |
getAutoCommitOnError() |
Map<String,String> |
getConfiguration() |
int |
getRecoveryInterval() |
KafkaConsumerProperties.StartOffset |
getStartOffset() |
boolean |
isAutoCommitOffset() |
boolean |
isAutoRebalanceEnabled() |
boolean |
isEnableDlq() |
boolean |
isResetOffsets() |
void |
setAutoCommitOffset(boolean autoCommitOffset) |
void |
setAutoCommitOnError(Boolean autoCommitOnError) |
void |
setAutoRebalanceEnabled(boolean autoRebalanceEnabled) |
void |
setConfiguration(Map<String,String> configuration) |
void |
setEnableDlq(boolean enableDlq) |
void |
setRecoveryInterval(int recoveryInterval) |
void |
setResetOffsets(boolean resetOffsets) |
void |
setStartOffset(KafkaConsumerProperties.StartOffset startOffset) |
public boolean isAutoCommitOffset()
public void setAutoCommitOffset(boolean autoCommitOffset)
public boolean isResetOffsets()
public void setResetOffsets(boolean resetOffsets)
public KafkaConsumerProperties.StartOffset getStartOffset()
public void setStartOffset(KafkaConsumerProperties.StartOffset startOffset)
public boolean isEnableDlq()
public void setEnableDlq(boolean enableDlq)
public Boolean getAutoCommitOnError()
public void setAutoCommitOnError(Boolean autoCommitOnError)
public int getRecoveryInterval()
public void setRecoveryInterval(int recoveryInterval)
public boolean isAutoRebalanceEnabled()
public void setAutoRebalanceEnabled(boolean autoRebalanceEnabled)
Copyright © 2016 Pivotal Software, Inc.. All rights reserved.