nik*_*kel 5 apache-kafka kafka-consumer-api
我们将实施Kafka Publish订阅系统.
现在,在最糟糕的情况下 - 如果给定主题的所有kafka经纪人都失败了 - 会发生什么？
我尝试了这个...发布者在元数据提取的默认超时后检测到它,如果不成功则抛出异常.
在这种情况下,我们可以监视异常并在修复Kafka后重新启动Publisher.
但是,消费者呢 - 一旦卡夫卡垮台,他们似乎没有任何例外.我们根本不能要求"所有"消费者重新启动他们的系统.有没有更好的方法来解决这个问题？
| 归档时间： |
|
| 查看次数： |
2087 次 |
| 最近记录： |