public static class KafkaComponentConfiguration.KafkaConfigurationNestedConfiguration extends Object
Modifier and Type | Field and Description |
---|---|
static Class |
CAMEL_NESTED_CLASS |
Constructor and Description |
---|
KafkaConfigurationNestedConfiguration() |
public static final Class CAMEL_NESTED_CLASS
public KafkaConfigurationNestedConfiguration()
public Boolean getTopicIsPattern()
public void setTopicIsPattern(Boolean topicIsPattern)
public String getGroupId()
public void setGroupId(String groupId)
public Boolean getBridgeEndpoint()
public void setBridgeEndpoint(Boolean bridgeEndpoint)
public Boolean getCircularTopicDetection()
public void setCircularTopicDetection(Boolean circularTopicDetection)
public String getPartitioner()
public void setPartitioner(String partitioner)
public String getTopic()
public void setTopic(String topic)
public Integer getConsumerStreams()
public void setConsumerStreams(Integer consumerStreams)
public Integer getConsumersCount()
public void setConsumersCount(Integer consumersCount)
public String getClientId()
public void setClientId(String clientId)
public Boolean getAutoCommitEnable()
public void setAutoCommitEnable(Boolean autoCommitEnable)
public Boolean getAllowManualCommit()
public void setAllowManualCommit(Boolean allowManualCommit)
public Integer getShutdownTimeout()
public void setShutdownTimeout(Integer shutdownTimeout)
public org.apache.camel.spi.StateRepository getOffsetRepository()
public void setOffsetRepository(org.apache.camel.spi.StateRepository offsetRepository)
public Integer getAutoCommitIntervalMs()
public void setAutoCommitIntervalMs(Integer autoCommitIntervalMs)
public Integer getFetchMinBytes()
public void setFetchMinBytes(Integer fetchMinBytes)
public Integer getFetchMaxBytes()
public void setFetchMaxBytes(Integer fetchMaxBytes)
public Integer getFetchWaitMaxMs()
public void setFetchWaitMaxMs(Integer fetchWaitMaxMs)
public String getAutoOffsetReset()
public void setAutoOffsetReset(String autoOffsetReset)
public String getAutoCommitOnStop()
public void setAutoCommitOnStop(String autoCommitOnStop)
public Boolean getBreakOnFirstError()
public void setBreakOnFirstError(Boolean breakOnFirstError)
public String getBrokers()
public void setBrokers(String brokers)
public String getCompressionCodec()
public void setCompressionCodec(String compressionCodec)
public Integer getRetryBackoffMs()
public void setRetryBackoffMs(Integer retryBackoffMs)
public Integer getSendBufferBytes()
public void setSendBufferBytes(Integer sendBufferBytes)
public Integer getRequestTimeoutMs()
public void setRequestTimeoutMs(Integer requestTimeoutMs)
public Integer getQueueBufferingMaxMessages()
public void setQueueBufferingMaxMessages(Integer queueBufferingMaxMessages)
public String getSerializerClass()
public void setSerializerClass(String serializerClass)
public String getKeySerializerClass()
public void setKeySerializerClass(String keySerializerClass)
public String getKerberosInitCmd()
public void setKerberosInitCmd(String kerberosInitCmd)
public Integer getKerberosBeforeReloginMinTime()
public void setKerberosBeforeReloginMinTime(Integer kerberosBeforeReloginMinTime)
public Double getKerberosRenewJitter()
public void setKerberosRenewJitter(Double kerberosRenewJitter)
public Double getKerberosRenewWindowFactor()
public void setKerberosRenewWindowFactor(Double kerberosRenewWindowFactor)
public String getKerberosPrincipalToLocalRules()
public void setKerberosPrincipalToLocalRules(String kerberosPrincipalToLocalRules)
public String getSslCipherSuites()
public void setSslCipherSuites(String sslCipherSuites)
public String getSslEndpointAlgorithm()
public void setSslEndpointAlgorithm(String sslEndpointAlgorithm)
public String getSslKeymanagerAlgorithm()
public void setSslKeymanagerAlgorithm(String sslKeymanagerAlgorithm)
public String getSslTrustmanagerAlgorithm()
public void setSslTrustmanagerAlgorithm(String sslTrustmanagerAlgorithm)
public String getSslEnabledProtocols()
public void setSslEnabledProtocols(String sslEnabledProtocols)
public String getSslKeystoreType()
public void setSslKeystoreType(String sslKeystoreType)
public String getSslProtocol()
public void setSslProtocol(String sslProtocol)
public String getSslProvider()
public void setSslProvider(String sslProvider)
public String getSslTruststoreType()
public void setSslTruststoreType(String sslTruststoreType)
public String getSaslKerberosServiceName()
public void setSaslKerberosServiceName(String saslKerberosServiceName)
public String getSaslMechanism()
public void setSaslMechanism(String saslMechanism)
public String getSaslJaasConfig()
public void setSaslJaasConfig(String saslJaasConfig)
public String getSecurityProtocol()
public void setSecurityProtocol(String securityProtocol)
public org.apache.camel.util.jsse.SSLContextParameters getSslContextParameters()
public void setSslContextParameters(org.apache.camel.util.jsse.SSLContextParameters sslContextParameters)
public String getSslKeyPassword()
public void setSslKeyPassword(String sslKeyPassword)
public String getSslKeystoreLocation()
public void setSslKeystoreLocation(String sslKeystoreLocation)
public String getSslKeystorePassword()
public void setSslKeystorePassword(String sslKeystorePassword)
public String getSslTruststoreLocation()
public void setSslTruststoreLocation(String sslTruststoreLocation)
public String getSslTruststorePassword()
public void setSslTruststorePassword(String sslTruststorePassword)
public Integer getBufferMemorySize()
public void setBufferMemorySize(Integer bufferMemorySize)
public String getKey()
public void setKey(String key)
public Integer getPartitionKey()
public void setPartitionKey(Integer partitionKey)
public String getRequestRequiredAcks()
public void setRequestRequiredAcks(String requestRequiredAcks)
public Integer getRetries()
public void setRetries(Integer retries)
public Integer getProducerBatchSize()
public void setProducerBatchSize(Integer producerBatchSize)
public Integer getConnectionMaxIdleMs()
public void setConnectionMaxIdleMs(Integer connectionMaxIdleMs)
public Integer getLingerMs()
public void setLingerMs(Integer lingerMs)
public Integer getMaxBlockMs()
public void setMaxBlockMs(Integer maxBlockMs)
public Integer getMaxRequestSize()
public void setMaxRequestSize(Integer maxRequestSize)
public Integer getReceiveBufferBytes()
public void setReceiveBufferBytes(Integer receiveBufferBytes)
public Integer getMaxInFlightRequest()
public void setMaxInFlightRequest(Integer maxInFlightRequest)
public Integer getMetadataMaxAgeMs()
public void setMetadataMaxAgeMs(Integer metadataMaxAgeMs)
public String getMetricReporters()
public void setMetricReporters(String metricReporters)
public Integer getNoOfMetricsSample()
public void setNoOfMetricsSample(Integer noOfMetricsSample)
public Integer getMetricsSampleWindowMs()
public void setMetricsSampleWindowMs(Integer metricsSampleWindowMs)
public Integer getReconnectBackoffMs()
public void setReconnectBackoffMs(Integer reconnectBackoffMs)
public Integer getHeartbeatIntervalMs()
public void setHeartbeatIntervalMs(Integer heartbeatIntervalMs)
public Integer getMaxPartitionFetchBytes()
public void setMaxPartitionFetchBytes(Integer maxPartitionFetchBytes)
public Integer getSessionTimeoutMs()
public void setSessionTimeoutMs(Integer sessionTimeoutMs)
public Integer getMaxPollRecords()
public void setMaxPollRecords(Integer maxPollRecords)
public Long getPollTimeoutMs()
public void setPollTimeoutMs(Long pollTimeoutMs)
public Long getMaxPollIntervalMs()
public void setMaxPollIntervalMs(Long maxPollIntervalMs)
public String getPartitionAssignor()
public void setPartitionAssignor(String partitionAssignor)
public Integer getConsumerRequestTimeoutMs()
public void setConsumerRequestTimeoutMs(Integer consumerRequestTimeoutMs)
public Boolean getCheckCrcs()
public void setCheckCrcs(Boolean checkCrcs)
public String getKeyDeserializer()
public void setKeyDeserializer(String keyDeserializer)
public String getValueDeserializer()
public void setValueDeserializer(String valueDeserializer)
public String getSeekTo()
public void setSeekTo(String seekTo)
public ExecutorService getWorkerPool()
public void setWorkerPool(ExecutorService workerPool)
public Integer getWorkerPoolCoreSize()
public void setWorkerPoolCoreSize(Integer workerPoolCoreSize)
public Integer getWorkerPoolMaxSize()
public void setWorkerPoolMaxSize(Integer workerPoolMaxSize)
public Boolean getRecordMetadata()
public void setRecordMetadata(Boolean recordMetadata)
public String getInterceptorClasses()
public void setInterceptorClasses(String interceptorClasses)
public Boolean getEnableIdempotence()
public void setEnableIdempotence(Boolean enableIdempotence)
public Integer getReconnectBackoffMaxMs()
public void setReconnectBackoffMaxMs(Integer reconnectBackoffMaxMs)
public org.apache.camel.spi.HeaderFilterStrategy getHeaderFilterStrategy()
public void setHeaderFilterStrategy(org.apache.camel.spi.HeaderFilterStrategy headerFilterStrategy)
public org.apache.camel.component.kafka.serde.KafkaHeaderDeserializer getKafkaHeaderDeserializer()
public void setKafkaHeaderDeserializer(org.apache.camel.component.kafka.serde.KafkaHeaderDeserializer kafkaHeaderDeserializer)
public org.apache.camel.component.kafka.serde.KafkaHeaderSerializer getKafkaHeaderSerializer()
public void setKafkaHeaderSerializer(org.apache.camel.component.kafka.serde.KafkaHeaderSerializer kafkaHeaderSerializer)
public Map getAdditionalProperties()
public void setAdditionalProperties(Map additionalProperties)
Apache Camel