Kafka Connect Vertica Sink连接器端口问题

文章/答案/技术大牛

发布

2回答

从Kafka到Vertica的数据导入(vkconfig Kafka连接器)

apache-kafka、apache-kafka-connect、vertica

我知道Vertica有从Kafka导入数据的vkconfig。但是，Confluent似乎也有一个连接器可以做同样的事情。正如他们的网站所说："Vertica Sink Connector for Confluent Platform -您可以使用Kafka Connect Vertica Sink连接器将Apache Kafka主题中的数据导出到Vertica。

浏览 0提问于2020-02-13得票数 0

1回答

apache-kafka、apache-kafka-connect

我正在尝试使用Vertica Sink连接器。我们拥有的数据库端口是443。连接器期望它介于1025和65535之间。我得到的错误如下所示。这里可以做些什么？"message"：“连接器配置无效，包含以下1个错误：\n无效值(443)必须介于1025和65535之间。对于configuration vertica.port\nYou，还可以在终结点/{connectorType}/config/validate找到上面的

浏览 14提问于2020-02-13得票数 0

1回答

设置kafka-connect以从远程代理获取数据

apache-kafka、remote-server、apache-kafka-connect

我正在尝试设置Kafka连接接收器连接器。Kafka connect是Kafka connect worker (confluent-3.2.0)的一部分。我想在另一台机器B上设置Kafka-connect-sink连接器，以使用自定义的Kafka-connect-sink连接器jar消费消息。假设机器A上的Kafka brok

浏览 1提问于2017-06-09得票数 0

2回答

复位卡夫卡连接水槽连接器

apache-kafka、apache-kafka-connect、aerospike

我想重置AerospikeSink卡夫卡连接器偏移量，我是通过删除连接器消费者组(connect-*)偏移量，然后重新创建它。注意:创建具有新名称的新连接器的没有解决问题。在重置补偿之前：重置补偿后：在用tasks = []重新创建连接器之后在使用tasks在RUNNING状态下重新创建连接器之后：Kafka Connect日志：org.apache.kafka.con

浏览 13提问于2021-08-13得票数 2

回答已采纳

1回答

如何在分布式模式下部署kafka连接？

distributed、apache-kafka-connect

我正在使用kubernetes中的JDBC接收器连接器构建Kafka连接应用程序。我尝试了独立模式，它是有效的。我想转到分布式模式。: vtqspec: template: labels:app: kafka-sink-postgres-dis containers: - name: kafka</e

浏览 1提问于2019-08-28得票数 4

1回答

卡夫卡·蒙戈对库伯内特斯(小库贝)(蒙戈作为卡夫卡不起作用的来源)与比特尼/卡夫卡

mongodb、kubernetes、apache-kafka、apache-kafka-connect、bitnami

图表：/bitnami/kafka/ 为了解决extraDeploy问题，我遵循了。这个问题已经解决，我的工作安排如下： connector.class=com.mo

浏览 3提问于2022-01-20得票数 0

2回答

kafka连接连接器不会自动启动

apache-kafka、apache-kafka-connect

我有一个Kafka连接源和接收器连接器，用于将数据放入Kafka中并将其取出来。我正在使用docker-compose运行Kafka和Kafka Connect，它在分布式模式下运行connect。确保在connect启动时它能找到我的插件，但它实际上不会做任何事情，除非我对JSON执行POST操作，包括/connectors中的配置。在安装插件时，我是否遗漏了一个步骤，或者在将连接器分配给工作人员之前，是否需要通过REST

浏览 21提问于2019-02-26得票数 3

回答已采纳

2回答

无法在Kafka Connect 2.4中成功覆盖我的连接器

java、apache-kafka、apache-kafka-connect

我想创建一个这样的例子： Map<String, String>ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest"); 接下来，我将创

浏览 6提问于2020-04-09得票数 1

4回答

Kafka connect不适用于文件流

streaming、apache-kafka、apache-kafka-connect

我一直在使用Kafka connect for confluent platform，使用的指南如下但是它不再更新接收器文件，源文件中的任何更改都不会写入kafka主题中。

浏览 0提问于2016-09-07得票数 0

2回答

org.apache.kafka.connect.runtime.rest.errors.BadRequestException

mongodb、confluent-schema-registry、confluent-platform

我正在尝试编写一个kafka连接器，将kafka主题中的数据移动到mongodb(接收器)中。/etc/kafka/connect-mongodb-sink.properties (org.apache.kafka.connect.cli.ConnectStandalone:104)我试图通过改变连接-mongo-sink.properties中的connection.uri来解决这个

浏览 1提问于2019-07-23得票数 0

回答已采纳

1回答

我能用一个卡夫卡连接附加多个接收器配置吗？

apache-kafka、apache-kafka-connect

接下来，我们将我们的CassandraSink配置发布到Kafka。java -jar kafka-connect-cli-0.5-all.jar create cassandra-sink-orders < cassandra-sink-distributed-orders.propertiescassandra-sink-orders**:** 连接器connector.class=co

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

1回答

Docker容器中的Kafka连接:未添加连接器

apache-kafka、apache-kafka-connect

，所以我不认为这会是个问题。由于我没有添加任何连接器，所以我查询可用的连接器：[ "class": "org.apache.kafka.connect.file.FileStreamSinkConnector", "version": "

浏览 0提问于2020-03-11得票数 0

回答已采纳

1回答

Windows上的Kafka* Connect for Oracle安装程序*

apache-kafka、windows-7、apache-kafka-connect

我可以在我的windows7机器上设置Kafka服务器/zookeeper。创建了一个.NET应用程序来生产和使用应用程序。我现在需要oracle来使用生成的主题。我需要一些关于在我的运行在Windows 7上的Kafka上设置Kafka连接的说明。请给我一些如何做到这一点的指导。我对卡夫卡非常陌生。到目前为止，我所做的只是在windows上设置Kafka服务器。

浏览 26提问于2019-06-07得票数 0

回答已采纳

1回答

本地系统中的kafka进出口数据

hadoop、apache-kafka、bigdata

sink.properties。但我错了错误未能为配置/连接文件-sink.properties创建作业，(org.apache.kafka.connect.cli.ConnectStandalone:89) 2017-05-1021:26:49,110错误停止后，连接器错误(org.apache.kafka.connect.cli.ConnectStandalone:100) java.util.concurrent.ExecutionException:

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

1回答

Kafka Connect群集不加载简单的连接器插件

java、apache-kafka、apache-kafka-connect

我试图在Connect集群中加载一个简单的Kafka连接器。我为连接器创建了jar，并启动了Kafka作为对接器。在日志中，我可以看到它正在加载插件。码头正确挂载jar文件。"},{"class":"io.confluent.connect.jdbc.JdbcSinkConnector","type":"sink","version":"5.5.0&q

浏览 4提问于2021-10-19得票数 1

回答已采纳

2回答

Kafka Connect -如何删除连接器

apache-kafka、apache-kafka-connect

我创建了一个cassandra-sink连接器，之后我在connector.properties文件中做了一些修改。在停止worker并再次启动它之后，现在当我使用以下命令添加连接器时：我得到以下错误： Error: the <em

浏览 0提问于2018-02-23得票数 16

回答已采纳

1回答

如何在kafka接收器连接器中设置特定表？

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

我使用的是confluent kafka连接器。我想将数据插入到接收器连接器中的特定表TB_TEST_KAFKA中。我已经创建了这个表。 auto.create=false。我不知道接收器连接器的属性、表名、键。但是错误 Caused by: org.apache.kafka.connect.errors.ConnectException: Table "TB_TEST_KAFKA" is missing andat io.co

浏览 51提问于2021-08-10得票数 0

2回答

卡夫卡对接

apache-kafka、dockerfile、apache-kafka-connect

/bin/connect-standalone启动连接器时，它会失败，出现以下错误org.apache.kafka.connect.errors.ConnectException: Failed to我的码头工人写的是两行文字，第一行应该做我的第一个问题，第二个问题是安装第二个问题声称丢失的东西…… 当然，我在这里遗漏了一些东西，这应该是如何运作的，知道吗？我阻止了映像的关闭，并且它仍然没有公开带有kafka-connect

浏览 2提问于2019-08-23得票数 0

回答已采纳

3回答

如何将连接器安装到apache kafka* connect的docker镜像*

docker、apache-kafka、apache-kafka-connect

我正在使用在ubuntu .I上安装docker kafka connect我可以运行它，但是我不能在里面安装更多的连接器。我尝试过的东西 1-我尝试将连接器文件从我的机器复制到docker containers连接器文件夹，然后重新启动，但是接口给出了空数组。2-还在connect-distributed.properties中添加了插件路径。怎么做到这一点有什么想法?？

浏览 2提问于2020-07-30得票数 2

2回答

在Kafka* Sink连接器上设置唯一的客户端id*

apache-kafka

我试图使用JMX来监视在分布式工作人员上运行的一组连接器任务。唯一可用的JMX输出似乎是卡夫卡消费者MBeans。不幸的是，在被工人任务使用的Kafka消费者上设置一个可识别的client.id似乎是不可能的。文档建议在client.id上使用。在连接器配置上设置此设置没有任何影响。这样做是可行的，但这是一个跨工作人员的所有任务设置的单一客户端id，因此无法监视单个使用者，甚至不可能有一个特定的连接器。JMX输出不包括此使用者所属的groupd.id，因此不可能将使用者连接与在该工作器中运行的连接器关联

浏览 5提问于2017-04-11得票数 2

回答已采纳

点击加载更多

从Kafka到Vertica的数据导入(vkconfig Kafka连接器)