@Generated(value="org.apache.camel.maven.packaging.SpringBootAutoConfigurationMojo") @ConfigurationProperties(prefix="camel.component.kafka") public class KafkaComponentConfiguration extends org.apache.camel.spring.boot.ComponentConfigurationPropertiesCommon
Modifier and Type | Class and Description |
---|---|
static class |
KafkaComponentConfiguration.KafkaConfigurationNestedConfiguration |
Constructor and Description |
---|
KafkaComponentConfiguration() |
Modifier and Type | Method and Description |
---|---|
Boolean |
getAllowManualCommit() |
Boolean |
getBreakOnFirstError() |
String |
getBrokers() |
KafkaComponentConfiguration.KafkaConfigurationNestedConfiguration |
getConfiguration() |
String |
getKafkaManualCommitFactory() |
Boolean |
getResolvePropertyPlaceholders() |
Boolean |
getUseGlobalSslContextParameters() |
String |
getWorkerPool() |
void |
setAllowManualCommit(Boolean allowManualCommit) |
void |
setBreakOnFirstError(Boolean breakOnFirstError) |
void |
setBrokers(String brokers) |
void |
setConfiguration(KafkaComponentConfiguration.KafkaConfigurationNestedConfiguration configuration) |
void |
setKafkaManualCommitFactory(String kafkaManualCommitFactory) |
void |
setResolvePropertyPlaceholders(Boolean resolvePropertyPlaceholders) |
void |
setUseGlobalSslContextParameters(Boolean useGlobalSslContextParameters) |
void |
setWorkerPool(String workerPool) |
public KafkaComponentConfiguration.KafkaConfigurationNestedConfiguration getConfiguration()
public void setConfiguration(KafkaComponentConfiguration.KafkaConfigurationNestedConfiguration configuration)
public String getBrokers()
public void setBrokers(String brokers)
public String getWorkerPool()
public void setWorkerPool(String workerPool)
public Boolean getUseGlobalSslContextParameters()
public void setUseGlobalSslContextParameters(Boolean useGlobalSslContextParameters)
public Boolean getBreakOnFirstError()
public void setBreakOnFirstError(Boolean breakOnFirstError)
public Boolean getAllowManualCommit()
public void setAllowManualCommit(Boolean allowManualCommit)
public String getKafkaManualCommitFactory()
public void setKafkaManualCommitFactory(String kafkaManualCommitFactory)
public Boolean getResolvePropertyPlaceholders()
public void setResolvePropertyPlaceholders(Boolean resolvePropertyPlaceholders)
Apache Camel