CODEWITHSUNDEEP
javaspringapache-kafkaspring-integration
Vinod Jayachandran
Vinod Jayachandran

Reputation: 3898

Spring Integration Kafka message-driven-channel-adapter receive message

For spring-integration-kafka version 2.1.0.RELEASE, documentation seems to be outdated

The example in the doc is incorrect as it doesn't match the constructor argument for KafkaMessageListenerContainer. Can somebody direct me how to create the bean correctly and corresponding Java code to process the message ?

<bean id="container1" class="org.springframework.kafka.listener.KafkaMessageListenerContainer">
        <constructor-arg>
            <bean class="org.springframework.kafka.core.DefaultKafkaConsumerFactory">
                <constructor-arg>
                    <map>
                        <entry key="bootstrap.servers" value="localhost:9092" />
                    </map>
                </constructor-arg>
            </bean>
        </constructor-arg>
        <constructor-arg name="topics" value="foo" />
</bean>

Upvotes: 0

Views: 881

Answers (1)

Gary Russell
Gary Russell

Reputation: 174799

Sorry about that; we'll fix the docs; the correct documentation is in the quick start section.

Upvotes: 1

Related Questions