在尝试将Kafka集成到我们的Storm拓扑中时,我收到错误 java.lang.ClassNotFoundException kafka.api.OffsetRequest. 你正在运行哪些版本并且它正在运行? 我的p…
标签:apache-kafka
apache-kafka – 如何在单个API调用中从Kafka发送和获取数据
我想在单个API调用中发送并从Kafka获取数据(参见下图). 这可能吗?我已经知道如何使数据向一个方向发展(例如,Spark Streaming使用Kafka使用者API读取数据).我也知道如何通过两种单向方法来“伪造…
apache-kafka – Storm UI不正确的值和毛细管工具
我对Apache Storm很陌生,并且一直尝试使用Kafka的三叉戟拓扑,即TransactionalTridentKafkaSpout.除Storm UI外,一切正常.即使我没有为我的主题生成任何数据,Storm U…
spring-integration – spring integration kafka错误处理
我们开始在项目中使用 spring-integration-kafka,但是找不到任何有关消费者方面的错误处理方法的文档. 理想情况下,我们需要一个不会阻塞线程的退避重试策略,因此,似乎无状态重试建议不是一个选项;但是,…
apache-kafka – 广域网上的卡夫卡制片人/消费者?
我在数据中心有一个Kafka群集.可以通过WAN(甚至是互联网)进行通信的一堆客户端将向/从群集发送/接收实时消息. 我从Kafka’s Documentation开始阅读: …It is possible to rea…
apache-kafka – kafka启动失败(版本0.8.0 beta1)
我正试图在独立模式下启动带有zookeeper版本(3.3.6)的kafka服务(在ec2上). 所以我运行1)sbt update 2)sbt package 3)sbt assembly-package-depend…
apache-kafka – Kafka Console Producer – 向主题发送消息时出错:TimeoutException:Expiring 1 record
我有一个Confluent平台Kafka集群有3个节点,一切似乎工作正常,但当产品与控制台的一些消息时,得到错误! 命令: /opt/kafka/confluent-4.0.0/bin/kafka-console-pro…
apache-kafka – Kafka – 无法建立与节点-1的连接
我正在尝试使用apache flink流消费kafka主题. 但是我遇到了这个问题. 2018-04-10 02:55:59,856|- ProducerConfig values: acks = 1 batch.siz…
apache-kafka – 一个针对多个主题的kafka消费者与针对每个主题/分区的一个消费者
我正在研究数据提取用例,其中数据来自多个主题,并且必须根据主题名称推送到多个表.我试图了解将所有主题的一个消费者与每个主题/分区有一个消费者有任何性能差异. 最佳答案 这两种方案之间的性能差异取决于代理,分区和预期吞吐量…
apache-kafka – 我应该使用什么:Kafka Stream或Kafka消费者api或Kafka连接
我想知道什么对我最好:Kafka流或Kafka消费者api或Kafka连接? 我想从主题中读取数据然后进行一些处理并写入数据库.所以我写了消费者,但我觉得我可以编写Kafka流应用程序并使用它的有状态处理器来执行任何更改…
apache-kafka – 订阅多个主题的Kafka消费者控制台
我使用Ubuntu服务器16.04尝试使用Kafka.对于启动生产者和消费者控制台的命令,我使用以下命令. 制片人控制台 bin/kafka-console-producer.sh --broker-list local…
apache-kafka – 如何使用Flink与Kafka 0.10.1.0?
Flink是否支持Kafka 0.10.1.0? 我看到有一个flink-connector-kafka-0.10,但我无法在flink最新版本中看到它. 目前我正在使用 <dependency> <g…