我使用Ubuntu服务器16.04尝试使用Kafka.对于启动生产者和消费者控制台的命令,我使用以下命令. 制片人控制台 bin/kafka-console-producer.sh --broker-list local…

我想知道什么对我最好：Kafka流或Kafka消费者api或Kafka连接？ 我想从主题中读取数据然后进行一些处理并写入数据库.所以我写了消费者,但我觉得我可以编写Kafka流应用程序并使用它的有状态处理器来执行任何更改…

我打算使用kafka作为 persistent log for event sourcing,我正在研究不同的序列化选项.我现在的重点是使用thrift来对我将在kafka中存储的消息进行序列化和反序列化. 当使用thr…

我们如何使用Apache Kafka API获取主题的复制因子和保留时间？ 我使用的是0.9版本,并计算了如何使用AdminUtils来获取数量. 最佳答案 如果你已经熟悉了AdminUtils,那就没那么远了.获取您感…

我正在使用kafka-net客户端向kafka发送消息.我只是想知道是否有任何方法可以检查kafka服务器是否可以接收消息.我关闭了kafka,但生成器已成功创建,SendMessageAsync刚冻结了很长时间.我试图…

我正在尝试使用apache flink流消费kafka主题. 但是我遇到了这个问题. 2018-04-10 02:55:59,856|- ProducerConfig values: acks = 1 batch.siz…

我正在研究数据提取用例,其中数据来自多个主题,并且必须根据主题名称推送到多个表.我试图了解将所有主题的一个消费者与每个主题/分区有一个消费者有任何性能差异. 最佳答案 这两种方案之间的性能差异取决于代理,分区和预期吞吐量…

在尝试将Kafka集成到我们的Storm拓扑中时,我收到错误 java.lang.ClassNotFoundException kafka.api.OffsetRequest. 你正在运行哪些版本并且它正在运行？ 我的p…

我在数据中心有一个Kafka群集.可以通过WAN(甚至是互联网)进行通信的一堆客户端将向/从群集发送/接收实时消息. 我从Kafka’s Documentation开始阅读： …It is possible to rea…

任何解决这个问题的方法???我无法阅读KAFKA-AVRO架构消息.我试图将消息从logstash发送到KAFKA到HDFS. 以下是技术堆栈： > Logstash 2.3 – 当前生产版本>汇合3.0.&…

我对Apache Storm很陌生,并且一直尝试使用Kafka的三叉戟拓扑,即TransactionalTridentKafkaSpout.除Storm UI外,一切正常.即使我没有为我的主题生成任何数据,Storm U…

我们要求删除/清除主题中任何给定分区的数据.我正在使用Kafka 0.10.0.1.有什么办法可以按需删除整个分区内容吗？如果是,那么如何.我看到我们可以使用日志压缩为密钥发布空消息并删除它但除此之外是否有任何方法可以实…