1回答
at org.apache.kafka.connect.runtime.Worker.startConnector(Worker.java:241)bootstrap.servers=kafka1:19092
key.converter=org.apache.kafka.connect.jso
浏览 0提问于2018-12-19得票数 0
回答已采纳
我们有一个运行在Kubernetes上的Kafka Connect集群，一些Snowflake连接器已经启动并工作。我们现在遇到的问题是试图从Kafka Connect集群中获取JMX指标以在Datadog中报告。根据我对文档(https://docs.confluent.io/home/connect/monitoring.html#using-jmx-to-monitor-kconnect)的理解，默认情况下工作人员已经在发出指标在我们的K8配置图中，
浏览 40提问于2021-07-08得票数 0
1回答
我有一个接口程序-E29，其中我运行了动物园管理员、Kafka、Kafka Connect和KafDrop，问题是，当我在本地运行时，我可以从我的Spring Boot<code>E 29</code>: 1 KAFKA_LISTENERS:
浏览 1提问于2020-12-07得票数 3
我使用kafka-connect镜像confluentinc/cp-kafka-connect已经有一段时间了。然而，我尝试将confluentinc/cp-kafka-connect更新到最新的v6.0.1，现在我得到了错误。: confluentinc/cp-kafka-connect:5.4.1 #using old version because of breaking change
hostname: <em
浏览 23提问于2021-01-26得票数 0
回答已采纳
3回答
: ports: environment: KAFKA_ZOOKEEPER_CONNECT: KAFKA_REST_LISTENERS: http://ka
浏览 0提问于2017-03-27得票数 19
我使用的是confluent的kafka连接器docker image confluentinc/cp-kafka-connect:5.4.0-beta1。cloudkarafka代理的连接： image: confluentinc/cp-kafka-connect:5.4.0-beta1
浏览 10提问于2020-05-20得票数 0
回答已采纳
(ElasticsearchSinkTask.java:126) at org.apache.kafka.connect.runtime.WorkerSinkTask$HandleRebalance.onPartitionsAssigned(at org.apache.kafka.connect.runtime.Wor
浏览 14提问于2022-07-27得票数 0
假设我有一个Kafka Connect worker，它是我使用confluentinc/cp-kafka-connect镜像中的Docker构建的，部署到服务器上并启动一个worker。
浏览 1提问于2020-03-21得票数 0
(RetryWithToleranceOperator.java:104)\n\tat org.apache.kafka.connect.runtime.TransformationChain.apply:292)\n\tat org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:228)\n\tatorg.apache.kafka.connect.runtime.WorkerTas
浏览 43提问于2020-06-23得票数 3
2回答
我下载了，并在kafka目录中构建了相同的jar manually.Placed，并在connect-standalone.properties中提到了插件路径。connect-standalone.propertieskey.converter=org.apache.kafka.connect.json.JsonConvertervalue.converter=org.apache.kafka.connect</e
浏览 6提问于2021-08-18得票数 0
我正在使用在ubuntu .I上安装docker kafka connect我可以运行它，但是我不能在里面安装更多的连接器。2-还在connect-distributed.properties中添加了插件路径。怎么做到这一点有什么想法?？
浏览 2提问于2020-07-30得票数 2
他们创建了一个自述文件来指导如何设置kafka的配置： "name" : "RedisSinkConnector1",
"connector.class" : "com.github.jcustenborder.kafka.connect</em
浏览 0提问于2019-09-15得票数 1
回答已采纳
2回答
我有一个Kafka连接源和接收器连接器，用于将数据放入Kafka中并将其取出来。我正在使用docker-compose运行Kafka和Kafka Connect，它在分布式模式下运行connect。确保在connect启动时它能找到我的插件，但它实际上不会做任何事情，除非我对JSON执行POST操作，包括/connectors中的配置。
浏览 21提问于2019-02-26得票数 3
回答已采纳
我想在hortonworks 2.4上使用kafka-connect-hdfs。您可以帮助我在HDP环境中设置需要遵循的步骤吗？
浏览 1提问于2016-09-29得票数 2
我尝试使用这个命令从Kafka获取主题，但它甚至在Docker显示[KafkaServer id=1001] started (kafka.server.KafkaServer)之前就已经报道过了。docker start queue-service-kafka && docker-compose exec kafka /opt/kafka/bin/kafka-topics.sh --list -
浏览 1提问于2018-12-06得票数 1
回答已采纳
这是我们用来托管docker-connect和插件的docker镜像 FROM confluentinc/cp-kafka-connect:5.3.1
RUN mkdir /tmp/kafka-connect-s
浏览 28提问于2019-12-20得票数 2
回答已采纳
卡夫卡连接开始时(例如在汇合平台)，是否有自动加载(多个) Kafka连接连接器的方法？到目前为止我发现的是：是否还有另一种方法，例如，将所有的连接器都包含在“Connect -独立的\\Distributed.properties”文件中(类似于在KSQL -server.properties中提供ksql查询文件)，以便在Kafka Connect启动时自
浏览 2提问于2019-06-06得票数 5
1.5.5 (installed in `/home/ubuntu/kafka/libs`connect-standalone.properties/maven2/org/apache/kafka/connect-transforms/2.5.1/conne
浏览 2提问于2021-09-24得票数 1
回答已采纳
\"dbserver1\", \"database.history.kafka.bootstrap.servers\": \"kafka:9092\",
\"database.history.kafka.topic\": \"dbhistory.invento
浏览 84提问于2021-07-15得票数 0
我在Kafka中有主题是以Avro格式存储的。我想消费整个主题(在收到时不会更改任何消息)，并将其转换为Parquet，直接保存在S3上。我目前是这样做的，但它要求我一次使用一个来自Kafka的消息，并在本地机器上进行处理，将它们转换为拼图文件，一旦使用完整个主题并完全写入拼图文件，就关闭编写过程，然后启动一个S3多部分文件上传。或者简称为| Avro in Kafka -> convert to parquet on local -> copy file to S3 |。我想要做的是| Avro in Kafka</e
浏览 24提问于2019-06-13得票数 3
云服务器
ICP备案
对象存储
即时通信 IM
腾讯会议
腾讯云开发者
