1回答
我已经启动了zookeeper，kafka服务器，kafka生产者和kafka消费者，我已经把从confluent下载的jdbc sql连接器jar放在路径中，我已经在connect-standalone\config\sink quickstart-MYSQL.properties没有任何错误，但是它有很多警告并且没有开始，但是我的数据没有反映在tables.what中我错过了，你能帮我吗我有下面的警告<init>(Reflections.java:140)
at org.apache.<em
浏览 21提问于2020-10-28得票数 0
在bash中，我可以写：并接收打电话者上下文的：函数这对于调试非常有用。给予：然后，我可以编写yelp来查看到达了哪些代码行。我可以将caller 0在bash中实现为：如何获得与caller 0在zsh中相同的输出
浏览 0提问于2018-07-03得票数 12
回答已采纳
我使用Debezium MySql连接器将数据库更改事件从MySql数据库流式传输到Kafka。我需要将特定的转换应用于某些指定表(而不是其他表)中的记录。有没有一种只使用Kafka Connect单消息转换(没有Kafka Streams或KSQL)的方法？我甚至不介意写一个自定义的SMT。但我找不到如何为消息指定要应用SMT的表/主题。谢谢。
浏览 10提问于2019-04-11得票数 1
我试着把一些连接器(jdbc连接器，mysql连接器)放到kafka- connector容器中，但是它没有工作。
如果我输入插件路径，我应该写在哪里？卡夫卡-连接？)
浏览 26提问于2022-05-20得票数 0
1回答
我正在从以下位置创建数据摄取：我能够将数据从MySQL流水线传输到Kibana，但我在处理MySQL表中的"Date“列时遇到了问题。Date列在Kafka主题和ES文档中显示为纪元日期。
我们可以在Elasticsearch/Logstash部分中将其转换为日期格式"yyyy-mm-dd“吗？
浏览 0提问于2017-08-15得票数 0
我正在设计一个MySQL -> Debezium -> Kafka -> Flink -> Kafka -> Kafka Connect JDBC -> MySQL。下面是我在Flink上写的示例消息(我也尝试过使用Kafka控制台生产者) { "type": "struct",
浏览 70提问于2019-02-27得票数 0
回答已采纳
我在hive表中显示了数据。在将数据加载到druid之前，我想应用一系列的转换。所以有一些方法，但我不太确定。1.转换后保存该表，然后通过hadoop摄取方式进行批量加载。但我希望避免在服务器上进行额外的写入。2.使用宁静。但它是针对Spark Streaming的，仅适用于Scala和Java，而不适用于Python。我说的对吗？
浏览 40提问于2019-11-04得票数 2
我已经创建了一个卡夫卡生产者，从MySQL数据库读取网站点击数据流，它工作得很好。我发现我也可以使用kafka connect或debezium将kafka连接到MySQL数据源。我的目标是使用kafka摄取数据，并将其发送到Storm进行消费和分析。看起来这两种方法都可以实现我的目标，但使用kafka producer可能需要我构建一个kafka服务来不断读取数据源。
浏览 1提问于2018-07-10得票数 0
3回答
我们有一个来自旧式系统的写密集型表(在AWS上)，我们希望将每个写事件(插入或更新)从该表流到动态表。其想法是创建一个管道来预热缓存和更新搜索引擎。
浏览 5提问于2016-08-17得票数 12
回答已采纳
我想写从spark到kafka的话题。我不想使用它的scala api，因为我不想有混合代码(java+ scala)。可以使用kafka自己的API来实现吗？有什么缺点吗？
谢谢!
浏览 0提问于2016-06-09得票数 0
1回答
我想知道是否有可能同时使用Flink实现端到端的精确语义？来源: kafka进程: flink接收器:数据库(mysql或redis)谢谢。
浏览 2提问于2022-09-26得票数 -1
我想同步HBASE数据库作为由MySQL产生的更新触发器与Kafka Streams或Kafka连接的帮助。关于它的可能性和它是如何实现的，有什么建议吗？
浏览 22提问于2019-11-27得票数 0
对于CDC来说，在服务器上运行Kafka集群的最佳方法是什么？
如何将mysql db连接到运行在本地的kafka集群，并创建到另一个mysql db的接收器连接。需要知道如何实现它
浏览 5提问于2022-01-19得票数 0
回答已采纳
我想使用kafka获取已删除的记录，并将其插入Sink数据库中的表中(并将删除标志列更新为Sink数据库中的true )。我将使用带参数源mysql的debezium来接收mysql。
浏览 2提问于2021-02-24得票数 0
1回答
在卡夫卡中失去一些事件
、、、、
我的应用程序中有3种不同的Spring流。每天有数十万条记录，然而，每天大约有3到4条记录消失。我看到它们在日志中出现，但是，不要完成所有的连接。 @StreamListener @Input(StreamBindings.BUSINESS_CONDITION_ORDER_CHARGED_CHARGE_IN) @Input(StreamBindings.BUSINESS_CONDITION_ORDER_CHARGED
浏览 0提问于2021-09-02得票数 0
2回答
我发现了如何从mysql加载数据，但它正在导出完整的数据库，有没有办法保持我的mysql DB和Hadoop之间的数据同步？
浏览 2提问于2020-03-07得票数 1
我使用logstash将数据从mysql读取到kafka。为了节省磁盘空间，我将输出配置写为： codec => plain { }正如我所期望的
浏览 0提问于2017-10-10得票数 0
我想写一个新的应用程序与Spring boot，使用数据库作为MySQL +芒果和消息Spring Kafka。我尝试了许多POC来同步Kafka和DB之间的事务，但在某些情况下我失败了，我还搜索了许多存储库，博客，以获得至少一个示例。我现在还没有得到任何例子。
浏览 29提问于2019-05-16得票数 5
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
