阿里云文档 2023-09-14

生产者会建立多少个到Broker的连接

每个生产者通常会建立2个到Broker的TCP连接。

文章 2023-08-04 来自:开发者社区

Kafka学习--3、Kafka Broker、节点服役和退役、Kafka 副本、Leader 选举流程、故障处理

1、Kafka Broker1.1 Kafka Broker工作流程1.1.1 Zookeeper储存的Kafka信息(1)启动Zookeeper集群、再启动Kafka集群,然后启动Zookeeper客户端(2)通过ls命令可以查看kafka相关信息。1.1.2 Kafka Broker总体工作流程1、模拟Kafka上下线,Zookeeper中数据变化(1)查看/kafka/brokers/id....

Kafka学习--3、Kafka Broker、节点服役和退役、Kafka 副本、Leader 选举流程、故障处理
阿里云文档 2023-07-19

升级Broker可能产生哪些影响

升级Broker可能产生消息乱序、客户端连接中断、消息量不均衡等影响。

问答 2023-04-27 来自:开发者社区

binlog消息过大无法正常发送到kafka的broker端时,canal 服务CPU打满并不停重试

问题如题,因为broker端显示kafka大小为1MB,所以碰到大消息时就没办法了。 错误日志如下,会不停打印 2021-05-16 23:13:18.046 [pool-6-thread-1] ERROR com.alibaba.otter.canal.kafka.CanalKafkaProducer - java.util.concurrent.ExecutionException: org....

文章 2023-01-10 来自:开发者社区

Kafka快速入门(Kafka Broker)节点服役和退役、手动调整副本(下)

Leader故障处理细节3.4 分区副本分配如果 kafka 服务器只有 4 个节点,那么设置 kafka 的分区数大于服务器台数,在 kafka底层如何分配存储副本呢?1)创建 16 分区,3 个副本\ (1)创建一个新的 topic,名称为 second。bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --create --part....

Kafka快速入门(Kafka Broker)节点服役和退役、手动调整副本(下)
文章 2023-01-10 来自:开发者社区

Kafka快速入门(Kafka Broker)节点服役和退役、手动调整副本(上)

1. Kafka Broker 工作流程1.1 Zookeeper 存储的 Kafka 信息(1)启动 Zookeeper 客户端。bin/zkCli.sh(2)通过 ls 命令可以查看 kafka 相关信息。ls /kafkaZookeeper中存储的Kafka 信息1.2 Kafka Broker 总体工作流程1)模拟 Kafka上下线,Zookeeper中数据变化(1)查看/kafka/b....

Kafka快速入门(Kafka Broker)节点服役和退役、手动调整副本(上)
文章 2022-12-01 来自:开发者社区

kafka报错: (localhost/127.0.0.1:9092) could not be established. Broker may not be available.

具体报错:[Producer clientId=console-producer] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)使用的指令:之后输入数据回....

kafka报错: (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
文章 2022-10-10 来自:开发者社区

Broker消息设计--Kafka从入门到精通(十三)

上篇文章说了,触发rebalance是当消费者组订阅的topic数量发生改变,或者topic分区数量发生改变,或者consumer数量发生变化,比如新的consumer加入组,则会重平衡。还介绍了分区策略range,round-robin,sticky。Kafka监听。以及kafkaConsumer是线程安全的吗?Rebalance&多线程实例消费(十二)Broker是kafka非常重要....

文章 2022-06-11 来自:开发者社区

【Kafka】(十三)broker 副本与 ISR 设计

kafka把分区的所有副本均匀地分配到所有broker上,并从这些副本中挑选一个作为leader副本对外提供服务,而其他副本被称为follower副本,只能被动地向leader副本请求数据,从而保持与leader副本的同步:所谓isr,就是Kafka集群动态维护的一组同步副本集合,每个topic分区都有自己的isr列表,isr中的所有副本都与leader保持同步状态,而producer写入的一条....

文章 2021-12-29 来自:开发者社区

《kafka问答100例 -7》如果Topic删除过程中有某台Broker宕机,删除流程会正常进行吗 ? |文末送书

如果Topic删除过程中有某台Broker宕机,删除流程会正常进行吗 ?删除Topic的过程中,跟这个Topic有关的Broker都会开始执行删除操作, 如果其中某台Broker宕机或者副本下线(副本由于某些原因不可读写了) 了,那么这台Broker删除流程受阻并不会影响其他Broker的删除流程正常进行,请看下图但是,只要某台Broker里的任意分区副本没有被正常删除(被标记了–delete)....

《kafka问答100例 -7》如果Topic删除过程中有某台Broker宕机,删除流程会正常进行吗 ? |文末送书

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

云消息队列

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/

+关注