Uses of Class
org.springframework.cloud.stream.binder.kafka.streams.properties.KafkaStreamsConsumerProperties

Packages that use KafkaStreamsConsumerProperties

Package	Description
org.springframework.cloud.stream.binder.kafka.streams
org.springframework.cloud.stream.binder.kafka.streams.properties

Uses of KafkaStreamsConsumerProperties in org.springframework.cloud.stream.binder.kafka.streams

Methods in org.springframework.cloud.stream.binder.kafka.streams that return KafkaStreamsConsumerProperties

Modifier and Type	Method	Description
KafkaStreamsConsumerProperties	GlobalKTableBinder.getExtendedConsumerProperties(String channelName)

Methods in org.springframework.cloud.stream.binder.kafka.streams with parameters of type KafkaStreamsConsumerProperties

Modifier and Type	Method	Description
protected org.apache.kafka.streams.Topology.AutoOffsetReset	AbstractKafkaStreamsBinderProcessor.getAutoOffsetReset(String inboundName, KafkaStreamsConsumerProperties extendedConsumerProperties)
org.apache.kafka.common.serialization.Serde<?>	KeyValueSerdeResolver.getInboundKeySerde(KafkaStreamsConsumerProperties extendedConsumerProperties)	Provide the Serde for inbound key.
org.apache.kafka.common.serialization.Serde<?>	KeyValueSerdeResolver.getInboundKeySerde(KafkaStreamsConsumerProperties extendedConsumerProperties, org.springframework.core.ResolvableType resolvableType)
org.apache.kafka.common.serialization.Serde<?>	KeyValueSerdeResolver.getInboundValueSerde(ConsumerProperties consumerProperties, KafkaStreamsConsumerProperties extendedConsumerProperties)	Provide the Serde for inbound value.
org.apache.kafka.common.serialization.Serde<?>	KeyValueSerdeResolver.getInboundValueSerde(ConsumerProperties consumerProperties, KafkaStreamsConsumerProperties extendedConsumerProperties, org.springframework.core.ResolvableType resolvableType)
protected org.apache.kafka.streams.kstream.KStream<?,?>	AbstractKafkaStreamsBinderProcessor.getKStream(String inboundName, org.springframework.cloud.stream.config.BindingProperties bindingProperties, KafkaStreamsConsumerProperties kafkaStreamsConsumerProperties, org.apache.kafka.streams.StreamsBuilder streamsBuilder, org.apache.kafka.common.serialization.Serde<?> keySerde, org.apache.kafka.common.serialization.Serde<?> valueSerde, org.apache.kafka.streams.Topology.AutoOffsetReset autoOffsetReset, boolean firstBuild)
protected org.apache.kafka.common.serialization.Serde<?>	AbstractKafkaStreamsBinderProcessor.getValueSerde(String inboundName, KafkaStreamsConsumerProperties kafkaStreamsConsumerProperties, org.springframework.core.ResolvableType resolvableType)
protected void	AbstractKafkaStreamsBinderProcessor.handleKTableGlobalKTableInputs(Object[] arguments, int index, String input, Class<?> parameterType, Object targetBean, org.springframework.kafka.config.StreamsBuilderFactoryBean streamsBuilderFactoryBean, org.apache.kafka.streams.StreamsBuilder streamsBuilder, KafkaStreamsConsumerProperties extendedConsumerProperties, org.apache.kafka.common.serialization.Serde<?> keySerde, org.apache.kafka.common.serialization.Serde<?> valueSerde, org.apache.kafka.streams.Topology.AutoOffsetReset autoOffsetReset, boolean firstBuild)

Method parameters in org.springframework.cloud.stream.binder.kafka.streams with type arguments of type KafkaStreamsConsumerProperties

Modifier and Type	Method	Description
protected Binding<org.apache.kafka.streams.kstream.GlobalKTable<Object,Object>>	GlobalKTableBinder.doBindConsumer(String name, String group, org.apache.kafka.streams.kstream.GlobalKTable<Object,Object> inputTarget, ExtendedConsumerProperties<KafkaStreamsConsumerProperties> properties)

Uses of KafkaStreamsConsumerProperties in org.springframework.cloud.stream.binder.kafka.streams.properties

Methods in org.springframework.cloud.stream.binder.kafka.streams.properties that return KafkaStreamsConsumerProperties

Modifier and Type	Method	Description
KafkaStreamsConsumerProperties	KafkaStreamsBindingProperties.getConsumer()

Methods in org.springframework.cloud.stream.binder.kafka.streams.properties with parameters of type KafkaStreamsConsumerProperties

Modifier and Type	Method	Description
void	KafkaStreamsBindingProperties.setConsumer(KafkaStreamsConsumerProperties consumer)