Apache和Confluent kafka文档中对TopicNameMatches类的包引用都是错误的

文章/答案/技术大牛

发布

1回答

apache-kafka、apache-kafka-connect、confluent-platform、debezium

我尝试了使用用于MS SQL的debezium连接器的kafka connect转换谓词示例，并使用kafka connect的文档遇到了问题。两个文档中的示例都提到了错误的org.apache.kafka.connect.predicates.TopicNameMatches，，而不是正确的org.apache</em

浏览 23提问于2020-12-31得票数 1

回答已采纳

2回答

通过Confluent* CLI启动Kafka时，未拾取kafka日志配置*

apache-kafka、confluent-platform

我正在尝试从apache kafka升级到融合kafkalog.dirs=<customlocation>bin/confluent start kafka 然而，当我检查kafka data文

浏览 1提问于2017-12-05得票数 0

1回答

Kafka流集成测试-由于类包错配而无法编译- Apache，KafkaEmbedded

java、apache-kafka、apache-kafka-streams

我正在尝试编译集成测试类的代码，这些测试类位于Confluent GitHub - 中。我得到了一个SecurityProtocol类的编译时异常，该类目前存在于import org.apache.kafka.common.security.auth.SecurityProtocol;中。for org.apache.kafka.common.protocol.SecurityPr

浏览 1提问于2018-10-22得票数 0

回答已采纳

1回答

卡夫卡合流S3连接器“找不到类”

amazon-s3、apache-kafka、apache-kafka-connect、confluent-platform

我正在尝试一个简单的快速启动示例，我得到：由: org.apache.kafka.connect.errors.ConnectException:未能找到任何实现连接器且名称与io.confluent.connect.s3.S3SinkConnector匹配的类时，可用的连接器为: io.confluent.connect.jdbc.JdbcSinkConnector、io.confluent.connect.jdbc.JdbcS

浏览 0提问于2017-04-05得票数 4

回答已采纳

1回答

Kafka s3源连接器:未能实例化分区器类

apache-kafka-connect、confluent-platform

当我试图创建源连接器时，我遇到了错误，无法实例化类。所做的工作:安装了confluent-hub和confluentinc/kafka-connect-s3-source，CLASSHPATH被导出。CLASSPATH=/connector/share/confluent-hub-components/confluentinc-kafka-connect-s3-source/lib/

浏览 3提问于2019-10-16得票数 2

回答已采纳

1回答

Teradata和Apache* Kafka使用Kafka连接*

java、apache-kafka、teradata、apache-kafka-connect、confluent-platform

如果我的问题到处都是，很抱歉，但我是Apache Kafka的新手，目前我正在尝试使用Windows操作系统将Teradata表(在VM上)中的数据导入到Kafka中。到目前为止，我已经完成了以下工作： 1-下载Apache Kafka 2-运行Kafka服务器和Zookeper。3-使用IntelliJ集成开发环境用Java语言编写一个生产者类

浏览 0提问于2020-10-28得票数 2

1回答

Gradle将通过CLI而不是Intellij (实例方法不存在)

java、gradle、avro

浏览 4提问于2020-07-28得票数 0

1回答

Docker合流Kafka* HDFS Sink运行但任务失败*

docker、apache-kafka、hdfs、apache-kafka-connect、confluent-platform

我能够成功地运行Kafka并使用Kafka添加HDFS连接器。我用我的HOST_IP液滴的IP代替了。Connect时，在任务下的JSON响应中收到以下错误(服务的状态正在运行，但任务已失败)： io.confluent.kafka.serializers.subject.TopicNameStrategy不是io.confluent.kafka.serializers.subj

浏览 1提问于2018-08-18得票数 1

1回答

EmbeddedKafkaCluster不见了？

apache-kafka、integration-testing、apache-kafka-streams

这篇博客文章引用了EmbeddedKafkaCluster类，这个类应该在kafka-streams https://www.confluent.io/blog/stream-processing-part但是，库中缺少此类，例如org.apache.kafka/kafka-streams-test-utils/2.5.1.我想我可以使用github https:/

浏览 17提问于2020-10-06得票数 0

4回答

Kafka-Connect将SQL JAR文件添加到类路径

java、apache-kafka、apache-kafka-connect

我正在尝试部署一个独立的连接作业来从mssql服务器流传输，但是我遇到了一个问题(Kafka-Connect是我的Ambari部署的一部分，而不是docker)。这是我正在使用的属性文件：connector.class=io.confluent.connect.jdbc.JdbcSourceConnectorsqlserver://servernamequery=SELECT

浏览 1提问于2018-05-29得票数 1

1回答

无法在Windows上启动Confluent* Kafka Connect (NoClassDefFoundError: io/confluent/connect/storage/StorageSinkConnectorConfig*

windows、elasticsearch、apache-kafka、apache-kafka-connect、confluent-platform

我通过在C:\中解压confluent-oss-5.0.0-2.11.zip文件来安装Confluent包。当我执行以下命令(或相对路径的任意组合)时，Zookeeper、Kafka broker和ElasticSearch都已启动并运行： > C:\confluent-5.0.0\bin\windows\connect-standalone.batC:\confluent-5.0.0\etc\kafka\co

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

回答已采纳

1回答

Java gradle kafka-avro-serializer和kafka-schema-registry-client无法在部署管道中下载

java、gradle、apache-kafka、dependencies

尝试在云中部署我们的服务时，我遇到了两个传递依赖项无法下载的问题，错误如下： Welcome to Gradle 6.7.1!:2.32.0 > org.apache.beam:beam-sdks-java-io-kafka:2.32.0 > Could not resolve io.confluent:kafka-avro-serializer:2.32.0 > org.apache.beam:beam-sdks-jav

浏览 207提问于2021-11-22得票数 0

回答已采纳

3回答

Kafka Connect Api -入门？

apache-kafka

我想了解一下Kafka连接模块的开发生命周期。遵循，我想使用"connect api“编写一个自定义的Kafka连接模块，但我不知道从哪里开始。有没有一些最小的例子来说明如何做到这一点？顺便说一句，我构建了这个，并试图(在谷歌云上)运行它，但我发现了错误--显然是一个缺失的依赖项，但我不知道该添加什么。当然，这可能只应该在融合平台上运行。如果它可以在其他地方运行，那就太好了。java.lang.NoClassDefFoundError: org/<

浏览 1提问于2016-03-22得票数 2

回答已采纳

1回答

未能连接到合流平台架构注册表- Apache* Confluent格式*

apache-kafka、apache-flink、confluent-platform、confluent-schema-registry、flink-sql

我正在使用集群、Schema服务，并试图在Flink作业中处理Debezium消息。作业被配置为使用Table & SQL连接器和Confluent格式。>:<SR_API_SECRET> https://<SR_ENDPOINT> 它看起来像是未经授权的错误消息"io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientExc

浏览 3提问于2021-02-08得票数 3

1回答

为融合云安装连接器

apache-kafka、ibm-mq、confluent-cloud

我正在尝试为我们的合流云安装MQ源和宿连接器。我已经为本地apache kafka做了这件事，但对云做同样的事情似乎是不同的。根据confluent文档，我需要在本地安装一个平台，然后运行confluent-hub安装，在本地安装连接器，然后使用json for distributed instance。我的问题是，当我运行json时，它说没有找到mq的类，我试图将CLASSPAT

浏览 20提问于2021-10-17得票数 0

1回答

模式注册表在升级到合流4.1后不会启动

apache-kafka、confluent-platform、confluent-schema-registry、ksqldb

下面是模式注册日志中的错误： [2018-04-20 11:27:38,426] ERROR Error starting the schema registry (io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplicationat org.apache.kafka.clients.producer.internals.FutureRecordMetadata.valueOrError(Futur

浏览 2提问于2018-04-20得票数 0

回答已采纳

1回答

卡夫卡属地- ccs对ce

java、maven、apache-kafka、apache-kafka-connect、confluent-platform

为了开发我的Kafka连接器，我需要添加一个connector依赖项。但是从到的链接，除了5.5.0-ccs，还有5.5.0-ce版本。所以，在这个时候，最后的版本是：我应该用哪一个？

浏览 5提问于2020-04-30得票数 8

回答已采纳

2回答

尝试启动动物园管理员服务器-合流设置时出错

apache-kafka、apache-zookeeper、confluent-platform

为了启动ZooKeeper服务器，我按照下面的从Confluent的根目录运行。出现的错误是- at org.apache.log4j.LogManager.).log4j:WARN See http:/&#

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

回答已采纳

1回答

Kafka Streams创建无模式的avro主题

java、apache-kafka、avro、apache-kafka-streams、confluent-platform

我开发了一个java应用程序，它使用Schema Registry从avro主题读取数据，然后进行简单的转换，并在控制台中打印结果。默认情况下，我对键和值使用GenericAvroSerde类。keyGenericAvroSerde.configure(serdeConfig, true);如果不这样做，我总是会得到如下错误at org.apache.kafka</

浏览 0提问于2017-10-05得票数 2

1回答

卡夫卡连接S3动态S3文件夹结构创建？

amazon-web-services、amazon-s3、apache-kafka、apache-kafka-connect、confluent-platform

不会抛出错误。但是，在AWS S3中，不为新数据创建文件夹结构，也不存储JSON数据。连接器是否应该在看到主题的第一个JSON数据包时动态创建文件夹结构？除了配置awscli凭据之外，connect.properties和s3-sink.properties还有其他需要设置的设置来正确连接到S3桶吗？关于安装文档的建议比汇合网站上的独立文档更全面？S3 key.converter=org.apac

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

回答已采纳

点击加载更多