apache-kafka
-
Kafka：从 ZooKeeper 获取代理主机
-
spark 提交失败，spark streaming workdcount python 代码
-
为什么这个 Kafka 消费者不关闭？
-
Slf4j 和类路径错误
-
使用 Shopify Sarama 的 Kafka 错误处理
-
Apache kafka 高级消费者 - 理解
-
如何在 Java 中使用 Kafka 8.2 API 生成消息？
-
how to solve java.lang.NoClassDefFoundError: org/apache/curator/RetryPolicy in storm
-
org.apache.spark.SparkException: 任务不可序列化
-
将 storm 的字数统计拓扑与 kafka 集成
-
kafka.javaapi.* 和 org.apache.kafka.* 有什么区别？
-
如果将新分区添加到 Kafka 主题，消费者偏移量会发生什么变化？
-
对于基于 Docker 容器的实现，运行 在同一个容器中放置一对 Kafka 服务器和 Zookeeper 服务器是否有意义？
-
Streamparse 连续调用 next_tuple
-
Kafka 0.7.2 是否兼容 Storm 0.9.3.1
-
kafka代理配置动态变化
-
kafka消费者代码不运行完全
-
删除 zookeeper 中的 kafka 消费者组
-
监控风暴三叉戟
-
java Kafka Producer 的客户端示例，发送方法不接受 KeyedMessage