apache-kafka
-
如何停止程序中的Python Kafka Consumer？
-
Java 许多短期对象的垃圾收集行为
-
Apache Kafka 0.8.2.1 - 生产者 (Java API) 不写入消息
-
如何从 python 客户端向 kafka 发送 JSON 对象
-
线程 "main" org.apache.spark.SparkException 中的异常：org.apache.spark.SparkException：找不到 Set()-Spark Steaming-kafka 的领导者
-
KafkaSpout 非常高的延迟
-
Kafka - 使用高级消费者实现延迟队列
-
在 Scala 中导入 avro 模式
-
带有自定义 appender 和 patternlayout 的 log4j2 不工作
-
spark 无法使用新的 groupId 从 Kafka 获取消息
-
如何通过生产者获得 Kafka 最大偏移量
-
如何使用 spring 从 kafka 入站消息中提取数据
-
zookeeper和kafka在hadoop 2.6集群中放在哪里
-
如何在启动Spark Streaming进程时加载历史数据，并计算运行个聚合
-
Java byte[] 到 String 在分配给 String 时不起作用
-
Storm - 有条件地消耗来自kafka spout的流？
-
如何将spark streaming DF写入Kafka主题
-
使用消息总线替代参与者之间的常规消息传递（例如，在 Scala 中）
-
元组失败太多 - 风暴拓扑
-
Scaladocs 构建失败 kafka