apache-kafka
-
是否可以在 Kafka 0.8.2 中向现有主题添加分区 我有一个运行2个分区的版本是0.8.2.2。在0.8.1版本中,曾经有一个名为的脚本,我想它可能会起作用。但是,我在0.8.2中没有看到任何这样的脚本。
-
-
避免apache kafka消费者中重复消息的有效策略如何从 Kafka 获取一次消息? 我已经学习apache kafka一个月了。然而,我现在被困在一个点上。我的用例是,我有两个或多个消费者进程在不同的机器上运行。我运行了一些测试,其中我在kafka服务器中发布了10,000条消息。然
-
如何检查Kafka服务器是否正在运行? 我想在开始生产和消费作业之前确保kafka服务器是否正在运行。它是在Windows环境中,这是我的kafka服务器在eclipse中的代码... 在这种情况下是不够的,因为它总是正确的。那么有没有办法知道我
-
动物园管理员在执行 kafka-console-consumer.sh 时不是公认的选项 我正在学习如何在这个网站上使用Kafka(除了我在zookeeper中使用端口2182),但它显示: 动物园管理员不是公认的选择 执行后: sudo ./bin/kafka-console-consumer.sh --topic test --zookeeper localhost:2182 如
-
启动 kafka 时输入行太长 我正在尝试在Windows上运行Kafka消息队列。 我是我们在本教程中 - 当我尝试用comand运行它时 - .\bin\windows\kafka-server-start.bat .\config\server.properties 我得到一个错误:输入行太长。该命令的语法不正
-
kafka 获取主题的分区计数 如何从代码中获取任何kafka主题的分区数。我研究了许多链接,但似乎没有一个有效。 举几个例子: 这看起来像类似的讨论。 SO上也有类似的链接,没有一个有效的解决方案。
-
如何为 Kafka 设置 Java 选项? 我一直在尝试Kafka,并从主站点的文档中看到,您可以为jvm设置不同的选项,例如堆大小和它使用的垃圾回收器: 但是,它没有说的是如何/在哪里设置这些选项。该应用程序带有一个 /config 目
-
如何通过Java在Kafka中创建主题 我想通过java在Kafka(kafka_2.8.0-0.8.1.1)中创建一个主题。如果我在命令提示符下创建一个主题,并且如果我通过java api推送消息,它工作正常。但我想通过java api创建一个主题。经过长时间的搜索
-
Kafka Connect 的堆空间不足 启动 Kafka Connect () 后,我的任务在以下情况下立即失败: 在一些Kafka文档中提到了堆空间,告诉您使用“默认值”尝试它,并且仅在出现问题时才修改它,但没有修改堆空间的说明。
标签