- 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 and offset updates
- setAutoCommitEnable(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
- setAutoCommitInterval(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
- setAutoCommitOffset(boolean) - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter
-
Automatically commit the offsets when 'true'.
- setAutoOffsetReset(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
- setAutoStartup(boolean) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
-
- setAutoStartup(boolean) - Method in class org.springframework.integration.kafka.support.KafkaProducerContext
-
- setBackoffIncrement(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
- 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
- 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
-
- 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
-
- setConsumerTimeout(String) - Method in class org.springframework.integration.kafka.support.KafkaConsumerContext
-
- 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
- setErrorHandler(ErrorHandler) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
-
- setExecutor(Executor) - Method in class org.springframework.integration.kafka.support.ConsumerConfiguration
-
- 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
-
- 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
-
- setHighWatermark(long) - Method in class org.springframework.integration.kafka.core.KafkaMessageBatch
-
- setId(int) - Method in class org.springframework.integration.kafka.core.Partition
-
- setIntegrationEvaluationContext(EvaluationContext) - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler
-
- setKeyDecoder(Decoder<?>) - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter
-
- setKeyDecoder(Decoder<K>) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
- setMaxFetch(int) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
-
- setMaxMessages(int) - Method in class org.springframework.integration.kafka.support.ConsumerConfiguration
-
- 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
-
- 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
-
- setQueuedChunksMax(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
- 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
-
- 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
- setSegmentSize(int) - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager
-
The size of a segment in the offset topic
- setSocketBufferSize(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
- 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
-
- 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
-
- setTopic(String) - Method in class org.springframework.integration.kafka.core.Partition
-
- setTopic(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
- setTopicExpression(Expression) - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler
-
- setTopicFilterConfiguration(TopicFilterConfiguration) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
- setTopicStreamMap(Map<String, Integer>) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
-
- 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
-
- 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
-
- shutdown() - Method in class org.springframework.integration.kafka.support.ConsumerConfiguration
-
- 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
-