1回答
我使用下面的脚本创建连接器，但在S3中，我看到分区格式为/year=2015/month=12/day=07/hour=15/。io.confluent.connect.s3.format.json.JsonFormat", "s3.bucket.name": "kafka-connect-test
浏览 24提问于2021-01-05得票数 1
我想使用Kafka将数据从本地流式传输到云(S3)。为此，我需要在源机和云上安装kafka。但我不想把它放在云端。我需要一些S3连接器，通过它我可以与kafka连接，并将数据从本地传输到云。
浏览 1提问于2017-03-29得票数 2
我正在使用Strimzi，Kafka，Kafka Connect和一个自定义连接器插件，遵循。
我知道原因:它找不到插件(一个jar文件)。但是如果我进入卡夫卡-连接荚，我
浏览 6提问于2021-12-10得票数 0
回答已采纳
1回答
我正在为一家零售组织工作，并试图将Kafka streams与Glue直接集成。我的意思是将Kafka主题作为输入源放到AWS胶水中。我使用的是Apache Kafka 2.12。如果有人在这个集成模式上工作过，我会来这个小组寻求一些帮助。我在集成测试过程中遇到的问题如下2)在
浏览 0提问于2020-06-04得票数 0
2回答
我正在编写一个Kafka连接器，以便从Github上的多个来源下载一些数据(文本和yaml文件)，并将它们转换为某个类的对象，这些对象是从avsc文件自动生成的： { sourcePartition, matomoTopic, org.apache.kafka</e
浏览 11提问于2019-06-04得票数 1
回答已采纳
与极光( MySQL )的连接测试正常。Kafka主题创建，列表都可以。然而，当我运行连接器时，在滚动了大量信息之后，我得到了 WARN [Producer clientId=xxx] Error while fetching metadata with correlationid 1 : {xxx.xxx=INVALID_REP
LICATION_FACTOR} (org.apache.kafka.clients.NetworkClient:1100) 他们中的许多人不断出现，并且连接
浏览 252提问于2021-05-02得票数 1
回答已采纳
我试图下沉的表数据一个数据库到另一个数据库使用kafka debezium ( Kafka流)在docker的帮助下。DB流工作正常。但是流式数据接收另一个MySQL DB进程时出错。我的连接器接收器配置如下。: command: [start-kafka.sh] - "9092:9092" - zookeep
浏览 4提问于2019-11-21得票数 3
我使用卡夫卡连接创建一个MQTT卡夫卡连接，我把所有卡夫卡MQTT连接器特定的jar从汇流网站下载到"/data“文件夹。并相应地更新"connect-standalone.properties“文件以反映插件路径，即当我运行卡夫卡连接/jcustenborder/kafka/co
浏览 0提问于2019-07-18得票数 0
我目前正在让Kafka使用相同的group.id连接两个节点的集群 当使用curl /connectors时，我可以获得我创建的连接器的列表，但我看不到关于活动节点的信息，健康检查...
浏览 25提问于2019-02-05得票数 1
4回答
我正在尝试使用Kafka Connect Elasticsearch连接器，但没有成功。中有以下一行：我可以看到文件夹中的各种连接器，但是Kafka C
浏览 1提问于2018-11-21得票数 9
我目前有一个3节点的Kafka集群，它连接到我的zookeeper集成中的基本chroot路径。zookeeper.connect=172.12.32.123:2181,172.11.43.211:2181,172.18.32.131:2181
现在，我想添加一个新的5节点Kafka集群，它将连接到同一zookeeper集成中的其他一些chroot路径。zookeeper.connect=172.12.32.123:2181,172.11.43.211:2181,172.18.32.13
浏览 92提问于2019-10-24得票数 0
回答已采纳
我是卡夫卡和卡夫卡连接世界的新手。我试图使用Kafka (在MSK上)、Kafka (使用PostgreSQL的Debezium连接器)和一个RDS实例来实现CDC。Kafka运行在部署在AWS中的集群中的K8吊舱中。在深入研究所使用的配置细节之前，我将尝试总结一下这个问题： "key.converter": "org
浏览 0提问于2021-07-09得票数 0
在Ksqldb服务器中嵌入Kafka连接器时，“卷”映射似乎不起作用ksqldb-server: ports: volumes:
- "/usr/local/share/kafkaKSQL_KSQL_LOGGING_PROCESS
浏览 13提问于2021-07-20得票数 2
我构造了一个spring boot应用程序来在Kafka中生成数据，但现在我需要将该应用程序连接到旧的Kafka (0.11v)。我尝试只更改bootstrap-server，但收到连接错误。我再次检查了这个Kafka实例是否工作正常，以及其他应用程序是否正在连接。
我的问题是，像v2.5.4.RELEASE这样的spring-Kafka的新版本是否可以连接到旧版本的Kafka。旧版Kafk
浏览 3提问于2020-08-28得票数 0
由于服务器没有使用HTTP，我预计会出现通信错误，但是如果curl甚至不能连接，并且我必须退出ctrl，那么TCP连接就不能工作了。reset by peer同样，我也可以将炮弹插进卡夫卡舱：通过服务名称连接到动物园管理员吊舱可以正常工作<
浏览 1提问于2018-03-09得票数 3
回答已采纳
我想继续用FilePulse源连接器在ksqldb中读取csv文件，但是它不能正常工作。( a)连接器只读取文件一次或( b)连接器从文件中读取所有数据，但在这种情况下，kafka主题中存在重复(每次连接器读取附加文件，然后将所有数据从文件插入到主题中--不仅仅是更改后的数据)。(连续读取文件中附加的数据或删除kafka主题中的重复)
谢谢
浏览 8提问于2022-01-02得票数 0
2回答
我有一个独立的kafka在windows上运行，一个JDBC源连接器连接到postgress db，这在我的机器上是可用的。当我尝试运行连接器时，它显示一个警告，指出由于找不到表，因此不会运行任何任务。然而，如果我使用mysql数据库(也是本地安装的)连接相同的连接器。它能够拿起桌子，并且工作正常。请注意，我使用的是confluent的jdbc连接器和默认的apache-kafka。下面是我从postgress得到的
浏览 39提问于2021-06-16得票数 1
回答已采纳
1回答
但是，我不能从启动连接，也许是因为我需要提供的安全证书？我已经尝试将引导属性设置为：获取错误:在身份验证期间终止到节点-1 (/xx.xx:9092)的连接。这可能是由于以下任何原因造成的：(1)身份验证失败是由于代理的凭据无效，代理的年龄超过1.0.0；(2)防火墙阻塞Kafka TLS通信量(例如，它可能只允许HTTPS通信)；(3)瞬态网络问题。spring.kafka.prop
浏览 2提问于2020-03-02得票数 1
目前在我的kafka-start.sh脚本中，Kafka是否正常工作是通过检查kafka的PID来确定的。但是只检查PID并不能帮助我们确定kafka是否正常工作。有没有其他方法来判断“Kafka是否运行正常”？
浏览 1提问于2017-03-22得票数 0
我试图让JMX监控来监控一个测试kafka实例。
我有卡夫卡(千斤顶/卡夫卡)运行在码头通过boot2docker，但我不能得到正确配置的JMX监控。我已经做了大量的故障排除，我知道kafka实例正在正常运行(消费者和生产者都在工作)。当我尝试简单的JMX工具(j控制台和jvisualvm)而两者都无法连接(不安全的连接错误，连接失败)时，就会出现问题。配置注意事项:我连接到192.168.59.103 (运行'b
浏览 1提问于2015-07-01得票数 2
回答已采纳
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
