有没有办法使用kafka stream api与预定义的用户主题,但能够调用函数,如通过()& to(),根据我的理解,这些函数将生成用于缓存目的的中间主题。
发布于 2019-12-31 11:15:21
您需要一个预定义的主题作为输入源。
through()
是您列出的唯一一个创建“中间”主题的操作。
to()
制作了一个终结性主题。
如果您不执行有状态操作或重新分区(通过更改消息键),就没有中间主题。
https://stackoverflow.com/questions/59539116
复制相似问题