- generateKey(Partition) - Method in class org.springframework.integration.kafka.listener.MetadataStoreOffsetManager
-
- getAdminTaskExecutor() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
-
- getAutoCommitEnable() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- getAutoCommitInterval() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- getAutoOffsetReset() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- getBackOff() - Method in class org.springframework.integration.kafka.core.AbstractConfiguration
-
- getBackOff() - Method in interface org.springframework.integration.kafka.core.Configuration
-
The retry backoff for this client
- getBackoffIncrement() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- getBatchBytes() - Method in class org.springframework.integration.kafka.support.ProducerMetadata
-
- getBeanClass(Element) - Method in class org.springframework.integration.kafka.config.xml.KafkaConsumerContextParser
-
Deprecated.
- getBeanClass(Element) - Method in class org.springframework.integration.kafka.config.xml.KafkaProducerContextParser
-
- getBeanClass(Element) - Method in class org.springframework.integration.kafka.config.xml.ZookeeperConnectParser
-
- getBrokerAddress() - Method in interface org.springframework.integration.kafka.core.Connection
-
The broker address for this consumer
- getBrokerAddress() - Method in class org.springframework.integration.kafka.core.DefaultConnection
-
- getBrokerAddresses() - Method in class org.springframework.integration.kafka.core.AbstractConfiguration
-
- getBrokerAddresses() - Method in interface org.springframework.integration.kafka.core.Configuration
-
The list of seed broker addresses used by this Configuration.
- getBufferSize() - Method in class org.springframework.integration.kafka.core.AbstractConfiguration
-
- getBufferSize() - Method in interface org.springframework.integration.kafka.core.Configuration
-
The buffer size for this client
- getCharset() - Method in class org.springframework.integration.kafka.support.ProducerMetadata
-
- getClientId() - Method in class org.springframework.integration.kafka.core.AbstractConfiguration
-
- getClientId() - Method in interface org.springframework.integration.kafka.core.Configuration
-
The client name to be used throughout this connection.
- getComponentName() - Method in class org.springframework.integration.kafka.support.KafkaProducerContext
-
- getComponentType() - Method in class org.springframework.integration.kafka.inbound.KafkaHighLevelConsumerMessageSource
-
Deprecated.
- getComponentType() - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter
-
- getComponentType() - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler
-
- getComponentType() - Method in class org.springframework.integration.kafka.support.KafkaProducerContext
-
- getCompressionType() - Method in class org.springframework.integration.kafka.support.ProducerMetadata
-
- getConcurrency() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
-
- getConfiguration() - Method in class org.springframework.integration.kafka.core.DefaultConnectionFactory
-
- getConnectionFactory() - Method in class org.springframework.integration.kafka.core.KafkaTemplate
-
- getConsumerConfiguration(String) - Method in class org.springframework.integration.kafka.support.KafkaConsumerContext
-
Deprecated.
- getConsumerConfigurations() - Method in class org.springframework.integration.kafka.support.KafkaConsumerContext
-
Deprecated.
- getConsumerConnector() - Method in class org.springframework.integration.kafka.support.ConsumerConfiguration
-
Deprecated.
- getConsumerConnector() - Method in class org.springframework.integration.kafka.support.ConsumerConnectionProvider
-
Deprecated.
- getConsumerId() - Method in class org.springframework.integration.kafka.listener.AbstractOffsetManager
-
- getConsumerId() - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager.Key
-
- getConsumerMetadata() - Method in class org.springframework.integration.kafka.support.ConsumerConfiguration
-
Deprecated.
- getConsumerTimeout() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- getConsumerTimeout() - Method in class org.springframework.integration.kafka.support.KafkaConsumerContext
-
Deprecated.
- getCurrentCount() - Method in class org.springframework.integration.kafka.support.MessageLeftOverTracker
-
Deprecated.
- getDefaultPartitions() - Method in class org.springframework.integration.kafka.core.AbstractConfiguration
-
- getDefaultPartitions() - Method in interface org.springframework.integration.kafka.core.Configuration
-
A list of default partitions to perform operations on.
- getDefaultTopic() - Method in class org.springframework.integration.kafka.core.AbstractConfiguration
-
- getDefaultTopic() - Method in interface org.springframework.integration.kafka.core.Configuration
-
A default topic to perform operations on.
- getEncoder() - Method in class org.springframework.integration.kafka.util.EncoderAdaptingSerializer
-
- getError(Partition) - Method in class org.springframework.integration.kafka.core.Result
-
- getErrorHandler() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
-
- getErrors() - Method in class org.springframework.integration.kafka.core.Result
-
- getFetchMetadataTimeout() - Method in class org.springframework.integration.kafka.core.AbstractConfiguration
-
- getFetchMetadataTimeout() - Method in interface org.springframework.integration.kafka.core.Configuration
-
The timeout on fetching metadata (e.g.
- getFetchSize() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- getFetchTaskExecutor() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
-
- getGroupId() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- getHighWatermark() - Method in class org.springframework.integration.kafka.core.KafkaMessageBatch
-
- getHost() - Method in class org.springframework.integration.kafka.core.BrokerAddress
-
- getId() - Method in class org.springframework.integration.kafka.core.Partition
-
- getKafkaProducerContext() - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler
-
- getKeyClassType() - Method in class org.springframework.integration.kafka.support.ProducerMetadata
-
- getKeyDecoder() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- getKeySerializer() - Method in class org.springframework.integration.kafka.support.ProducerMetadata
-
- getLeader(Partition) - Method in interface org.springframework.integration.kafka.core.ConnectionFactory
-
Return the leader for a single partition
- getLeader(Partition) - Method in class org.springframework.integration.kafka.core.DefaultConnectionFactory
-
- getLeaders(Iterable<Partition>) - Method in interface org.springframework.integration.kafka.core.ConnectionFactory
-
Retrieve the leaders for a set of partitions.
- getLeaders(Iterable<Partition>) - Method in class org.springframework.integration.kafka.core.DefaultConnectionFactory
-
- getMaxFetch() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
-
- getMaxMessages() - Method in class org.springframework.integration.kafka.support.ConsumerConfiguration
-
Deprecated.
- getMaxSizeInBytes() - Method in class org.springframework.integration.kafka.core.FetchRequest
-
- getMaxWait() - Method in class org.springframework.integration.kafka.core.AbstractConfiguration
-
- getMaxWait() - Method in interface org.springframework.integration.kafka.core.Configuration
-
The maximum amount of time that a server fetch operation will wait before returning
(unless minFetchSizeInBytes) are available.
- getMessage() - Method in class org.springframework.integration.kafka.core.KafkaMessage
-
- getMessageLeftOverFromPreviousPoll() - Method in class org.springframework.integration.kafka.support.MessageLeftOverTracker
-
Deprecated.
- getMessageListener() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
-
- getMessages() - Method in class org.springframework.integration.kafka.core.KafkaMessageBatch
-
- getMetadata() - Method in class org.springframework.integration.kafka.core.KafkaMessage
-
- getMinBytes() - Method in class org.springframework.integration.kafka.core.AbstractConfiguration
-
- getMinBytes() - Method in interface org.springframework.integration.kafka.core.Configuration
-
The minimum amount of data that a server fetch operation will wait for before returning,
unless maxWait has elapsed.
- getNextOffset() - Method in class org.springframework.integration.kafka.core.KafkaMessageMetadata
-
- getNumberOfStreams() - Method in class org.springframework.integration.kafka.support.TopicFilterConfiguration
-
Deprecated.
- getObject() - Method in class org.springframework.integration.kafka.support.ConsumerConfigFactoryBean
-
Deprecated.
- getObject() - Method in class org.springframework.integration.kafka.support.ProducerFactoryBean
-
- getObjectType() - Method in class org.springframework.integration.kafka.support.ConsumerConfigFactoryBean
-
Deprecated.
- getObjectType() - Method in class org.springframework.integration.kafka.support.ProducerFactoryBean
-
- getOffset() - Method in class org.springframework.integration.kafka.core.FetchRequest
-
- getOffset() - Method in class org.springframework.integration.kafka.core.KafkaMessageMetadata
-
- getOffset(Partition) - Method in class org.springframework.integration.kafka.listener.AbstractOffsetManager
-
- getOffset(Partition) - Method in interface org.springframework.integration.kafka.listener.OffsetManager
-
- getOffsetManager() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
-
- getPartition() - Method in class org.springframework.integration.kafka.core.FetchRequest
-
- getPartition() - Method in class org.springframework.integration.kafka.core.KafkaMessageBatch
-
- getPartition() - Method in class org.springframework.integration.kafka.core.KafkaMessageMetadata
-
- getPartition() - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager.Key
-
- getPartitioner() - Method in class org.springframework.integration.kafka.support.ProducerMetadata
-
- getPartitions(String) - Method in interface org.springframework.integration.kafka.core.ConnectionFactory
-
Retrieves the partitions of a given topic
- getPartitions(String) - Method in class org.springframework.integration.kafka.core.DefaultConnectionFactory
-
- getPhase() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
-
- getPhase() - Method in class org.springframework.integration.kafka.support.KafkaProducerContext
-
- getPort() - Method in class org.springframework.integration.kafka.core.BrokerAddress
-
- getProducerConfigurations() - Method in class org.springframework.integration.kafka.support.KafkaProducerContext
-
- getProducerMetadata() - Method in class org.springframework.integration.kafka.support.ProducerConfiguration
-
- getQueuedChunksMax() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- getQueueSize() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
-
- getRebalanceRetriesMax() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- getResult(Partition) - Method in class org.springframework.integration.kafka.core.Result
-
- getResults() - Method in class org.springframework.integration.kafka.core.Result
-
- getSendTimeout() - Method in class org.springframework.integration.kafka.support.ProducerMetadata
-
- getSocketBufferSize() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- getSocketTimeout() - Method in class org.springframework.integration.kafka.core.AbstractConfiguration
-
- getSocketTimeout() - Method in interface org.springframework.integration.kafka.core.Configuration
-
The socket timeout for this client
- getSocketTimeout() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- getStopTimeout() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
-
- getStreams() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- getTopic() - Method in class org.springframework.integration.kafka.core.Partition
-
- getTopic() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- getTopic() - Method in class org.springframework.integration.kafka.support.ProducerMetadata
-
- getTopicConfiguration(String) - Method in class org.springframework.integration.kafka.support.KafkaProducerContext
-
- getTopicFilter() - Method in class org.springframework.integration.kafka.support.TopicFilterConfiguration
-
Deprecated.
- getTopicFilterConfiguration() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- getTopicStreamMap() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- getValueClassType() - Method in class org.springframework.integration.kafka.support.ProducerMetadata
-
- getValueDecoder() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- getValueSerializer() - Method in class org.springframework.integration.kafka.support.ProducerMetadata
-
- getZkConnect() - Method in class org.springframework.integration.kafka.support.ZookeeperConnect
-
- getZkConnectionTimeout() - Method in class org.springframework.integration.kafka.support.ZookeeperConnect
-
- getZkSessionTimeout() - Method in class org.springframework.integration.kafka.support.ZookeeperConnect
-
- getZkSyncTime() - Method in class org.springframework.integration.kafka.support.ZookeeperConnect
-
- getZookeeperConnect() - Method in class org.springframework.integration.kafka.support.KafkaConsumerContext
-
Deprecated.
- GROUP_ID - Static variable in class org.springframework.integration.kafka.core.KafkaConsumerDefaults
-
- SEGMENT_BYTES - Static variable in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager
-
- send(String, Object, Object) - Method in class org.springframework.integration.kafka.support.KafkaProducerContext
-
- send(String, Integer, Object, Object) - Method in class org.springframework.integration.kafka.support.KafkaProducerContext
-
- send(String, K, V) - Method in class org.springframework.integration.kafka.support.ProducerConfiguration
-
- send(String, Integer, K, V) - Method in class org.springframework.integration.kafka.support.ProducerConfiguration
-
- serialize(String, KafkaTopicOffsetManager.Key) - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager.KeySerializerDecoder
-
- serialize(String, Long) - Method in class org.springframework.integration.kafka.listener.LongSerializerDecoder
-
- serialize(T, DatumWriter<T>) - Method in class org.springframework.integration.kafka.serializer.avro.AvroSerializer
-
- serialize(String, T) - Method in class org.springframework.integration.kafka.util.EncoderAdaptingSerializer
-
- setAdminTaskExecutor(Executor) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
-
The task executor for leader, offset, and partition reassignment updates.
- setAutoCommitEnable(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- setAutoCommitInterval(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- setAutoCommitOffset(boolean) - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter
-
Automatically commit the offsets when 'true'.
- setAutoCommitOnError(boolean) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
-
Whether offsets should be auto acknowledged even when exceptions are thrown during processing.
- setAutoOffsetReset(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- setAutoStartup(boolean) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
-
- setAutoStartup(boolean) - Method in class org.springframework.integration.kafka.support.KafkaProducerContext
-
- setBackoff(int) - Method in class org.springframework.integration.kafka.core.AbstractConfiguration
-
The retry backoff time for this client
- setBackoffIncrement(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- setBatchBytes(int) - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager
-
The maximum batch size in bytes for offset writes
- setBatchBytes(int) - Method in class org.springframework.integration.kafka.support.ProducerMetadata
-
- setBeanName(String) - Method in class org.springframework.integration.kafka.support.KafkaProducerContext
-
- setBufferSize(int) - Method in class org.springframework.integration.kafka.core.AbstractConfiguration
-
The buffer size for this client
- setCharset(Charset) - Method in class org.springframework.integration.kafka.support.ProducerMetadata
-
The character encoding to preform String <-> byte[] conversion
instead of general (de)serialization.
- setClientId(String) - Method in class org.springframework.integration.kafka.core.AbstractConfiguration
-
A client name to be used throughout this connection.
- setCompressionCodec(ProducerMetadata.CompressionType) - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager
-
The compression type for writing to the offset topic
- setCompressionType(ProducerMetadata.CompressionType) - Method in class org.springframework.integration.kafka.support.ProducerMetadata
-
- setConcurrency(int) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
-
- setConsumerConfigurations(Map<String, ConsumerConfiguration<K, V>>) - Method in class org.springframework.integration.kafka.support.KafkaConsumerContext
-
Deprecated.
- setConsumerId(String) - Method in class org.springframework.integration.kafka.listener.AbstractOffsetManager
-
The identifier of a consumer of Kafka messages.
- setConsumerTimeout(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- setConsumerTimeout(String) - Method in class org.springframework.integration.kafka.support.KafkaConsumerContext
-
Deprecated.
- setConversionService(ConversionService) - Method in class org.springframework.integration.kafka.support.ProducerConfiguration
-
- setDefaultPartitions(List<Partition>) - Method in class org.springframework.integration.kafka.core.AbstractConfiguration
-
- setDefaultTopic(String) - Method in class org.springframework.integration.kafka.core.AbstractConfiguration
-
- setDispatcherTaskExecutor(Executor) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
-
The task executor for invoking the MessageListener
- setEnableHeaderRouting(boolean) - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler
-
Enable the use of headers for determining the target topic and partition of outbound messages.
- setErrorHandler(ErrorHandler) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
-
- setExecutor(Executor) - Method in class org.springframework.integration.kafka.support.ConsumerConfiguration
-
Deprecated.
- setFetchMetadataTimeout(int) - Method in class org.springframework.integration.kafka.core.AbstractConfiguration
-
The timeout on fetching metadata (e.g.
- setFetchSize(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- setFetchTaskExecutor(Executor) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
-
The task executor for fetch operations.
- setGenerateMessageId(boolean) - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter
-
Generate Message ids for produced messages.
- setGenerateTimestamp(boolean) - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter
-
Generate timestamp for produced messages.
- setGroupId(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- setHighWatermark(long) - Method in class org.springframework.integration.kafka.core.KafkaMessageBatch
-
- setId(int) - Method in class org.springframework.integration.kafka.core.Partition
-
- setIncludeContents(boolean) - Method in class org.springframework.integration.kafka.support.LoggingProducerListener
-
Whether the log message should include the contents (key and payload).
- setKeyDecoder(Decoder<?>) - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter
-
- setKeyDecoder(Decoder<K>) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- setMaxContentLogged(int) - Method in class org.springframework.integration.kafka.support.LoggingProducerListener
-
The maximum amount of data to be logged for either key or password.
- setMaxFetch(int) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
-
- setMaxMessages(int) - Method in class org.springframework.integration.kafka.support.ConsumerConfiguration
-
Deprecated.
- setMaxQueueBufferingTime(int) - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager
-
For how long will producers buffer data before writing to the topic
- setMaxSize(int) - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager
-
Sets the maximum size of a fetch request, allowing to tune the initialization process.
- setMaxSizeInBytes(int) - Method in class org.springframework.integration.kafka.core.FetchRequest
-
- setMaxWait(int) - Method in class org.springframework.integration.kafka.core.AbstractConfiguration
-
The maximum amount of time that a server fetch operation will wait before returning
(unless minFetchSizeInBytes) are available.
- setMessageKeyExpression(Expression) - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler
-
- setMessageListener(Object) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
-
- setMessages(List<KafkaMessage>) - Method in class org.springframework.integration.kafka.core.KafkaMessageBatch
-
- setMetadataStore(MetadataStore) - Method in class org.springframework.integration.kafka.listener.MetadataStoreOffsetManager
-
The backing MetadataStore for storing offsets.
- setMinBytes(int) - Method in class org.springframework.integration.kafka.core.AbstractConfiguration
-
The minimum amount of data that a server fetch operation will wait for before returning,
unless maxWait has elapsed.
- setOffset(long) - Method in class org.springframework.integration.kafka.core.FetchRequest
-
- setOffsetManager(OffsetManager) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
-
- setPartition(Partition) - Method in class org.springframework.integration.kafka.core.FetchRequest
-
- setPartition(Partition) - Method in class org.springframework.integration.kafka.core.KafkaMessageBatch
-
- setPartitioner(Partitioner) - Method in class org.springframework.integration.kafka.support.ProducerMetadata
-
- setPartitionExpression(Expression) - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler
-
- setPartitionIdExpression(Expression) - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler
-
- setPayloadDecoder(Decoder<?>) - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter
-
- setPhase(int) - Method in class org.springframework.integration.kafka.support.KafkaProducerContext
-
- setProducerConfigurations(Map<String, ProducerConfiguration<?, ?>>) - Method in class org.springframework.integration.kafka.support.KafkaProducerContext
-
- setProducerListener(ProducerListener) - Method in class org.springframework.integration.kafka.support.ProducerConfiguration
-
- setQueuedChunksMax(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- setQueueSize(int) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
-
The maximum number of messages that are buffered by each concurrent
MessageListener runner.
- setRebalanceRetriesMax(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- setReferenceTimestamp(long) - Method in class org.springframework.integration.kafka.listener.AbstractOffsetManager
-
A timestamp to be used for resetting initial offsets
- setReplicationFactor(int) - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager
-
The replication factor of the offset topic
- setRequiredAcks(int) - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager
-
The number of required acks on write operations
- setRetentionTime(int) - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager
-
How long are dead records retained in the offset topic
- setRetryTemplate(RetryTemplate) - Method in class org.springframework.integration.kafka.listener.KafkaNativeOffsetManager
-
- setSegmentSize(int) - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager
-
The size of a segment in the offset topic
- setSendTimeout(int) - Method in class org.springframework.integration.kafka.support.ProducerMetadata
-
- setSocketBufferSize(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- setSocketTimeout(int) - Method in class org.springframework.integration.kafka.core.AbstractConfiguration
-
The socket timeout for this client
- setSocketTimeout(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- setStopTimeout(int) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
-
The timeout for waiting for each concurrent
MessageListener to finish on
stopping.
- setStreams(int) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- setSync(boolean) - Method in class org.springframework.integration.kafka.support.ProducerMetadata
-
- setTopic(String) - Method in class org.springframework.integration.kafka.core.Partition
-
- setTopic(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- setTopicExpression(Expression) - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler
-
- setTopicFilterConfiguration(TopicFilterConfiguration) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- setTopicStreamMap(Map<String, Integer>) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- setUseMessageBuilderFactory(boolean) - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter
-
Use the MessageBuilderFactory returned by IntegrationObjectSupport.getMessageBuilderFactory() to create messages.
- setValueDecoder(Decoder<V>) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
Deprecated.
- setZkConnect(String) - Method in class org.springframework.integration.kafka.support.ZookeeperConnect
-
- setZkConnectionTimeout(String) - Method in class org.springframework.integration.kafka.support.ZookeeperConnect
-
- setZkSessionTimeout(String) - Method in class org.springframework.integration.kafka.support.ZookeeperConnect
-
- setZkSyncTime(String) - Method in class org.springframework.integration.kafka.support.ZookeeperConnect
-
- setZookeeperConnect(ZookeeperConnect) - Method in class org.springframework.integration.kafka.support.KafkaConsumerContext
-
Deprecated.
- shutdown() - Method in class org.springframework.integration.kafka.support.ConsumerConfiguration
-
Deprecated.
- SOCKET_BUFFER_SIZE - Static variable in class org.springframework.integration.kafka.core.KafkaConsumerDefaults
-
- SOCKET_BUFFER_SIZE_INT - Static variable in class org.springframework.integration.kafka.core.KafkaConsumerDefaults
-
- SOCKET_TIMEOUT - Static variable in class org.springframework.integration.kafka.core.KafkaConsumerDefaults
-
- SOCKET_TIMEOUT_INT - Static variable in class org.springframework.integration.kafka.core.KafkaConsumerDefaults
-
- start() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
-
- start() - Method in class org.springframework.integration.kafka.support.KafkaProducerContext
-
- stop(Runnable) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
-
- stop() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
-
- stop() - Method in class org.springframework.integration.kafka.support.KafkaProducerContext
-
- stop(Runnable) - Method in class org.springframework.integration.kafka.support.KafkaProducerContext
-
- stop() - Method in class org.springframework.integration.kafka.support.ProducerConfiguration
-
- StringDecoder - Class in org.springframework.integration.kafka.serializer.common
-
String Decoder for Kafka message key/value decoding.
- StringDecoder() - Constructor for class org.springframework.integration.kafka.serializer.common.StringDecoder
-
- StringDecoder(String) - Constructor for class org.springframework.integration.kafka.serializer.common.StringDecoder
-
- StringEncoder - Class in org.springframework.integration.kafka.serializer.common
-
- StringEncoder() - Constructor for class org.springframework.integration.kafka.serializer.common.StringEncoder
-
- StringEncoder(String) - Constructor for class org.springframework.integration.kafka.serializer.common.StringEncoder
-