1回答
我是apache环境的新手，它有一些让我很好奇的东西。我的kafka是通过ambari安装的。所以一切都可以通过ambari的GUI启动。当kafka通过ambari安装时，它包含kafka-connect。但是如果没有包含我需要的连接器怎么办？下面是一些包含的连接器。/etc/kafka-
浏览 13提问于2020-06-12得票数 0
回答已采纳
我们正在使用kubernetes上的kafka连接集群(头盔图表)。我无法这样做与雪花卡夫卡连接器。有推荐的工作场所吗？对于PoC，我在本地机器上运行了kafka connector，并在插件目录中添加了雪花-kafka-连接器jar文件，运行良好。
浏览 2提问于2019-10-10得票数 1
回答已采纳
我想在我们的HortonWorks Hadoop集群上安装最新版本的Kafka，该集群包含2个主节点、2个边缘节点和8个数据节点。该计划是在8个数据节点盒中的2个上安装Kafka。Kafka每天需要处理几百万个事件，可能是0.5 of 1.2 of大小的文件的几个批量拷贝。
问:为了避免kafka (或数据节点)的性能下降，我需要考虑对数据节点或kafka进行任何特殊配置吗？Kafka</e
浏览 1提问于2015-09-11得票数 1
1回答
/ambari-metrics-kafka-sink.jar\" ]; then\n export CLASSPATH=$CLASSPATH:/usr/lib/ambari-metrics-kafka-sink/ambari-metrics-kafka-sink.jar\n export CLASSPATH=$CLASSPATH:/usr/lib/ambari-metrics-
浏览 0提问于2018-06-03得票数 2
回答已采纳
我们有一个Kafka Connect项目，我们依赖于一个从gitlab获取数据的。这个图书馆依赖于泽西。Kafka也使用Jersey。当启动连接器时，我们收到一个类转换错误，这似乎是由于jersey具有某种全局发现模式导致的，当server和client在同一个类路径中时，该模式会发生冲突。/confluent-kafka-mqtt/jersey-server-2.27.jar
./kafka/jersey-server-2.27
浏览 0提问于2019-02-26得票数 0
我们公司的Kafka是融合的Kafka，它是Kerberized的。我能够通过Kafka API编写生产者和消费者，因为我们知道代理和密钥表文件。建议使用Kafka-Connect，但由于它是多租户集群，Ops团队可能无法提供直接访问，甚至无法运行插件安装命令。我们有自己的托管虚拟机，可以在其中部署应用程序实例。Ques -有没有可能通过在我们的VM上安装连接器插件而不是在Conf
浏览 5提问于2020-06-18得票数 0
1回答
通过Ambari 1.7执行安装，并希望获得有关Zookeeper安装的一些说明。设置包括(3) Zookeeper和(3) Kafka实例。Ambari UI要求指定Zookeeper主机和Zookeeper客户端/从属。我是否应该选择所有三个Zookeeper节点作为主节点，并在每个Kafka服务器上安装Zookeeper客户端？Zookeeper没有任何主节点，这里我对Ambari的主/从术语有点困惑。
浏览 3提问于2014-12-19得票数 4
如何仅打印json文件中的属性行{
"href" : "http://master02:8080/api/v1/clusters/HDP/configurations/ambari-metrics-kafka-sink.jar\" ]; then\n export CLASSPATH=$CLASSPATH:/usr/lib/am
浏览 0提问于2018-05-27得票数 10
回答已采纳
我正在尝试做一个POC，我们需要连接RabbitMQ和Kafka。我的问题是，是否有可能将RabbitMQ和卡夫卡联系起来？提前感谢
浏览 0提问于2018-06-05得票数 2
我正在尝试设置一个针对Apache 2.5的mongo连接器.我正在使用。ExchangeMessage"; string oid = 1;我为这个proto构建了一个jar文件，并放置在插件路径中我的Pom文件
<?xml version="1.0" encoding="UTF-8"?:293) at org.apache.kafka.connec
浏览 5提问于2020-07-10得票数 1
2回答
/'}/path_to_kafka/kafka_2.12-2.3.0/bin/connect-standalone.sh /path_to_kafka到目前为止我所做的：
更新的plugin.path ( /path_to_kafka/kafka_2.
浏览 6提问于2019-12-13得票数 1
6回答
更新前的json示例 "href" : "http://master02:8080/api/v1/clusters/HDP/configurations?/ambari-metrics-kafka-sink.jar\n export CLASSPATH=$CLASSPATH:/usr/lib/ambari-metrics-kafka-sink/li
浏览 0提问于2018-05-25得票数 0
回答已采纳
在Ksqldb服务器中嵌入Kafka连接器时，“卷”映射似乎不起作用ksqldb-server:当我试图使用连接器创建源时，我会看到下面的错误
{ "error_code“：500，"message”：“未能找到任何实现连接器且名称与io.debezium.connector.mysql.MySqlConnector匹配的<
浏览 13提问于2021-07-20得票数 2
我有一个集群设置并由Ambari管理，但是我想添加一个KafkaConnect停靠程序，并使用ZooKeeper，这已经是通过Ambari安装的。我只能找到对接者的形象，部署卡夫卡-连接到动物园和卡夫卡，但我不需要这些对接。
我应该看什么，找到一个码头形象，让我使用现有的卡夫卡和动物园管理员服务？
浏览 2提问于2018-05-28得票数 2
回答已采纳
我尝试使用"transform“为我的数据创建插件，以便kafka-connect并将其与不同的接收器连接器一起使用。当我安装插件时，kafka-connect看不到我的类。我使用kafka-connect maven插件来创建我的捆绑包zip。使用confluent-hub (从本地文件)安装已成功。所有文件都已解压缩，我的worker属性已更新plugin.paths
浏览 31提问于2019-08-29得票数 1
我需要别人的帮助。这是我的设置和其他信息。卡夫卡连接：。MySQL连接器: 0.8.1决赛。
我添加插件路径
当我试图连接到Kafka Connect时，它给了我一个错误。“未能找到实现连接器且名称与io.debezium.connector.mysql.MySqlConnecto
浏览 2提问于2018-08-14得票数 3
回答已采纳
4回答
如何在java中集成Kafka与Kafka生产者的连接，以便我能够实时读取CSV文件？我很难找到与此相关的任何消息来源。现在我正在使用scala运行一个简单的Kafka生产者类，但是不知道如何将它与Kafka连接一起使用。
浏览 0提问于2018-09-17得票数 3
回答已采纳
我正在使用Kafka Connect，并在我的连接器插件中启动了一个独立的线程，该插件正在侦听一个端口(比如"9090")。我想使用这个端口来允许应用程序(在kafka环境之外)与我的连接器插件进行通信。 我在docker-compose中运行Kafka Connect (和kafka环境)。问:如何在docker compose中公开端口，以便外部应用程序可以
浏览 33提问于2021-10-08得票数 0
回答已采纳
我正在使用Kafka Connect开发一个自定义源连接器，并且我正在尝试合并Avro支持。为此，我创建了一些.avsc文件来描述键和值模式，并将avro-maven-plugin添加到项目中，以自动创建可在代码中使用的相应java类。从生成的类中，我可以获得作为org.apache.avro.Schema类型的对象的模式。但是，源连接器的poll方法的返回类型是一组org.apache.kafka
浏览 18提问于2020-03-16得票数 0
回答已采纳
云服务器
ICP备案
对象存储
云点播
云直播
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号