with configuration
using spring-integration-kafka extention , following configuration:
<int-kafka:zookeeper-connect id="zookeeperconnect" zk-connect="#{kafkaconfig['zookeeperurl']}" zk-connection-timeout="10000" zk-session-timeout="10000" zk-sync-time="2000" /> <int-kafka:consumer-context id="consumercontext" consumer-timeout="5000" zookeeper-connect="zookeeperconnect">
the timeout
time of waiting message or time of waiting message , reading message? value different read timeout?
consumer.timeout.ms -1
kafka configuration
throw timeout exception consumer if no message available consumption after specified interval
Comments
Post a Comment