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.