apache-kafka
-
Spring Kafka 该类不在受信任的包中 在库更新之前的Spring Boot/Kafka应用程序中,我使用以下类来向Kafka主题发布消息。现在我使用以下.如您所见 - 它们具有不同的包。 应用程序重新启动后,我遇到了以下问题:
-
连接到在 Docker 中运行的 Kafka免責聲明答tl;博士相关问题附录 我在本地计算机上设置了一个单节点 Kafka Docker 容器,如 也有类似的问题,但它是基于图像的。我使用不一样的基于图像。
-
Kafka 如何存储每个主题的偏移量? 在轮询Kafka时,我使用该函数订阅了多个主题。现在,我想设置要从每个主题中阅读的偏移量,而不是在每个主题之后重新订阅。在轮询数据之前,对每个主题名称进行迭代调用是否能获得结果
-
了解使用者组 ID 我重新安装了Apache Kafka 0.10.1.0。 我能够在命令提示符下发送/接收消息。 在使用生产者/消费者Java示例时,我无法知道消费者示例 group.id 参数。 让我知道如何解决此问题。 以下是我使用的消
-
不满意的LinkError: /tmp/snappy-1.1.4-libsnappyjava.so 加载共享库ld-linux-x86-64.so.2时出错:没有这样的文件或目录 我正在尝试在 kubernetes 中运行 Kafka Streams 应用程序。当我启动 pod 时,我得到以下异常:
-
如何在弹簧卡夫卡中确认当前偏移以进行手动提交 我第一次使用Spring Kafka,我无法在我的消费者代码中使用Ressless.acknowledge()方法进行手动提交。如果我的使用者配置或监听器代码中缺少任何内容,请告诉我。或者有其他方法来处理基于条件
-
kafka 8 和内存 - 内存不足,无法继续 Java 运行时环境 我正在使用具有512兆内存的DigiOcean实例,我得到了以下带有kafka的错误。我不是一个精通Java的开发人员。如何调整卡夫卡以利用少量的RAM。这是一个开发服务器。我不想为一台更大的机器每小时
-
无法读取工件描述符:IntelliJ 我的Maven POM文件遇到了一个问题,它无法找到spark依赖项并返回错误:无法读取org.apache.spark:spark-streaming-kafka_2.10:jar:1.2.1的工件描述符 我已经确认它不是任何企业防火墙的问题,因为所有其
-
-
如何使用Avro二进制编码器编码/解码Kafka消息? 我正在尝试使用Avro来读取/写入Kafka的消息。有没有人有使用Avro二进制编码器对将放在消息队列中的数据进行编码/解码的示例? 我需要Avro部分而不是Kafka部分更多。或者,也许我应该看看一个
标签