我们有一个由3个盒子组成的2.3 Kafka集群。当我们在几天前将它升级到2.3版时,我们注意到那些日志消息使得两个代理上的一个主题分区的replicaFetcher线程崩溃: at kafka.log.Log.appendAsFollower(Log.scala:830)at kafka.cluster.Partiti
我在K8s环境中运行Kafka,并有一个init容器来创建几个主题。我希望我的主容器只在主题创建并且主题是“可订阅的”时才启动。我确实尝试过kafka-控制台-使用者,但是即使主题不存在,它也不会退出状态1,如果无法访问引导服务器,它也会退出状态1。我正在寻找一种类似于下面的解决方案退出时使用0(这个可以工作)
k
我有一个Kafka基础设施,主题只有一个分区,2个消费者将订阅该分区。第一个使用者在应用程序的主实例中配置,第二个使用者是应用程序的灾难恢复实例的一部分。现在的问题是,我希望第二个使用者充当故障转移使用者,即如果应用程序使用者的主实例发生故障,则故障转移应用程序的使用者应该开始使用消息。我可以做的一件事是,在第二个使用者端,我可以通过调用Thread#Sleep来引入延迟,这样分区将被分配给主实例
// called at the consumer