我的工作是听Kafka的两个主题（从一开始）：托皮卡和托皮卡。当来自topica的消息到达时，作业进行计算。当来自topicb的消息到达时，我希望作业重置计算并重新读取topica（也从一开始）。
有可能吗？我没有找到办法重读Kafka的一个主题。我有一个临时解决方案：借助shell脚本重新启动作业，以便重新读取topica（从一开始）。
谢谢你的帮助。