在我的需求中,我有两个消费者组,一个组(Main)只是获取数据并发送到其他服务器,如果发送到其他服务器失败,那么我需要重新加入(启动)其他消费者组(失败的处理)。 在这种情况下,Main Group将继续读取并重试,并将继续相同的操作,当消息发送成功时,它需要通知其他使用者组(失败的处理)。现在失败的处理应该从第一个失败到最后一个失败的地方开始发送。 public void StartMainstreamHandler() {
StreamsBuilder builder = new StreamsBuilder();
KStream<String, S