我正在编写java api来创建kafka消费者，我有一个错误： Exception in thread "main" java.lang.NoSuchMethodError: org.apache.kafka.clients.consumer.Consumer.subscribeConsumerConfig.BOOTSTRAP_SERVERS_CONFIG,"localhost:9092");
props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_C
浏览 6提问于2019-06-27得票数 2
回答已采纳
=localhost:9092
spring.kafka.consumer.auto-offset-reset=earliestspring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer=org.<
浏览 5提问于2019-10-17得票数 1
有没有开源工具来监控融合的Kafka？大多数可用的开源工具都是特定于Apache Kafka的，但不是针对Confluent Kafka的。
我们希望至少监控连接器、流和集群的运行状况
浏览 3提问于2017-07-04得票数 0
Reason:org/apache/flink/kafka011/shaded/org
浏览 231提问于2019-09-20得票数 0
2回答
implementation (('org.apache.kafka:kafka-streams:2.3.0'), {无法为参数org.rocksdb:rocksdbjni:5.18.3在DefaultExternalModuleDependency{group='org.apache.kafka'，名称=‘ka
浏览 10提问于2020-07-13得票数 1
回答已采纳
=earliestspring.kafka.bootstrap-servers=${spring.embedded.kafka.brokers<init>(EndPoint.scala:32) at kafka.server.Defaults$.<init>(K
浏览 0提问于2019-11-19得票数 3
回答已采纳
这篇博客文章引用了EmbeddedKafkaCluster类，这个类应该在kafka-streams https://www.confluent.io/blog/stream-processing-part但是，库中缺少此类，例如org.apache.kafka/kafka-streams-test-utils/2.5.1.我想我可以使用github https://github.com/a0x8o/kafka</e
浏览 17提问于2020-10-06得票数 0
(RetryWithToleranceOperator.java:104)\n\tat org.apache.kafka.connect.runtime.TransformationChain.apply:292)\n\tat org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:228)\n\tatorg.apache.kafka.connect.runtime.WorkerTas
浏览 43提问于2020-06-23得票数 3
当Kafka从2.3升级到2.4时，关于Spark需要考虑什么(如果有)？它会影响现有的Spark版本吗？
浏览 38提问于2020-01-17得票数 0
: Failed to construct kafka consumer at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:703) at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:553) at org.apache.kaf
浏览 0提问于2018-02-09得票数 2
回答已采纳
(RocksDBTimestampedStore.java:87) at org.apache.kafka.streams.state.internals.WrappedStateStore.init(WrappedStateStore.java:54)
at org.apache.kafka.strea
浏览 1提问于2021-02-07得票数 0
我有一个独立的spark集群，正在从kafka队列中读取数据。kafka队列有5个分区，spark只处理其中一个分区的数据。我使用的是以下内容： <dependencies> <groupId>org.apache.spark</groupId</dependency> <groupId>org.<em
浏览 2提问于2017-02-27得票数 3
回答已采纳
2回答
{Milliseconds, Seconds, StreamingContext}import org.apache.spark.streaming.kafka010.LocationStrategies.PreferConsistentimport org.apa
浏览 1提问于2018-03-12得票数 2
我使用的是kafka 0.9.0，spark 1.6.1 -这些依赖项是否正常，或者我是否需要更改它们？我在下面附上了pom.xml。
这是我正在使用的流式API。:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">>0.9.0.0</kafka-versio
浏览 0提问于2016-10-07得票数 0
2回答
- Added sensor with name Fetch - delayQueuejava.lang.NoSuchMethodError: org.apache.kafka.common.network.ChannelBuilders.serverChannelBuilder(Lorg / apache / kafka</e
浏览 8提问于2018-07-14得票数 3
2回答
SBT无法导入Kafka编解码类
、、、、
它似乎是在错误的路径下搜索(org.apache.spark.streaming.kafka而不是org.apache.kafka)。错误消息：importkafka.serializer.DefaultDecoder. [info] +-org.apache
浏览 4提问于2016-04-04得票数 7
回答已采纳
>
<groupId>org.springframework.kafka</groupId> <version>2.2.0.RELEASE</version> <groupId>org.apache.<e
浏览 0提问于2019-06-02得票数 2
:成功，但也找不到：
[info] Resolving org.apache.kafka#kafka;0.7.2-spark ...[info] downloading file:/C:/Users/S80035683//.m2/repository/org/apache/kafka/kafka/0.7.2-spark/kafka-[info]
浏览 5提问于2014-05-13得票数 0
回答已采纳
1回答
我正在设置我的Pepper-Box纯文本Config，以使用${accountNumber}, ${{accountNumber}}, {{accountNumber}}传递变量，并使用函数返回字符串，但它没有工作。{ "payload": { "Limit": 20000000}
但是变量没有通过，
浏览 0提问于2019-08-26得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
