public class KafkaHighLevelConsumerMessageSourceSpec.ConsumerMetadataSpec
extends java.lang.Object
ConsumerMetadata
and populate ConsumerConfiguration
.public KafkaHighLevelConsumerMessageSourceSpec.ConsumerMetadataSpec consumerTimeout(int consumerTimeout)
consumer.timeout.ms
property.consumerTimeout
- the consumer timeout.public <T> KafkaHighLevelConsumerMessageSourceSpec.ConsumerMetadataSpec valueDecoder(kafka.serializer.Decoder<T> valueDecoder)
Decoder
for Kafka message body.
Can be used as Java 8 Lambda.T
- the expected value type.valueDecoder
- the value decoder.public <T> KafkaHighLevelConsumerMessageSourceSpec.ConsumerMetadataSpec keyDecoder(kafka.serializer.Decoder<T> keyDecoder)
Decoder
for Kafka message key.
Can be used as Java 8 Lambda.T
- the expected key type.keyDecoder
- the key decoder.public KafkaHighLevelConsumerMessageSourceSpec.ConsumerMetadataSpec topicStreamMap(java.util.Map<java.lang.String,java.lang.Integer> topicStreamMap)
topicStreamMap
- the of Kafka topics and their number of streams.public KafkaHighLevelConsumerMessageSourceSpec.ConsumerMetadataSpec topicStreamMap(Consumer<MapBuilder<?,java.lang.String,java.lang.Integer>> topicStreamMap)
topicStreamMap
- the MapBuilder
Java 8 Lambda for Kafka topics and their number of streams.public KafkaHighLevelConsumerMessageSourceSpec.ConsumerMetadataSpec topicFilter(java.lang.String pattern, int numberOfStreams, boolean exclude)
pattern
- the Kafka topics pattern.numberOfStreams
- the number of streams.exclude
- the boolean
flag to include or exclude hte provided pattern.public KafkaHighLevelConsumerMessageSourceSpec.ConsumerMetadataSpec executor(java.util.concurrent.Executor executor)
executor
- the Consumer task executor.public KafkaHighLevelConsumerMessageSourceSpec.ConsumerMetadataSpec maxMessages(int maxMessages)
maxMessages
- the number of messages to consume for one stream during one polling task.