回答情况：
提问时间：
问题标签：
我对apache kafka非常陌生，我正在尝试做kafka分区，同时将字符串发送给kafka，
public static void main$1.onCompletion(Producer.java:29) at org.apache
浏览 1提问于2018-07-03得票数 0
回答已采纳
我已经在kafka上工作了六个月了，我有一些关于消费者延迟和存储到主题中分区的数据的问题。问题1:最初，当我开始阅读kafka并了解其功能如何使用时，我被反复传授一个包含一个部分和一个复制因子的主题将会带来奇迹。
浏览 20提问于2017-08-30得票数 0
回答已采纳
Apache Kafka:分布式消息传递系统我们如何在实时数据管道中使用这两种技术来处理事件数据？
在实时数据管道方面，在我看来两者做的工作是一样的。
浏览 35修改于2015-04-27得票数 109
回答已采纳
有没有人能告诉我们如何在Apache Avro.It中使用Apache Kafka，似乎只有Confluent平台支持模式注册表。
浏览 36修改于2021-03-17得票数 0
我试图用Scala2.10.1构建Kafka。我试着按照Git-集线器上的步骤。最后，它在Target目录中生成一个Jar，但是Jar是空的，大小为5kb。我是不是漏掉了什么？我对SBT完全陌生。
浏览 3修改于2014-01-22得票数 1
回答已采纳
我读到了Apache Kafka，我偶然发现了它的消费者群体的概念。我不理解的是它的用例。来自不同组的两个不同的消费者可以阅读正在发布的相同消息。为什么要由两个不同的消费者处理相同的消息？
浏览 0修改于2016-11-06得票数 0
我有一个正在运行的Apache Kafka消息代理实例，我希望将其用作camel路由的起点/终点。Caused by: [org.apache.kafka.common.errors.InterruptException - java.lang.InterruptedException] at org.apache
浏览 233修改于2020-06-10得票数 0
回答已采纳
" % "kafka-clients" % "0.8.2.1"
我甚至用import org.apache.kafka.clients.ClientRequest;
import org.apache.kafka
浏览 1修改于2018-05-25得票数 0
据我所知，Apache Kafka是异步消息传递平台，而Apache Camel是实现企业集成模式的平台。
那么，Apache Camel和Apache Kafka的实际区别是什么呢？我们计划用Apache Camel实现系统，这相对容易，但我们的客户想要Apache Kafka而不是rational。选择Apache Kafka实现消息队列功能有什么好处，Apache Camel
浏览 4修改于2020-10-16得票数 16
我刚接触Kafka，似乎对Apache Kafka的“快速入门”指南有几个问题，可以在这里找到： at org.apache.zookeeper.server.quo
浏览 7修改于2018-07-04得票数 0
我最近开始研究Apache Kafka。一切都很好。今天，当我重新启动Apache Kafka时，我得到了很多日志。_2.11-2.0.0/Kafka-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log/ajinkya/software/Kaftka&
浏览 1修改于2018-10-27得票数 0
回答已采纳
KafkaSpout和KafkaBolt对象有什么区别？通常KafkaSpout用于读取卡夫卡制作者的数据，但为什么我们使用KafkaBolt呢？
浏览 0提问于2018-09-03得票数 0
回答已采纳
我正在尝试用Java程序导入kafka类，找不到需要导入的Java类，例如：import kafka.utils.Utils;
谁能告诉我在哪里可以找到这些在我看来，Kafka是用Scala编写的，所以在我下载了它的源代码后，我找不到那些java类。
浏览 1修改于2014-08-22得票数 5
回答已采纳
我正在学习如何将kafka与apache camel集成，我遇到了以下错误。我在C:/收件箱文件夹中创建了一个文件，并希望使用kafka使用者使用其中的文本。: org.apache.kafka.common.KafkaException: Failed to construct kafka producer
at org.apache.camel.RuntimeCamelException.wrapRuntimeCamelExceptionby: o
浏览 5提问于2020-07-01得票数 0
我正在研究Apache-kafka，有一些困惑。请帮助我理解以下场景。
我有一个主题，在一个Kafka集群中有5个分区和5个代理。
浏览 0修改于2018-12-28得票数 0
我有一个IBM AIX的例子，需要将syslog、文件日志和可能的appslog发送到Apache，这有可能吗？我试着搜索一些关于nxlog的内容，但是他没有输出到Kafka的AIX，还有其他解决方案吗？
浏览 5修改于2018-01-05得票数 1
在中提到：
xtzWWN4bTjitpL3kfd9s5g./bin/kafka-storage.sh format -t <uuid> -c ./config/kraft/server.properties
浏览 3修改于2021-07-29得票数 2
回答已采纳
我有一个非常基本的Kafka安装，只是为了测试。现在我正在尝试从控制台向一个主题发送一些数据： at kafka.network.BoundedByteBufferSend.writeCompletely(BoundedByteBufferSend.scala:26)
at kafka.network.BlockingChannel.send有没有可能Kafka得到了一个损坏的索引文件，并因此抛出了这样的错误？主题"test“是几分钟前创建的，顺便说一句，我没有重启任何东西。我发现我可以将索
浏览 2修改于2015-02-19得票数 3
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号