有人使用Debezium kafka测试集群进行gradle的单元测试吗？
我有一个Vertx gradle项目，希望将debezium测试集群与我的verticl kafka客户端测试集成在一起。我的第一个问题是如果导入，它们似乎不起作用。如何转换maven风格的测
浏览 3提问于2018-01-27得票数 2
回答已采纳
3回答
我正在使用一个Java应用程序来启动消费者阅读Kafka主题。每次我需要启动使用者应用程序时，我都必须使用cmd中的命令启动和Kafka服务器。是否有可能用小型Java程序启动/阻止它们？谢谢。
浏览 1提问于2017-06-17得票数 3
回答已采纳
我有一个Kafka客户端，我需要测试它的功能。为此，我需要在本地创建一个Kafka集群，并连接到它。根据限制，我不能使用Docker镜像或K8s。我进行了搜索，发现在测试中使用了This class，但我不能更改代理端口。 我尝试使用Debezium KafkaCluster，但它间歇性地创建集群失败，因此导致间歇性测试失败。有没有办法在本地创建Kafka
浏览 18提问于2019-08-26得票数 0
回答已采纳
debezium kafka connect命令是：docker run -it --rm --name connect -p 8083:8083 -e GROUP_ID=1 -e CONFIG_STORAGE_TOPICOFFSET_STORAGE_TOPIC=my_connect_offsets -e STATUS_STORAGE_TOPIC=my_connect_statuses --link zookeeper:zookeeper --link kafka:kafka --link mysql:mysql
浏览 21提问于2019-06-05得票数 1
回答已采纳
1回答
我正在使用KafkaCluster在K8s上部署KafkaConnect。Strimzi算子集群图像:quay.io/strimzi/运算符:0.26.1
从这个图像‘quay.io/strimzi/kafka:0.26.1-Kafka3.0.0’构建一个新的Kafka
浏览 7提问于2021-12-22得票数 0
我正在寻找关于如何在开发人员&集成测试环境上设置和运行Apache的建议和指导。我必须求助于某种无节制
浏览 2提问于2017-03-07得票数 9
回答已采纳
我在Aiven (GCP)的云中运行了一个托管的kafka集群。我正在尝试使用Debezium SQL Server连接器从我们的本地数据库中流式传输CDC记录。有人知道如何从云中的kafka连接到本地数据库吗？是否可以通过某种VPN连接来实现，或者我是否需要通过google云配置VPC？感谢您的建议。
浏览 2提问于2019-11-11得票数 0
2回答
我正在使用kafka-connect + Debezium捕获我的MySQL集群中的数据更改。目前，我们使用Debezium的table.whitelist来摄取MySQL集群中的一小部分表。每当我向table.whitelist配置添加一个新表时，Debezium将创建一个只使用replication_factor = 2和partition=1的</e
浏览 4提问于2021-05-25得票数 0
我有个DockerfileRUN mkdir -p /opt/kafka/plugins/debezium# Download, unpack, and place the debezium-connector-postgres folder into the /opt/kafka/plugins&#
浏览 8提问于2021-10-23得票数 5
回答已采纳
我试图为Kafka创建一个自定义转换，我希望在MySQL和MongoDB之间运行一个复制。我更喜欢在MySQL数据库中的行更新/插入时，在MongoDB中记录与该行相关的(层次结构树结构)对应的复杂JSON文档(层次结构JSON文档)更新/插入。我能为Debezium实现自定义转换吗？
浏览 1提问于2022-03-07得票数 0
回答已采纳
我有一个由3个节点组成的kafka集群，我使用debezium(一个kafka-mysql连接器)。然后，听众突然陷入了一个无限的循环。
jstack和使用者日志(无限)这是个虫子吗？获得异常是可以接受的，但我不希望CPU
浏览 4提问于2017-12-02得票数 0
我不使用confluent，只使用apache kafka，已经添加了mongo插件，得到... / MongoSinkConnector -plugins响应，列出连接器{}...当我使用下面的帖子时，我得到了错误：{"config": {
"connector.class": "com.mongo
浏览 3提问于2021-04-23得票数 1
1回答
需要运行涉及两个数据库中的表的临时查询。目前，我们正以两种方式之一这样做：
我们已经使用了Google平台(用于使用Postgres服务器的项目)。我们熟悉Google BigQuery (BQ)。我们想要做的事情：--我们希望这两个数据库中的大多数表(按原样)都可以在一个位置上<e
浏览 5提问于2017-03-06得票数 1
回答已采纳
当使用AWS MSK连接器(Debezium Postgres连接器)时，我目前面临以下问题我不知道是什
浏览 11提问于2022-01-19得票数 0
1回答
我使用此页面上的说明在CentOS 7.9上安装了confluent平台。sudo yum install confluent-platform-oss-2.11 我使用的是带有apache版本2.6.1的AWS MSK集群。我开始使用/usr/bin/connect-distributed /etc/kafka/connect-distributed.properties连接。":
浏览 72提问于2021-09-16得票数 0
回答已采纳
1回答
连接器任务状态无法连接
、、、
连接器的任务状态因错误而失败：
org.apache.kafka.connect.errors.ConnectException: java.lang.NoClassDefFoundError我在分布式模式下运行kafka连接集群，并使用kafka(0.10.0.2.5)连接的ambari部署。我使用导出CLASSPATH=/path给出了debezium mysql连接器路径。使用以下命令将连接器配置加
浏览 0提问于2018-08-27得票数 0
回答已采纳
1回答
我正在使用Spring和Gradle依赖管理插件： id 'org.springframework.boot' version '2.5.6'
id 'io.spring.dependency-management我遇到了问题，因为我使用的一些库需要这些依赖项的不同版本，当插件覆盖这些依赖项时，我就会遇到兼容性问题。例如，我使用的是Debezum1.7.1的，但是Sp
浏览 5提问于2021-11-18得票数 0
回答已采纳
我需要实现CDC模式，但无法使其工作:我的debezium工作人员已经启动并运行，但我的连接器仍然失败，尽管我的努力。我在我的mongo集群上测试了一个简单的“手表”，它起作用了：while (!watchCursor.isExhausted()){ print(watchCursor.next());}
浏览 31提问于2022-03-15得票数 1
1回答
过滤数据库中的行
、、
我想知道kafka平台是否适合下面的工作。例如，如果基于日期，将来可能会满足条件，那么是否有机会再次过滤被拒绝的邮件，以最终通过过滤器并进一步处理？在给Kafka提供数据之前先过滤数据行是不是更好？
谢谢。
浏览 9提问于2017-08-11得票数 0
回答已采纳
我希望当在管理微服务API中执行crud操作时，rabbitMQ捕捉事件并将crud操作作为消息发布，然后从另一端使用服务或某个工具使用消息，然后使用它来更新另一个数据库？如何做到这一点？
浏览 1提问于2021-02-16得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
