在我的应用程序中,我使用的是Spring Kafka
,并且有多个consumers
在使用单独的topic
。我想处理application.properties
中的consumer
属性。下面是我要添加的一些属性:
spring.kafka.consumer.group-id=test
spring.kafka.consumer.auto-offset-reset=latest
spring.kafka.consumer.key-deserializer=<Deserializer.class>
spring.kafka.consumer.value-deserializer=<Deserializer.class>
spring.kafka.consumer.properties.spring.deserializer.key.delegate.class=<Deserializer.class>
spring.kafka.consumer.properties.spring.deserializer.value.delegate.class=<Deserializer.class>
我想为每个主题处理所有上述配置(不创建自定义ContainerFactory
)。我怎么能做到这一点?
暂无答案!
目前还没有任何答案,快来回答吧!