kafka-streams-scala版本与kafka-streams版本

文章/答案/技术大牛

发布

1回答

scala、apache-kafka-streams

我在项目中使用的org.apache.kafka/kafka-streams scala版本应该与org.apache.kafka/kafka-stream版本相同吗？或者，例如，我可以将kafka-streams-scala版本2.2.0与kafka-streams-scala版本2.0.1一起使用吗？

浏览 15提问于2019-04-22得票数 0

2回答

org.apache.kafka.common.metrics.MetricsContext :java.lang.ClassNotFoundException

java、apache-kafka、apache-kafka-streams

3.8.1</version> <groupId>org.apache.kafka</groupId> <artifactId>kafka-streams

浏览 12提问于2020-11-19得票数 2

回答已采纳

1回答

Maven冲突依赖kafka-stream-test-utils和kafka-stream

java、maven、apache-kafka

</dependency> <groupId>org.apache.kafka</groupId>[INFO] | +- (org.apache.kafka:kafka-streamsorg.apache.kafka

浏览 36提问于2020-05-22得票数 0

1回答

理解eclipse maven依赖关系层次结构

eclipse、maven、pom.xml、maven-dependency

我想了解多模块maven项目的依赖关系，以及eclipse依赖关系层次结构。下面是屏幕截图。谢谢。

浏览 0提问于2018-08-28得票数 11

回答已采纳

3回答

尝试运行简单Kafka流应用程序时接收异常

java、apache-kafka、apache-kafka-streams

我一直试图使用Kafka运行一个简单的wordcount应用程序，但是每当我运行它时，我就会得到以下错误： at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:630) at org.apache.kafka.streams.KafkaStreams.<init>

浏览 0提问于2018-12-12得票数 0

回答已采纳

1回答

卡夫卡流: org.apache.kafka.clients.consumer.ConsumerConfig.addDeserializerToConfig

spring-boot、apache-kafka、apache-kafka-streams、spring-kafka

我正在学习卡夫卡流，我得到了一个错误，我尝试了一些东西，但是注意到了作品public static void main(String[] args) throws InterruptedException { String consumer_group = "firstGroup1";

浏览 16提问于2022-01-08得票数 0

回答已采纳

2回答

无法安装npm软件包(kafka-streams)

node.js、apache-kafka、node-gyp、librdkafka、node-kafka-streams

我正在尝试使用npm包，但下面是错误：似乎卡夫卡流，它试图使用node版本(v3.8.0)，但我有v5.0.3做了很少的修改，现在当我运行npm i kafka-

浏览 1提问于2019-07-27得票数 0

回答已采纳

1回答

在java中使用kafka流会导致错误：“从启动到PARTITIONS_ASSIGNED的意外状态转换”

java、apache-kafka、apache-kafka-streams

大家好，请大家注意使用kafka-连接java有问题，它不适合我，有人能帮我吗？ [est-fcdd4514-2d81-41d6-aead-15a8b08e6051-StreamThread-1] ERROR org.apache.kafka.streams.processor.internals.StreamThread - stream-thread [est-fcdd4514-2d81-41d6-aead-15a8b08e6051-StreamThread-1] Unexpected state tr

浏览 3提问于2020-04-23得票数 2

1回答

卡夫卡:线程“主”java.lang.NoSuchFieldError中的异常:跟踪

apache-kafka、apache-kafka-streams

String prefix = "B"; properties.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092"); properties.put(StreamsConfig.DEFAULT_VAL

浏览 5提问于2022-01-12得票数 1

4回答

StreamsException:无法初始化状态，如果Kafka Streams的多个实例在同一状态目录中运行，则可能会发生这种情况

spring-boot、java-8、apache-kafka-streams、spring-kafka

这是关于升级生产中的现有代码库，这些代码库使用来自kafka-clients，kafka-streams，spring-kafka 2.4.0到2.6.x的窗口，并将spring-boot-starter-parent2.2.2.RELEASE升级到2.3.x，因为2.2与kafka-streams 2.6不兼容。现有的代码在下面的旧版本中提到了这些bean(2.4.0，2.2春季版本)：public To

浏览 20提问于2021-05-15得票数 2

1回答

Scala Jar文件不适合Kafka Streams应用程序

scala、intellij-idea、apache-kafka、sbt、executable-jar

) //"org.slf4j" % "slf4j-simple" % "1.7.28", "org.apache.kafka" %% "kafka-streams-scala" % "2.3.0",

浏览 5提问于2020-01-23得票数 0

1回答

Kafka-streams:将内部主题清除策略设置为delete无效

apache-kafka、apache-kafka-streams

我使用卡夫卡版本1.0.0和kafka-streams版本1.0.0

浏览 0提问于2018-09-02得票数 6

回答已采纳

1回答

AccessDeniedException for Kafka 3默认state.dir

java、apache-kafka、windows-10

java.nio.file.AccessDeniedException: C:/tmp/kafka-streams/user/global api 'org.apache.kafka:kafka-clients' 我已经检查了文件夹权限，它似乎是只读的kafka-streams

浏览 4提问于2022-03-03得票数 0

回答已采纳

1回答

从中间主题加入KStream和KTable会导致异常

apache-kafka、apache-kafka-streams

我正在尝试加入一个KStream和一个KTable。如果没有联接，我从中间主题"book-attribute-by-id“中阅读就没有问题。{key: {id: 1}用于KStream的示例msg： value: {id: 1, book_id: 1, attribute_id: 1, value: 200}}{key: {id: 1}, value: {book_id: 1, at

浏览 1提问于2019-02-06得票数 0

回答已采纳

1回答

Kafka POM依赖版本问题

java、apache-kafka

我在我的项目中使用Kafka stream 2.3.0依赖项，但当我使用2.3.0构建JAR时，我看到2.0.1 Kafka版本并导致Kafka连接问题。我从来没有在我的代码中使用2.0.1，我想知道Kafka从哪里获得这个版本 <streams.version>2.3.0</streams.version><dependency> <groupId>org.apache.kafka<&#x

浏览 2提问于2020-08-13得票数 0

1回答

具有重要磁盘IO的Kafka流作业

apache-kafka、kafka-consumer-api、apache-kafka-streams

KStreams作业消耗了大量磁盘IO，我遇到了问题。这是一个最大IOPS为500的Azure VM，它消耗了大约500 This (从RHEL中的iostat到每秒处理400个记录)。作业从Kafka主题(12个分区)获取记录，解构JSON字符串并进行一些处理(字符串搜索、替换和数据充实)，然后将其传递给Kafka接收器(6个分区)。尽管如此，据我所知，这项工作应该是无状态的，不应该需要RocksDB或其他状态存储。我有commit.interval.ms=60000 (1分钟)，在Properties中设置为StreamsConfig.COMMIT_INTERVAL_MS_CONFIG=

浏览 0提问于2019-07-24得票数 0

回答已采纳

1回答

Spring kafka -构建kafka消费者失败

java、spring-boot、apache-kafka、spring-kafka

我在启动和运行我的Kafka / confluent spring boot with gradle项目时遇到了一个问题。我最初在这个测试项目中只有一个生产者，一切都运行得很好。然后我添加了一个Kafka消费者，现在我在启动时得到了一个异常。有人能发现这里的问题吗：首先，这是堆栈跟踪 2021-01-22 19:56:08.566 WARN 61123 --- [ main] ConfigServletWebServerApplicationContext : Exception encountered during context initialization -

浏览 506提问于2021-01-23得票数 0

回答已采纳

1回答

Kafka流:在不覆盖两个值的情况下配置‘`AdminClientConfig`’或‘`ConsumerConfig`’

scala、apache-kafka、kafka-consumer-api、apache-kafka-streams

使用kafka版本: 2.0.1和kafka-streams-scala版本2.0.1 调试2019年-05-08:57:53,322 he.kafka.clients.NetworkClient

浏览 0提问于2019-05-08得票数 2

回答已采纳

1回答

卡夫卡流-抵消提交失败。请求超时

java、apache-kafka、apache-kafka-streams

我正在使用版本： kafka_2.11: 2.1.1

浏览 0提问于2019-05-09得票数 0

6回答

Lib上的UnsatisfiedLinkError在使用Kafka流进行开发时对dll的影响

java、apache-kafka、apache-kafka-streams、rocksdb

我使用的是Kafka Streams版本0.10.2.1。 streamsConfiguration.put(StreamsConfig.APPLICATION_ID_CONFIG, "kafka-streams

浏览 14提问于2017-05-02得票数 8

回答已采纳

点击加载更多