有人能告诉我罐子和的区别吗？我正在尝试编写kafka客户端，以便从的KafkaConsumer上使用poll(长超时) API从代理中提取数据，但其实现似乎是自动生成的。(见下文)。任何关于什么是正确的罐子的想法。 return null;
}
浏览 7提问于2016-12-30得票数 1
回答已采纳
4回答
卡夫卡火花缭乱
、、
在执行过程中，我们正在使用Spark结构化流处理Kafka，我们得到的问题如下： The jars for#kafka-clients;0.10.0.1 by [org.apache.kafka#kafka-clients;0.10.1.0] in [default] 18&
浏览 0提问于2018-02-22得票数 0
我正在尝试阅读Spark集群中的Kafka主题，该集群使用结构化流式API与Spark中的Kafka集成 .master("kafka.bootstrap.servers", "<brokerUrl>:9094") .option
浏览 3提问于2018-09-28得票数 0
我正在尝试将Storm拓扑提交到群集，但不断收到相同的错误： Exception in thread "main" java.lang.NoClassDefFoundError: kafka/api/OffsetRequest at org.apache.storm.kafka.triden
浏览 23提问于2020-01-28得票数 1
回答已采纳
1回答
我很难用常春藤解决卡夫卡的依赖。
我试图在junit测试中创建一个kafka服务器。和kafka_2.11-0.2.1-test.jar在测试类路径上，因为kafka.utils.TestUtils在*-test.jar中。问题是如何使用常春藤和蚂蚁来解决*-test.jar？<dependency org="org.apache.kafka" name="kafka</e
浏览 1提问于2017-07-31得票数 0
回答已采纳
，我正在尝试使用pyspark结构的流来阅读google dataproc中的kafka消息。，因为我必须最终将此数据写到google org.apache.spark:spark-sql-kafka-0-10_2.12:3.0.1版本3.0.1上托管的增量，而pyspark使用的python版本是3.7.3，我正在使用的软件包是org.apache.spark:spark-sql-kafka-0-
浏览 3提问于2021-03-01得票数 2
下面是pom.xml <properties> <maven.compiler.target在我的本地设置中，使用以下命令可以正常运行jar spark-submit --master local[*] --class com.stream.Main --num-executors 3 --driver-memory2g --executor-cores 2 --execu
浏览 169提问于2020-12-06得票数 0
1回答
我设计了一个组件来收集应用程序运行时数据，这些数据通过Kafka发送到分析服务器。在大多数情况下，应用程序会集成Kafka。为了避免连接到同一个Kafka两次，我需要确定应用程序是否使用Kafka。如果应用程序使用Kafka，我会直接重用连接。如果app集成了spring-kafka，我应该怎么做？
浏览 1提问于2021-05-20得票数 0
1回答
(KafkaChannel.java:424) ~[kafka-clients-2.3.0.jar:na]at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java::307) [kafka
浏览 13提问于2022-09-20得票数 0
/zk/EmbeddedZookeeper<dependency> <artifactIdgroupId>org.apache.k
浏览 0提问于2019-06-02得票数 2
Spring Boot: 2.0.3版本 org.apache.kafka.kafka-streams: 1.0.0 Org.apache.kafka.kafka-客户端: 1.0.0 org.springframwork.kafka:spring-kafka-test:2.1.7.RELEASE 我有一个使用Kafka的Spring启动应用程序。我正在尝试使用https://b
浏览 92提问于2019-04-30得票数 0
回答已采纳
我一直试图使用Kafka运行一个简单的wordcount应用程序，但是每当我运行它时，我就会得到以下错误： at org.apache.kafka.streams.KafkaStreams.<init>
浏览 0提问于2018-12-12得票数 0
回答已采纳
在测试中我使用的是MockSchemaReigstryClient at org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:640) ~[
浏览 9提问于2021-01-10得票数 3
当消费来自kafka-2.2.1的消息时，我们会遇到问题，我们在kafka broker.The上配置compression.type = zstd时，全异常堆栈是 org.apache.kafka.common.KafkaExceptionat org.apache.kafka.clients.consumer.internals.Fetcher$CompletedFetch.fetchRecords(Fetcher.java:1519)at org
浏览 406提问于2021-07-30得票数 1
回答已采纳
我对Apache和Spring相当陌生，我正在编写一个应用程序，它使用来自主题的信息并执行一些操作。现在，当我指向Kafka的DEV服务器(版本- 0.10.0.2.5)时，我看到客户端日志中出现了以下异常：
network.Selector - Connection with qm-alpha.activehealth.netat org.apache.kafka.common.network.Selector.poll(Selector.java:291) [<em
浏览 4提问于2017-04-04得票数 2
回答已采纳
tasks.max=6curl "https://repo1.maven.org/maven2/org/apache/kafka/kafka_2.13/2.5.1/kafka_2.13-2.5.1.jar"
浏览 2提问于2021-09-24得票数 1
回答已采纳
我正在尝试使用Kafka：import org.apache.kafka.clients.producer.Producer;import org.apache.kafka.clients.producer.ProducerRecord/kafka/clients
浏览 904提问于2019-05-31得票数 2
回答已采纳
1回答
我得到的异常风暴拓扑。
java.lang.NoSuchMethodError: org.apache.kafka.common.network.NetworkSend.at org.apache.storm.kafka.KafkaUtils.getOffset(KafkaUtils.java:81) ~[stormjar.jar:?]at org.apache.storm.kafka.KafkaUtils.getOffset(KafkaUtils.j
浏览 0提问于2018-08-27得票数 0
回答已采纳
当我将它连接到一个SSL配置的Kafka代理时，它会给出一个"OutofMemory“错误，如下所示，尽管我已经多次增加堆大小，但没有效果。:265) ~[kafka-clients-2.7.1.jar!:236) ~[kafka-clients-2.7.1.jar!:215) ~[kafka-clients-2.7.1.jar!我测试了所有其他可能性，并指出它与客户端的SSL配置有关。
浏览 30提问于2021-11-01得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
