1回答
我们正在开发一个SAAS系统，在这个系统中，我们最初使用MySQL作为DB，但随着数据的增长，我们的数据列表变慢了，所以为了解决这个问题，我们已经使用了Mongo DB，我们已经在其中存储了准备好的JSON，我们需要显示一段时间(与MySQL的所有连接)，它工作得很好
我们用java编写了一个调度程序，它每2分钟运行一次，并将修改后的记录从MySQL更新到mongo。最初，它工作得很好，但随着时间的推移，数据和它的速率增加，它失败了很多次，所以我们决定寻找任何可以从MySQL</
浏览 14提问于2020-02-04得票数 0
1回答
过滤数据库中的行
、、
我想知道kafka平台是否适合下面的工作。例如，如果基于日期，将来可能会满足条件，那么是否有机会再次过滤被拒绝的邮件，以最终通过过滤器并进一步处理？在给Kafka提供数据之前先过滤数据行是不是更好？
谢谢。
浏览 9提问于2017-08-11得票数 0
回答已采纳
1回答
我正在尝试使用Flink 2.1.0从mysql日志表中读取流数据，但是，它只读取一次，然后它将停止该过程。我希望它继续读取，如果有传入的数据，并打印它。env.createInput( .setDrivername("com.mysql.jdbc.Driver")
.setDBUrl("jdbc:mysq
浏览 72提问于2017-02-22得票数 2
我在用debezium捕获mysql中的数据时遇到了问题，将数据捕获并使用kafka连接jdbc接收器将其消费到另一个mysql。因为debezium对kafka主题产生的模式和有效负载与kafka连接jdbc接收器所期望的模式不兼容。
当jdbc接收器想要使用数据并在另一个mysql中创建记录时，我就会异常。
浏览 2提问于2017-05-14得票数 1
回答已采纳
将数据从mysql传递到kafka produce的最佳方式是什么 我知道有很好的kafka连接器。然而，我想使用springboot框架。因为我需要转换数据并与其他http结果合并，然后我想产生数据到kafka。 那么有没有什么好的例子，github，博客wahtever~？
浏览 44提问于2020-07-21得票数 1
1回答
我已经启动了zookeeper，kafka服务器，kafka生产者和kafka消费者，我已经把从confluent下载的jdbc sql连接器jar放在路径中，我已经在connect-standalone\config\sink quickstart-MYSQL.properties没有任何错误，但是它有很多警告并且没有开始，但是我的数据没有反映在tables.what中我错过了，你能帮我吗我有下面的警告<init>(Reflections.java:140)
at org.a
浏览 21提问于2020-10-28得票数 0
2回答
我的公司每天产生大约600万条记录，我看到hadoop是处理大量数据的一个很好的解决方案。我发现了如何从mysql加载数据，但它正在导出完整的数据库，有没有办法保持我的mysql DB和Hadoop之间的数据同步？
浏览 2提问于2020-03-07得票数 1
1回答
我在MySQL上有5000万行事务数据，我想报告这些数据。我想把数据转储到HDFS中。现在，数据每天都在DB中出现，我正在为新的数据添加KAFKA。我想知道如何组合多个源数据并进行实时分析(延迟1-2分钟是可以的)，并保存这些结果，因为未来的数据需要先前的结果。
浏览 3提问于2022-08-27得票数 0
1回答
我正在寻找一个开源来将MySQL复制到Hadoop，我找到了两个选项，但是
那么，还有哪些其他工具可以满足这一要求呢？
浏览 3提问于2017-06-27得票数 0
对于CDC来说，在服务器上运行Kafka集群的最佳方法是什么？
如何将mysql db连接到运行在本地的kafka集群，并创建到另一个mysql db的接收器连接。
浏览 5提问于2022-01-19得票数 0
回答已采纳
2回答
我有卡夫卡作为服务器生态系统中的消息代理，我能以某种方式使MySQL成为消费者吗？
我需要直接用卡夫卡的数据库来写数据。
浏览 7提问于2015-07-07得票数 1
回答已采纳
我试图下沉的表数据一个数据库到另一个数据库使用kafka debezium ( Kafka流)在docker的帮助下。DB流工作正常。但是流式数据接收另一个MySQL DB进程时出错。{ "config": {
"connector.class": "io.confluent.conne
浏览 4提问于2019-11-21得票数 3
1回答
我想知道是否有可能同时使用Flink实现端到端的精确语义？来源: kafka进程: flink接收器:数据库(mysql或redis)谢谢。
浏览 2提问于2022-09-26得票数 -1
我最近开始学习apache kafka。在得到一些初步的想法后，我对kafka在应用程序架构中的位置感到困惑。
我的意思是，我们如何将它引入到以前只有三层的简单应用程序中。前端(安卓应用)，后端(Node.js)，MySQL。用户可以从应用程序创建帖子，应用程序将调用node.js上的端点，并将帖子存储在数据库中。在这个简单，直截了当的架构中，kafka还会添加什么额外的东西？它将如何集成？
浏览 2提问于2021-10-27得票数 0
1回答
我正在设计一个可伸缩的服务(Springboot)，使用它将数据索引为弹性搜索。我的应用程序使用具有相同模式的6个数据库(MySql)。每个数据库都适合特定的区域。我有一个微型服务，它连接到所有这些dbs，并以类似的方式将数据从特定表索引到弹性搜索服务器(v6.8.8)，具有6个elasticsearch索引，每个db一个索引。目前的问题：
当前的设计是不可扩展的-一个服务完成所有的工作(数据加载、映射、批量插入)。因为索引是通过夸脱作业完成的，所以缩放服务(运行多个实例)
浏览 2提问于2020-08-25得票数 1
在MySQL中，使用binlog，我们可以提取数据更改。但我只需要在那个时间/一天内所做的最新更改，并需要将这些数据输入到timeseries DB (计划使用druid)
在读取binlog时，有没有什么机制可以避免重复并保留最新的更改？我的意图是每天在timeseries数据库中备份整个MySQL数据库。它有助于通过参考当天存在的实际数据来调试我的应用程序的过去日期
浏览 4提问于2021-10-28得票数 0
而不是下面的mysql容器DB链接，我想链接在码头yml file中的AWS Mysql RDS。有可能吗？mysql_db: container_name: shishir_db MYSQL_ROOT_PASSWORD: "xxxxxxxx" #MYS
浏览 24提问于2017-01-27得票数 4
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
