我需要开发一个kstream(读写)应用程序,它使用来自broker-1的数据并向broker-2生成数据。
为了实现这一点,我设置了以下配置属性:
consumer.bootstrap-servers= broker 1
producer.bootstrap-servers= broker 2
但kstream应用程序正在为消费和生产部分设置broker-1细节。
通过进一步研究,我发现kstream api本身并没有提供这种功能,但这似乎很奇怪,因为它是流式api的基本功能。
问题:使用kstream有可能实现我的目标吗?
暂无答案!
目前还没有任何答案,快来回答吧!