@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() |
public KafkaComponentConfiguration.KafkaConfigurationNestedConfiguration getConfiguration()
public void setConfiguration(KafkaComponentConfiguration.KafkaConfigurationNestedConfiguration configuration)
public String getBrokers()
public void setBrokers(String brokers)
public ExecutorService getWorkerPool()
public void setWorkerPool(ExecutorService 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 org.apache.camel.component.kafka.KafkaManualCommitFactory getKafkaManualCommitFactory()
public void setKafkaManualCommitFactory(org.apache.camel.component.kafka.KafkaManualCommitFactory kafkaManualCommitFactory)
public Boolean getResolvePropertyPlaceholders()
public void setResolvePropertyPlaceholders(Boolean resolvePropertyPlaceholders)
Apache Camel