使用tidb向kafka集群中写入binlog,kafka集群包含3个broker,为什么tidb只向其中的一个broker中写数据,另外两个broker中并没有数据,特别说明:同一个topic的三个分区,分布在3个broker上,三个分区都是leader分区

为提高效率,提问时请提供以下信息,问题描述清晰可优先响应。

  • 【TiDB 版本】:
  • 【问题描述】:

若提问为性能优化、故障排查类问题,请下载脚本运行。终端输出的打印结果,请务必全选并复制粘贴上传。

请查看下这个帖子是否有帮助:

啊 了解了。还有一个问题,binlog方式支持kafka的多副本吗?现在有这样一种情况:binlog发送给kafka集群,这个kafka集群中有三个broker,其中broker1中的分区是leader分区,broker2和broker3中的分区是follower分区,但是我停掉broker1后,发现binlog无法写入到broker2或者broker3中,这是怎么回事呢?

binlog 向 kafka 写入数据的配置,是配置了多个 broker 还是一个 broker ?方便的话,请提供下 drainer 写入 kafka 的相关信息。

W68ZY%5DBEO2Q1~GIR0(S_12B

1、请确认当 broker1 作为 leader 分区服务停止后,broker2,broker3 是否升级为 leader ?

2、尝试将 broker1,broker2 以及 broker3 均配置为 leader 的情况下,将 broker1 停服,观察一下是否会向 broker2 或 broker3 写入数据~