我创建了一个cassandra-sink连接器，之后我在connector.properties文件中做了一些修改。在停止worker并再次启动它之后，现在当我使用以下命令添加连接器时：我得到以下错误：
Error: the Kafka Connect API ret
浏览 0提问于2018-02-23得票数 16
回答已采纳
我正在尝试订阅一个带有kafka的mqtt主题，为此我使用了以下连接器：。我按照上面描述的步骤做了一些修改，一切似乎都很顺利。但是，当我启动连接器时，我会得到一个 (屏幕截图)，连接器就会停止。它似乎来自IMqttMessageListener，但我不知道如何解决这个问题。connector.class : be.jovacon.kafka.connect.MQTTSourceConnector
mqtt.broker :
浏览 0提问于2020-05-10得票数 2
回答已采纳
我面临的情况是，多个开发人员正在致力于特定的kafka源或接收器连接器配置。连接器通过创建、更新、删除等。必须保证
开发人员从不删除或修改他人的连接器。开发人员只能管理特定connector.class的连接器，例如connector.class。是否有任何方法来配置Kafka，将Kafka-Connect REST的使用限制在与连接器配置细节相关的特定操作上？卡夫卡ACL似乎没有涵盖这一用途。
浏览 10提问于2022-07-22得票数 0
回答已采纳
Confluent默认为Kafka主题提供此JMSSourceConnector。我在Confluent页面上没有看到任何关于这方面的文档。
浏览 13提问于2016-09-24得票数 1
回答已采纳
我使用sql-server kafka-connect和debezium来监视sql server数据库，但是当我发布并运行我的工作程序时，主题已经用名称{server_name}.如何手动更改表主题的分区和复制，或者在worker/connector配置中预先指定？此外，不同的主题可能有不同的分区和复制。
浏览 0提问于2019-12-30得票数 2
我们从Confluent 4.0.0升级到5.0.0，升级后我们无法列出kafka connect hdfs接收器连接器消费者lag。$ /opt/kafka/bin/kafka-consumer-groups.sh --bootstrap-server <hostname>:9092 --list | grep scribe_log_backend5.0.0中的消费者组命令有什么修改吗？如何跟踪我们需要根据此延迟发出警报的延迟？我们的
浏览 0提问于2018-09-17得票数 0
我正在尝试做一个POC，我们需要连接RabbitMQ和Kafka。我的问题是，是否有可能将RabbitMQ和卡夫卡联系起来？提前感谢
浏览 0提问于2018-06-05得票数 2
我有一个需求，我需要消费Kafka Topic并将其写入MQ Topic。有人能建议我做它的最好的方法，我是新手卡夫卡。我在confluent中读过关于IBM MQ Connector的文章，但不知道如何实现它。
浏览 55提问于2019-05-28得票数 0
回答已采纳
相反，Kafka提供了它的API接口，它对于处理配置以及任务、工作人员等都非常有用。
解决如何构建一个像Kafka这样的REST接口API，它封装了Kafka应用程
浏览 11提问于2021-04-26得票数 0
在snowflake连接器中应该为主题提供什么？
因为我能够使用所需的主题名称通过单个表数据填充数据。但我有捕获连续数据流到表中的要求。
浏览 0提问于2021-10-07得票数 5
1回答
我正在修改memsql Kafka连接器代码，而且Kafka Connector似乎没有使用Kafka使用者订阅API，所以我想知道是否有任何方法来改变消费者的配置，如组id、分区分配策略，……？
浏览 10提问于2021-01-11得票数 1
回答已采纳
1回答
我在AWS的Kafka服务器会生成AVRO消息，根据我所看到的，Dataflow需要接收JSON格式的消息。因此，我搜索并找到了一篇文章，解释了如何向PubSub接收消息，但在PubSub上，我只看到在这种体系结构中，他们在GCP上创建了一个Kafka来生成消息。我需要知道的是：
可以从外部的Kafka服务器在PubSub上接收AVRO消息，然后使用messages反序列化消息，将其发送到Dataflow，并最终将其发送到BigQuery表？还是我需要创建一个Kafka并使用它来使用来自外部服务器的消
浏览 1提问于2021-04-27得票数 3
回答已采纳
我需要关于这个github代码的帮助：我能够正常地编译它，但是没有多少关于如何使用它的信息。我现在唯一关心的是知道我必须使用JSON格式发送到这个连接器的消息格式是什么，这样他就可以解释它并添加到Cassandra数据库中。First record kafka coordinates:({}-{}-{}). Writing them to Cassandra...最后是配置文件(cassandra-sink.propert
浏览 1提问于2019-10-15得票数 0
我有Mule应用程序，并使用Apache Kafka连接器连接主题。mule-kakfa连接器jar是"mule-module-kafka-2.1.0.jar“连接器使用producer.properties和consumer.properties文件，这些文件包含纯文本形式的你能建议如何加密这些密码和使用在mule流程中。Mule Kafka连接器代码在mule流中。producerPropertiesFile="producer
浏览 42提问于2019-06-11得票数 0
1回答
我已经在docker上使用终端上的curl创建了一个debezium连接器，并且我一直在修改现有的连接器。#"transforms.dropPrefix.regex":"procura.dbo.(.*)",
"transforms.dropPre
浏览 26提问于2020-01-21得票数 0
回答已采纳
在JSON中从Kafka生产/消费。使用以下属性保存到JSON中的HDFS：value.converter=org.apache.kafka.connect.json.JsonConverterkey.converter.schemas.enable=false制片人：
curl -X POST -H "Content-Type:
浏览 0提问于2016-11-21得票数 1
我已经实现了一个Kafka Connect JDBC Source连接器，它连接到Oracle-Database，并将数据写入Kafka-Topic。目前，我已经在设置value.converter.schemas.enable=false的情况下设置了选项value.converter=org.apache.kafka.connect.json.JsonConverter该选项允许将JSON数据写入Kafka主题(顺便说一句，它工作得很好)，但不包括在将数据发送到Kafka代理之前<e
浏览 3提问于2021-02-18得票数 0
我们希望在读取来自kafka的消息时实现并行性。因此，我们希望在flinkkafkaconsumer中指定分区编号。它将读取kafka中所有分区的消息，而不是特定的分区号。
浏览 139提问于2020-07-09得票数 1
到目前为止，我使用kafka spring在this blog上生成了一条主题消息。如何实现上述功能？
浏览 12提问于2021-08-25得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
实时音视频活动推荐
腾讯云开发者
