我正在尝试使用Kafka Connect和kafka-connect-twitter在Github的jcustenborder中将Twitter推文引入Kafka。connect avro docker属性文件在kafka-connect-twitter存储库中运行mvn clean包后，似乎希望使用target/kafka-connect-target/usr/我<e
浏览 47提问于2021-11-12得票数 0
回答已采纳
我正在尝试使用https://github.com/jcustenborder/kafka-connect-spooldir中的SpoolDirCsvSourceConnector 我在Kafka中有以下连接器配置： connector.class=com.github.jcustenborder.kafka.connect.spooldir.SpoolDirCsvSourceConnector
csv.firs
浏览 13提问于2019-02-09得票数 1
回答已采纳
我正在尝试做一个POC，我们需要连接RabbitMQ和Kafka。我的问题是，是否有可能将RabbitMQ和卡夫卡联系起来？提前感谢
浏览 0提问于2018-06-05得票数 2
在担心密钥之前，我可以使用HdfsSinkConnector将Avro值保存在datalake上的文件中。为此，我使用了kafka-connect-transform-archive，它将字符串键和Avro值包装到一个新的Avro模式中。 这很有效..。"transforms": "tran",
"transforms.tran.type": "com.github.jcustenborder.kafka.co
浏览 9提问于2019-04-26得票数 2
/releases/download/0.0.1.11/kafka-connect-snmp-0.0.1.11.tar.gz
RUN mkdir /tmp/kafka-connect-snmp && tar-xf /tmp/kafka-connect-snmp-0.0.1.11.tar.gz -C /tmp/kafka-connect-s
浏览 28提问于2019-12-20得票数 2
回答已采纳
如何在s3连接器中使用kafka msg key作为分区标准，或者如何获取key并将其存储在s3对象中，谢谢！
浏览 18提问于2020-08-24得票数 0
回答已采纳
使用独立模式，我创建了一个连接器，并进行了如下定制的转换：connector.class=com.github.jcustenborder.kafka.connect.rabbitmq.RabbitMQSourceConnectorEOF >/tmp/connector "name": "rabbitmq-source", "connecto
浏览 17提问于2017-09-08得票数 1
回答已采纳
因此，我在MySQL源连接器中使用debezium key.field.name将字段添加到我的主题中。 该消息在登录到主题后显示在下面。": "compose-connect-group", "database.history.kafka.sasl.mechanism": "kafka:9092",
"time
浏览 24提问于2021-01-06得票数 0
1回答
我对从SQL Server加载数据到Kafka感兴趣。表中的一列是XML one。如何在KSQL streams中将XML转换为JSON或AVRO共振峰？
浏览 9提问于2020-02-05得票数 1
我尝试使用这个Kafka连接器: com.github.jcustenborder.kafka.connect.spooldir.SpoolDirCsvSourceConnector在Kafka集群上公开"name": "CsvSpoolDirAutoAck", "connector.class": "com.github.<e
浏览 8提问于2022-02-03得票数 0
我使用Kafka-Python将CSV数据发送到Kafka topic。消费者收发数据成功。现在我正在尝试连续流式传输csv文件，任何添加到该文件的新条目都会自动发送到Kafka主题。任何建议都会对CSV文件的连续流式传输有所帮助 下面是我的现有代码， from kafka import KafkaProducer from json
浏览 138提问于2020-06-17得票数 0
我正在使用卡夫卡连接到redis。curl -s -X POST -H 'Content-Type: application/json' --data @connector.jsonconnector.json文件包含： "config" : {
浏览 0提问于2019-09-15得票数 1
回答已采纳
2回答
谢谢现在我在跑步：kafka-connect-cdc-mssql-0.0.1-SNAPSHOT.jar
jar tvf kafka-connect</
浏览 3提问于2017-09-06得票数 2
回答已采纳
2回答
当我尝试用kafka-connect-spooldir安装confluent-hub时：
confluent-hub install jcustenborder/kafka-connect-spooldir
浏览 0提问于2019-06-12得票数 0
回答已采纳
我正在使用Kafka Connect加快速度。尝试使用Kafka Connect Elasticsearch Service接收器连接器将我们的数据从Kafka移动到Elasticsearch。我们的应用程序发布一个删除操作的事件，并将其设置为Kafka消息中标头值的一部分。我们希望删除文档本身，而不是使用此删除操作信息更新elastic中的文档。我们如何使用Kafka Connect</e
浏览 23提问于2021-04-07得票数 0
回答已采纳
我试图使用谷歌PubSub源连接器从我的谷歌云获取数据到卡夫卡。我确实得到了数据，但是消息以字节的形式出现。我引用了，并且如前所述，我使用了一个JSON转换器来更改它。下面是我的连接器代码部分：connector.class=com.google.pubsub.kafka.source.CloudPubSubSourceConnectortasks.max=10kafka.topic.replication.
浏览 6提问于2020-08-26得票数 0
回答已采纳
我必须将csv数据从对象存储(只能使用url访问)加载到kafka主题。如何将该csv数据加载到kafka中的topic中?请讲解具体步骤。后台文件配置：
{"connector.class":"com.github.jcustenborder.kafka.connect.spooldir.SpoolDirCsvSourceConnector
浏览 6提问于2021-06-09得票数 0
我使用卡夫卡连接创建一个MQTT卡夫卡连接，我把所有卡夫卡MQTT连接器特定的jar从汇流网站下载到"/data“文件夹。并相应地更新"connect-standalone.properties“文件以反映插件路径，即当我运行卡夫卡连接/config/connect-mqtt-source.properties
2019-0
浏览 0提问于2019-07-18得票数 0
: container_name: kafka-connect CONNECT_KEY_CONVERTER: org.apache.kafka.connect.storage.StringConverter:10.0.2
conf
浏览 9提问于2022-08-15得票数 1
云服务器
ICP备案
云直播
即时通信 IM
对象存储
腾讯云开发者
