apache-kafka
-
Solr日志没有直接推送到kafka，Solr无法连接到ZK
-
ELK 的好的架构是什么？
-
卡夫卡- "Received -1 from channel reading from source socket has likely been closed"
-
如何将主题从kafka集群复制到另一个kafka集群？
-
kafka broker 重启后，out queue 中的所有消息都无法传递给 broker
-
KafkaUtils.createDirectStream 到字符串对象 Spark
-
如何解决 librdkafka 中的 RdKafka::ERR__TIMED_OUT 和 RdKafka::ERR__MSG_TIMED_OUT？
-
如何覆盖 Kafka 代理的存储时间配置？
-
分区和流之间的 Apache Kafka 关系
-
如何构建高效的Kafka broker healthcheck？
-
如何通过 SimpleConsumer 在 Kafka 中获取没有获取请求的消息的大小（元数据）？
-
在 librdkafka 中，每次调用 produce() 后都会调用 dr_cb()
-
如何在消费消息时访问 Kafka headers？
-
为 Kafka 编译自定义生产者
-
kafka 频道中的动态主题使用 flume
-
Scala：class 在将 class 传递给另一个 class 时采用类型参数？
-
如何使用 jmxtrans 监控 Kafka 代理？
-
Lambda 架构与 Apache Spark
-
消耗所有 Kafka 主题然后立即断开连接？
-
Kafka生产者配置立即发送消息