单一的kstream应用程序,为消费者和生产者提供独立的kafka代理

bpzcxfmw  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(151)

我需要开发一个kstream(读写)应用程序,它使用来自broker-1的数据并向broker-2生成数据。
为了实现这一点,我设置了以下配置属性:

consumer.bootstrap-servers= broker 1
producer.bootstrap-servers= broker 2

但kstream应用程序正在为消费和生产部分设置broker-1细节。
通过进一步研究,我发现kstream api本身并没有提供这种功能,但这似乎很奇怪,因为它是流式api的基本功能。
问题:使用kstream有可能实现我的目标吗?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题