当前位置: 首页 > 知识库问答 >
问题:

Kafka:从无效代理中移动分区

董宜然
2023-03-14

我有一个无效的经纪人,它并不真的存在。我错误地启动了一个id无效的服务器。

但其中一个主题以前分配给了这个代理:

Topic:raw-logs  PartitionCount:3    ReplicationFactor:1 Configs:
    Topic: raw-logs Partition: 0    Leader: -1      Replicas: 100   Isr:
    Topic: raw-logs Partition: 1    Leader: none    Replicas: 2     Isr:
    Topic: raw-logs Partition: 2    Leader: none    Replicas: 3     Isr:
{"topic":"raw-logs","partition":0,"replicas":[1]}

共有1个答案

樊运乾
2023-03-14

只是猜测,但您是否尝试过使用bin/kafka-preferred-replica-election.sh--zookeeper zk_host:port/chroot方法。

 类似资料:
  • 我们在单独的服务器上运行 zookeeper 3.3 和 kafka 0.8。我们正在使用 HL 消费者,它们按预期访问 kafka 队列中的数据,重新启动时,他们会从上次中断的地方继续。因此,消费者的行为符合预期。问题是当我们使用 zkCli.sh 时,我们无法看到动物园管理员中的偏移量。目前,消费者设置为仅在一个分区中为主题运行。CMD “ls /consumer/mygrpid/offset

  • 我将主URL设置为:http://[master_ip]:8080我将windows从机配置如下:slave_config 现在,我试图通过运行以下命令,使用agent.jar启动从机: 我遵循了一百万个教程,一遍又一遍地重复同样的步骤...有什么想法吗?

  • 关于Kafka,我有以下几个问题: > 如果我创建一个主题,并且指定的分区数多于代理数,那么单个代理将处理多个分区? 如果我创建了一个主题,并且指定的复制因子大于没有代理,那么该主题会创建还是不会创建? 一个代理可以处理不同主题的多个分区。

  • 我们正在使用kafka拓扑转发向kafka主题发送记录。 我们之前使用了一个单独的生产者来发布消息,我们能够获取消息的偏移量和分区。现在我们想用上下文替换它。向前地 如何使用上下文获取Kafka接收器处理器发送的记录的偏移量和分区。向前地

  • 但运气不好。有什么想法吗?这有意义吗?