3回答
Apache的WSO2ESB JMS代理消费
wso2、wso2-esb
我已经设法让ESB生成一个Kafka主题，但我不知道如何从这个队列中使用JMS代理。
浏览 0提问于2014-11-26得票数 2
回答已采纳
2回答
卡夫卡MySQL作为消费者
mysql、apache-kafka
我有卡夫卡作为服务器生态系统中的消息代理，我能以某种方式使MySQL成为消费者吗？
我需要直接用卡夫卡的数据库来写数据。
浏览 7提问于2015-07-07得票数 1
回答已采纳
1回答
如何在使用REST创建Kafka连接器时定义模式
apache-kafka、apache-kafka-connect
我已经将Kafka连接工作人员配置为在集群中运行，并能够获取DB数据。此外，我还以JSON格式以Kafka主题存储DB数据。这里我使用JSON转换器来序列化数据是否有任何方法在连接器创建期间发送架构。
浏览 2提问于2019-10-01得票数 0
回答已采纳
1回答
从mysql到mongo数据库的数据调度问题
mysql、mongodb、apache-kafka、etl、data-synchronization
我们正在开发一个SAAS系统，在这个系统中，我们最初使用MySQL作为DB，但随着数据的增长，我们的数据列表变慢了，所以为了解决这个问题，我们已经使用了Mongo DB，我们已经在其中存储了准备好的JSON，我们需要显示一段时间(与MySQL的所有连接)，它工作得很好
我们用java编写了一个调度程序，它每2分钟运行一次，并将修改后的记录从MySQL更新到mongo。最初，它工作得很好，但随着时间的推移，数据和它的速率增加，它失败了很多次，所以我们决定寻找任何可以从MySQL</
浏览 14提问于2020-02-04得票数 0
2回答
如何定期向hadoop提供数据
mysql、hadoop
我的公司每天产生大约600万条记录，我看到hadoop是处理大量数据的一个很好的解决方案。我发现了如何从mysql加载数据，但它正在导出完整的数据库，有没有办法保持我的mysql DB和Hadoop之间的数据同步？
浏览 2提问于2020-03-07得票数 1
1回答
KSQL流未从主题中获取输出
confluent-platform、ksqldb
我已经将kafka连接到mysql。该主题包含AVRO格式的数据。现在，我想将该数据转换为CSV格式。为此，我使用了KSQL流。当我像这样创建流时(如果我用相同的主题运行消费者命令，它会显示数据)，然后给select * from source_avro，它不会显示任何数据
浏览 1提问于2019-04-23得票数 1
1回答
Apache :如何正确配置消息缓冲
apache-kafka
我运行一个系统，包括一个InfluxDB、一个卡夫卡代理和产生时间序列数据的数据源(传感器)。代理的目的是保护数据库不受入站事件过载的影响，并作为接收数据的不确定格式平台。数据通过阿帕奇骆驼路线从卡夫卡传输到InfluxDB。我想使用Kafka，一种中间消息缓冲区，以防骆驼路径崩溃或不可用--这是系统中最常见的错误。到目前为止，我还没有实现对Kafka的配置，使入站消息仍然可供以后使用。如何正确配置它？
浏览 1提问于2020-11-20得票数 0
回答已采纳
1回答
在Kafka streams作业中执行同步数据库查询或restful调用是一种好的做法吗？
apache-kafka、bigdata、streaming、apache-kafka-streams
我使用Kafka streams来处理实时数据，在Kafka streams任务中，我需要访问MySQL来查询数据，并且需要调用另一个restful服务。
所有的操作都是同步的。
浏览 3提问于2018-08-21得票数 1
1回答
如何使用Kafka Streams/Connect保持MySQL数据库与HBASE同步？
mysql、hbase、apache-kafka-connect
我想同步HBASE数据库作为由MySQL产生的更新触发器与Kafka Streams或Kafka连接的帮助。关于它的可能性和它是如何实现的，有什么建议吗？
浏览 22提问于2019-11-27得票数 0
2回答
如何根据配置跳过Cucumber中的其余场景
java、cucumber、bdd、cucumber-jvm、cucumber-java
我们有一个数据迁移系统，可以将数据从不同的源迁移到目标。例如，从Oracle到Db2，从Postgres到Kafka，从MySQL到Hadoop等等。following source to target mapping | Oracle | Db2 | | MySql | Hadoop |
When I try to run migration basi
浏览 7提问于2021-08-22得票数 0
1回答
有没有可能把debezium产生的卡夫卡信息沉到雪花上
apache-kafka、snowflake-cloud-data-platform、debezium
我使用来测试debezium mysql cdc特性，消息通常可以流。在kafka中，创建mysql连接的请求主体如下： "name": "inventory-connector", }然后我需要把卡夫卡的信息转化成雪花，我的团队使用的数据仓库。":"true"
浏览 2提问于2021-06-24得票数 0
回答已采纳
1回答
"OffsetOutOfRangeException:偏移超出范围而没有配置分区重置策略“的含义是什么？
apache-spark、apache-kafka、apache-spark-sql、spark-structured-streaming
，经过几次转换后，最终数据存储在Cassandra表中。-一些数据可能丢失。偏移量62687超出了范围，并将跳过[62687,62727)中的记录(GroupId: GroupId TopicPartition:入站-19)。有些数据可能已经丢失，因为这些数据在Kafka中不再可用；要么数据被Kafka老化，要么在处理该专题的所有数据之前就删除了该主题。，_入站-19)
这是什么告诉我的？
浏览 1提问于2019-12-11得票数 1
1回答
WSO2 ESB Kafka消费者项目
apache-kafka、wso2esb
我创建了两个WSO2企业服务总线集成项目，一个用于Kafka消息生产者，另一个用于Kafka消息消费者。我成功地在调用REST API时创建了Kafka消息生成器，并将消息放在主题上。当我创建Kafka消息消费者时，没有像Kafka这样的传输供代理监听，并且根据文档，我们需要使用IP端点来实现同样的传输。我的要求是，当消息在主题上可用时，应该在使用者处自动从主题(类似于JMS使用者)接收Kafka消息。那么我如何使用带有Kafka细节的IP端点来实现这一点呢？ 有什么建
浏览 30提问于2021-11-18得票数 0
回答已采纳
1回答
java包中接收器连接器的实现
java、apache-kafka、apache-kafka-connect
我已经启动了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
1回答
Kafka实时流vs Micro服务
apache-kafka、kafka-consumer-api、kafka-producer-api
选择Kafka实时流是否有gbps的最低报文速率要求？
我们可以在Kafka中处理非常低的消息率吗？
浏览 0提问于2019-03-31得票数 1
1回答
使用将模式和数据更改从MySQL流到MySQL
apache-kafka、apache-kafka-connect
如何使用Kafka连接源连接器将模式和数据更改以及某些类型的转换流到另一个MySQL实例。如果我使用Kafka的Python (Confluent_kafka)在加载到目标DB之前使用和转换消息，是否也有一种传播模式更改的方法。
浏览 3提问于2022-06-01得票数 0
1回答
过滤数据库中的行
mysql、apache-kafka、apache-kafka-streams
我想知道kafka平台是否适合下面的工作。例如，如果基于日期，将来可能会满足条件，那么是否有机会再次过滤被拒绝的邮件，以最终通过过滤器并进一步处理？在给Kafka提供数据之前先过滤数据行是不是更好？
谢谢。
浏览 9提问于2017-08-11得票数 0
回答已采纳
1回答
配置Debezium连接到给定的mySQL实例
apache-kafka、apache-kafka-connect、debezium
比方说，我将获得多个MySQL实例，并且必须流式传输实时数据。为此，我使用下面列出的命令在Docker Container上启动了一些服务，这些命令将我连接到示例库存数据库，并且当我在MySQL命令行客户端中执行任何DML命令时，都能够监控这些数据的变化。但是，连接到实际的MySQL数据库并在观察器窗口中传输相同的内容所需的更改或等效命令是什么呢？-p 9092:9092 --link zookeeper:zookeeper debezium/kafk
浏览 2提问于2020-05-27得票数 1
1回答
Flink 1.2.0 jdbc从Mysql读取流数据
java、mysql、jdbc、apache-flink、flink-streaming
我正在尝试使用Flink 2.1.0从mysql日志表中读取流数据，但是，它只读取一次，然后它将停止该过程。我希望它继续读取，如果有传入的数据，并打印它。env.createInput( .setDrivername("com.mysql.jdbc.Driver")
.setDBUrl("jdbc:mysq
浏览 72提问于2017-02-22得票数 2
云服务器
ICP备案
对象存储
实时音视频
云点播
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号