我有两个配置文件，用来创建从rsyslog到Kafka主题的流，配置如下: worker.propertiesekey.converter=org.apache.kafka.connect.json.JsonConverterconfluent.topic.bootst
浏览 31提问于2020-03-07得票数 0
我试图使用omkafka模块在远程机器上发布从rsyslog到kafka的消息。" topic="rsyslog_kafka"
2
浏览 6提问于2017-02-17得票数 1
回答已采纳
我需要将这些日志数据发送到kafka，并使用python (通过应用regex)从这些日志中提取一些错误信息，并使用我提取的数据准备一个实时仪表板。如何获取持续生成到kafka的日志数据？
浏览 14提问于2020-03-02得票数 0
我在第一服务器使用apache kafka，在第二服务器使用apache动物园管理员。我希望在其他server.Is中有卡夫卡连接服务，可以使用独立的服务。我需要阿帕奇卡夫卡连接或融合卡夫卡连接。
浏览 7提问于2022-06-29得票数 0
我正在阅读关于Kafka和Kafka Connect的文章。文档在Kafka Connect文档中以一种通用的方式提到了“Kafka源”和“Kafka汇”。我不确定这两个术语是否特定于Kafka Connect，或者它们只是指生产者和消费者。
浏览 13提问于2021-06-24得票数 0
回答已采纳
我正在尝试部署一个独立的连接作业来从mssql服务器流传输，但是我遇到了一个问题(Kafka-Connect是我的Ambari部署的一部分，而不是docker)。这是我正在使用的属性文件：connector.class=io.confluent.connect.jdbc.JdbcSourceConnector/servernamequery=SELECT * FROM IB_WEBLOG_DUMMY_small
value
浏览 1提问于2018-05-29得票数 1
1回答
过滤数据库中的行
、、
我想知道kafka平台是否适合下面的工作。例如，如果基于日期，将来可能会满足条件，那么是否有机会再次过滤被拒绝的邮件，以最终通过过滤器并进一步处理？在给Kafka提供数据之前先过滤数据行是不是更好？
谢谢。
浏览 9提问于2017-08-11得票数 0
回答已采纳
我尝试通过PySpark在HBase中创建Kafka数据摄取。目前，我尝试使用HappyBase将数据从卡夫卡插入到Hbase中，但是速度非常慢。
浏览 18提问于2019-03-25得票数 0
我正在使用docker容器来构建zookeeper，kafka和connect。- zookeeper
image: debezium/connect portsto error [org.apache.kafka.connect.cli.ConnectDistributed]
kafka-<em
浏览 139提问于2020-10-18得票数 1
我正在使用卡夫卡连接到redis。curl -s -X POST -H 'Content-Type: application/json' --data @connector.json"config" : { "connector.class" : &
浏览 0提问于2019-09-15得票数 1
回答已采纳
我已经开始实施卡夫卡制作人和发布信息的主题，从那里到卡夫卡消费者收到的json。
现在，我需要发送json有效负载从卡夫卡消费者到谷歌酒吧/潜艇。我很困惑，我应该为此需要卡夫卡的消费者吗。或者只是从卡夫卡生产者到谷歌酒吧子，我可以发送通过使用卡夫卡connector.jar和配置在主题中的属性。对于此实现，任何帮助都是非常感谢的。
浏览 3提问于2019-03-21得票数 1
回答已采纳
我是第一次使用Kafka Connect。
场景:我们希望在Kafka中导出存储在多个主题(好的数字> 400)中的数据，并将这些数据转储到Elastic Search Indexes中。我们公司的Kafka是融合的Kafka，它是Kerberized的。我能够通过Kafka API编写生产者和消费者，因为我们知道代理和密钥表文件。Ques -有没有可能通过在我们的VM上安装连接器插件而不是在Confluent
浏览 5提问于2020-06-18得票数 0
我使用的是kafka_2.11.-0.9.0.1。首先，我用以下命令启动了zookeeper & kafka (如所解释的)：然后：bin/kafka-server-start.sh config/server.properties[itay@localhostKafka和zookeeper
浏览 0提问于2016-04-27得票数 1
如何在apache Kafka中集成cassandra作为数据生产者？ 在kafka配置上有什么特别的配置吗？
浏览 41提问于2019-04-07得票数 0
要在本地mac中运行cps3连接以使用kafka主题，我做了如下操作ML-C02Z605SLVDQ:kafka_2.12e192270$ cd kafka_2.12-2.5.0
ML-C02Z605SLVDQ:kafka_2.12-2.5.0 e192270$ bin/
浏览 3提问于2020-05-23得票数 1
我正在尝试订阅一个带有kafka的mqtt主题，为此我使用了以下连接器：。我按照上面描述的步骤做了一些修改，一切似乎都很顺利。但是，当我启动连接器时，我会得到一个 (屏幕截图)，连接器就会停止。这是我的源文件：mqtt.broker : tcp://localhost:1883mqtt.topic : te
浏览 0提问于2020-05-10得票数 2
回答已采纳
2回答
我需要帮助来理解这个问题:所以我使用ansible，基本上我有一个包含3vvariable的vault文件，在我的角色中，我有这个部分，它应该将vault的每个变量复制到3个不同的文件中： shell: echo {{ client_kafka_rsyslog_cer }} >> {{ dest_cert_file }}
shell: echo {{ client_kafka_rsyslog_key }} >>
浏览 18提问于2021-05-17得票数 0
回答已采纳
我正在尝试为Kafka更改数据捕获设置一个Docker文件环境，我遇到了以下错误：
docker run -it --name kafka -p 9092:9092 --link zookeeper:zookeeper debezi
浏览 4提问于2021-02-07得票数 4
回答已采纳
我正在尝试运行 Docker，编写多容器应用程序，并使用bin/kafka_topics.sh创建主题，如中所述。: ports: volumes: environment:
- KAFKA_CFG_ZOOKEEPER_CONNE
浏览 19提问于2022-01-03得票数 2
1回答
我已经启动了zookeeper，kafka服务器，kafka生产者和kafka消费者，我已经把从confluent下载的jdbc sql连接器jar放在路径中，我已经在connect-standalone<init>(Reflections.java:140)
at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader<init>(DelegatingCl
浏览 21提问于2020-10-28得票数 0
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号