文章 2017-05-02 来自:开发者社区

Apache Kafka源码分析 – Broker Server

1. Kafka.scala 在Kafka的main入口中startup KafkaServerStartable, 而KafkaServerStartable这是对KafkaServer的封装 1: val kafkaServerStartble = new KafkaServerStartable(serverConfig) 2: kafkaServerStartble.st...

Apache Kafka源码分析 – Broker Server
文章 2017-03-22 来自:开发者社区

Apache Kafka学习 (二) - 多代理(broker)集群

1. 配置server.properties > cp config/server.properties config/server-1.properties> cp config/server.properties config/server-2.properties   2. 编辑server.properties config/server-1.properties: ...

文章 2017-03-07 来自:开发者社区

Kafka发送超过broker限定大小的消息时Client和Broker端各自会有什么异常?

前几天遇到一个bug,查看发送日志发现java.io.IOException: Broken pipe的错误,通过深入了解发现当kafka producer发送的消息体大于Broker配置的默认值时就会报这个异常。如果仅发送一次是不会报这个异常的,要连续发送才会报这个异常。 本博文记录一下当Kafka发送超过broker限定大小的消息时Client和Broker端各自会有什么异常。 Kafk...

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

产品推荐

云消息队列

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

+关注