我的应用程序生成数据给卡夫卡,并使用动物园管理员进行领导人选举。现在卡夫卡不再需要动物园管理员了,我也需要离开它,因为我不想仅仅为了这个而把它保存在我的基础设施中。那么,卡夫卡是否提供了一个API来实现领导人选举?或者我必须手动做,创建一个主题,并提出我自己的逻辑?我的应用程序有很多实例,但其中只有一个应该同时生成到Kafka,所以我需要一种分布式锁,我希望能够以一种简单的方式使用Kafka本身或k8s来实现它,避免在我的基础结构中添加另一部分。
发布于 2022-09-29 19:56:31
https://stackoverflow.com/questions/73898447
复制相似问题