有没有开源工具来监控融合的Kafka？大多数可用的开源工具都是特定于Apache Kafka的，但不是针对Confluent Kafka的。
我们希望至少监控连接器、流和集群的运行状况
浏览 3提问于2017-07-04得票数 0
1回答
问题是，当我第一次在机器上运行对接-撰写，那么所有的容器运行良好，但当我停止/移除容器并重新运行码头-撰写，然后图像容器"cnfldemos/cp-server-connect-datagen:0.2.0main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka version: 5.4.0-ccs
[main] INFO org.apache.kafka.common.utils.AppIn
浏览 1提问于2020-04-03得票数 2
回答已采纳
我会将kafka-rest-proxy融合解决方案与apache kafka 2.0.0集成在一起
有人能解释一下我的集群如何只安装kafka rest代理吗?有3个节点kafka和3个znode？
浏览 20提问于2019-03-29得票数 0
Apache Kafka集群中可以使用Confluent Kafka JDBC连接吗？我正在尝试使用Confluent JDBC connect在apache kafka集群上安装和配置它，用于连接到mssql数据库的源属性。
浏览 6提问于2019-10-08得票数 0
{"foo":"bar"}confluentconfluentlogs
localhost:8082**)**上的消费者(异常(关于卡夫卡)rest-proxy | [2018-12-31 03:09:27,232] INFO 172.25.0.1)
<e
浏览 0提问于2018-12-31得票数 1
回答已采纳
我有两个越南船民-我试图将connect容器链接到汇合集群，以向集群添加另一个连接，但失败了。 KAFKA_CONFLUENT_BAL
浏览 12提问于2022-03-06得票数 1
我正在使用docker-compose.yml文件作为我的Kafka设置，这是正常工作的。当我试图连接到oracle数据库时，我还需要安装ojdbc驱动程序。因此，我修改了我的撰写文件以直接下载ojdbc jar，但是在添加了这段代码之后，我无法启动Kafka-connect。: 1 CONNECT_VALUE_CONVE
浏览 1提问于2020-06-06得票数 0
2回答
我在寻找SMT的解决方案，我找到了这个，这是我的拼图文件，version: '2' zookeeper: - 8082:8082 container_name: rest-proxy
浏览 12提问于2021-06-26得票数 1
回答已采纳
1回答
我有一个火花结构流应用程序，它必须从12个卡夫卡主题(不同的模式，Avro格式)读取一次，反序列化数据并存储在HDFS中。SchemaConverters.toSqlType(schema).dataType.asInstanceOf[StructType]
.readStream
.format("kafka
浏览 0提问于2020-04-13得票数 2
(cp-all-in-one)的docker镜像 那么，为了避免kafka不可用，我如何在不影响现有集群设置的情况下更改docker-compose来配置多kafka代理？: http://schema-registry:8081 CONNECT_INTERNAL_VALUE_CONVER
浏览 9提问于2020-12-30得票数 0
在生产环境中，我将有两个站点，每个站点都有一个Kafka集群和Postgres实例。我想模拟一下，并在我的Dev机器上创建两个Kafka“集群”，每个集群都有一个代理和两个Postgres实例。每个Kafka“集群”将运行一个源连接器，将数据复制到另一个站点。下面的docker-compose有两个Postgres实例，但只有一个Kafka +源连接器。使用另一个源连接器创建第二个Kafka集群需要复制/更
浏览 40提问于2020-10-22得票数 0
我正在尝试在HDP上为Kafka Streams安装Confluent，这可能是不可能的，你们能建议我怎么做吗
浏览 2提问于2016-06-20得票数 0
我不使用confluent，只使用apache kafka，已经添加了mongo插件，得到... / MongoSinkConnector -plugins响应，列出连接器{
"class, name='org.apache.kafka.connect.file.FileStreamSinkConnector', version='2.7.0', encodedVersion=2.7.0, name='org.ap
浏览 3提问于2021-04-23得票数 1
1回答
，另一个是用Go编写的机器代理，它使用来自SegementIO.Normally卡夫卡的卡夫卡- Go客户端在端口9092下运行，我的两个应用程序都运行为expected.The，我现在遇到的问题是，在安装了机器代理的环境中存在一定的端口限制有一种方法可以使用端口转发，所以在我的Go客户机中使用端口转发，而不是拥有一个URL :9092，我有80，这击中了Nginx，这反过来应该将它转发到端口9092，我尝试了一种方法，但它没有成功。KAFKA_CONFLUENT_LI
浏览 4提问于2021-08-20得票数 0
我一直在尝试与kafka-avro-console-consumer从Confluent连接到我们的遗留Kafka集群，该集群是在没有Confluent Schema Registry的情况下部署的。我使用如下属性显式地提供了模式： --topic test \org.a
浏览 2提问于2018-09-19得票数 6
回答已采纳
我能够在没有任何问题的情况下提升所有所需服务的堆栈。但是，当我导航到kafka-connect文件夹以查找ojdbc时，我看不到那里。理想情况下，它应该下载并放在kafka-connect中。: 1 CONNECT_VALUE_CONVERTER: "org.apache.kafka.conne
浏览 2提问于2020-06-06得票数 0
回答已采纳
1回答
我有一个卡夫卡集群，我正在管理与码头。AnalysisException: Failed toGuide"
有人知道如何从另一个外部容器访问在码头容器中运行的Kafka主题吗？KAFKA_CONFLUENT</e
浏览 4提问于2021-03-20得票数 3
回答已采纳
我正在尝试部署一个独立的连接作业来从mssql服务器流传输，但是我遇到了一个问题(Kafka-Connect是我的Ambari部署的一部分，而不是docker)。这是我正在使用的属性文件：connector.class=io.confluent.connect.jdbc.JdbcSourceConnectorsqlserver://servernamequery=SELECT * FROM IB_WEBLOG_DUMMY_small
value.c
浏览 1提问于2018-05-29得票数 1
我们有一个"Kerberized集群“运行代理版本Apache 0.15。这个集群由一个不同的团队管理，我们对此没有任何控制。根据这一点，由于Brokers版本为0.11，我们不得不坚持使用架构注册表和Kafka Connect吊舱的合流平台3.3.3图像。问题如下：
1)我们可以使用最新的合流图像(例如:
浏览 0提问于2019-06-10得票数 0
回答已采纳
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
