3回答
我已经研究了Interactive queries和KSQL，但我似乎无法确定是否可以基于键查询特定的记录。假设我在一个主题中有一条记录，如下所示： { value: id: "1", }
} 可以在主题中搜索关键字另外，KSQL和交互式查询会占用整个主题来执行查询吗？
浏览 30提问于2020-01-02得票数 0
回答已采纳
1回答
我们已经使用了Mongo DB，我们已经在其中存储了准备好的JSON，我们需要显示一段时间(与MySQL的所有连接)，它工作得很好
我们用java编写了一个调度程序，它每2分钟运行一次，并将修改后的记录从MySQL最初，它工作得很好，但随着时间的推移，数据和它的速率增加，它失败了很多次，所以我们决定寻找任何可以从MySQL binlog读取的替代方案，我们可以在途中根据需要合并MySQL表，并将其存储在Mongo
浏览 14提问于2020-02-04得票数 0
我已经实现了一个Kafka Connect JDBC Source连接器，它连接到Oracle-Database，并将数据写入Kafka-Topic。目前，我已经在设置value.converter.schemas.enable=false的情况下设置了选项value.converter=org.apache.kafka.connect.json.JsonConverter该选项允许将JSON数据写入Kafka主题(顺便说一句，它工作得很好)，但不包括在将数据发送到Kafka代理之前修改
浏览 3提问于2021-02-18得票数 0
1回答
我有一个在本地运行的kafka集群和一个名为"my- topic“的主题，在这个主题中我正在推送数据。我还运行了ksql服务器，并且查询: SELECT*FROM "my-topic“给出了"my-topic I not exist”。我知道这个查询是不正确的，我想知道是否有其他方法来查询主题。
浏览 4提问于2018-06-05得票数 1
我将页面访问和搜索查询(某种点击流分析)记录到kafka。我打算定期批处理它们，比如每小时或每天，然后将聚合结果写入elasticsearch。如果不是写入kafka，而是写入文件系统，则可以很容易地配置记录器写入文件名中有时间戳的文件，自动按照小时/天间隔划分日志。但对于kafka，我搜索了足够多的时间，还没有找到任何每小时/每天创建一个新主题的例子。如果不是每小时/每天创建一个新主题，我只能想象通过logstash/flume将日志从<
浏览 8提问于2017-07-20得票数 1
回答已采纳
Memgraph是否充当Kafka的流源的接收器，然后一旦接收到消息，将它们组织到一个图形数据库中？如果是，这些消息是如何组织的。我不明白如何将消息从它们在特定主题中的格式转换为图形数据库可以理解的内容，比如Memgraph。
浏览 1提问于2022-09-28得票数 0
回答已采纳
现在，我正在尝试编写一个自定义的HiveStorageHandler实现，用于使用Hive Table查询和推送消息到Kafka。我看到了HiveStorageHandler的其他实现，它允许我们使用hive表在NoSQL数据库上查询和写入。有人
浏览 5提问于2018-11-25得票数 0
我需要写一个java应用程序，从Kinesis流读取和存储数据到Kafka主题。我不能使用连接器，我必须使用Kafka Streams，因为其中涉及到很多逻辑。Kafka Stream是否可以直接从Kinesis流读取，或者我必须先将数据存储到Kafka topic才能被Kafka Stream读取？我读了很多关于Kafka Streams的文章，除了Kafka主题之外，我从来没有
浏览 18提问于2019-07-29得票数 1
使用Telegraf插件，有一种方法可以从InfluxDb读取数据并将其发布到Kafka主题。 但有没有一种方法可以按需读取数据并将其放在Kafka主题上？就像基于查询的需求。我可以通过REST API (curl GET)执行基于查询的读取。 有HTTP侦听器插件，但这些插件仅用于POST方法。GET方法没有，我可以从InfluxDb查询数据的子集，并将它们放在Kafka主题上。在这种情况下，<e
浏览 28提问于2019-06-14得票数 1
1回答
我有一些做REST微服务架构的经验，但现在我想开始在我的事件驱动架构中使用kafka作为消息提供者。 我有一个问题，就是理解微服务之间的通信是如何工作的。可以创建用户，然后用户可以向另一个用户发送消息，我计划用主题来做这些事情，然后将它们存储在MongoDB中。 如何在事件驱动的体系结构中检索此消息？编辑:这个示例非常简单，只是为了教育目的和使用Apache-Kafka进行练习。
浏览 7提问于2019-12-29得票数 0
我正在尝试编写一个kafka streams应用程序，它执行一些转换并将数据放入物化的键值存储中，然后从存储区读取它(我需要查询压缩的数据)。我面临的问题是，在启动KafkaStreams (运行状态上的侦听器)之后，我看不到有办法等待从输入主题到存储区处理数据。如果我在KafkaStreams状态运行后直接开始查询存储(并且在单独的线程中这样做)，我将读取空存储，在实际读取任何数据之前应用程序退出。总括而言：
，在查询输入主题之前，
浏览 1提问于2021-04-06得票数 0
2回答
实时事件处理
、、
我把flume和kafka搞混了。我不想将事件存储在某个地方，因为我已经用最新的值更新了数据库。我真的需要spark，(flume/kafka) + spark，来满足处理端吗？
我们可以在没有水槽的情况下使用flume进行任何类型的处理吗？
浏览 13提问于2017-06-29得票数 1
哪个camel kafka连接器组件可以从远程服务器读取文件并将记录发布到kafka主题？我尝试了camel-sftp-kafka-connector，但它将整个文件移到了主题。有没有连接器可以直接读取远程服务器上的文件？
浏览 27提问于2020-12-31得票数 0
我正在使用Java1.6运行我的应用程序，并计划将一些方面与Kafka集成。
我正在探索是否应该使用Kafka Consumer (使用poll())或使用KafkaStreams API。
浏览 3提问于2018-12-20得票数 0
相反，Kafka提供了它的API接口，它对于处理配置以及任务、工作人员等都非常有用。
如何将信息从SinkConnector发送到卡夫卡主题</em
浏览 11提问于2021-04-26得票数 0
我希望使用Source连接器将SQL中的数据导入kafka主题，因此，为了配置源代码属性文件，我将从SQL表中获取整个数据到Kafka主题中，但我不希望从SQL表中获得全部数据，我希望从表中获得特定的列，表可能是多个，主要是我不知道如何配置每个查询的多个主题。
浏览 1提问于2019-10-03得票数 0
回答已采纳
我正在使用星火流从卡夫卡主题列表中阅读。我正在遵循这个的官方API。KafkaUtils.createDirectStream[String, String, StringDecoder, StringDecoder](我想知道执行者将如何从主题列表中读取信息他们会阅读一个主题，然后当他们完成消息传递给其他主题吗？
最重要的是，在调用此方法之后，我如何检查RDD中的消息<em
浏览 3提问于2017-04-05得票数 3
我们正试图从传统的架构J2EE应用服务器/关系数据库迁移到Kafka。我有一个用例，我不确定该如何处理……或者在调度触发点创建KafkaStream以从Kafka流中收集此信息？
你认为
浏览 4提问于2018-09-11得票数 0
)，它在SpringBoot主类中使用在我们的用例中，命令端微服务需要从kafka主题中挑选消息，而不是将其公开为Rest api。它会将事件存储在事件存储中，然后将其移动到另一个kafka主题，供查询端微服务消费。
由于KafkaAutoCOnfiguration被禁用，我不能使用spring-kafka配置来编写消费者。如何在Axon中使用
浏览 18提问于2019-07-12得票数 0
我有一个用例"XML文件==> Kafka主题==>构建REST来查询“来自卡夫卡主题的数据。我熟悉把数据转换成Avro格式，并写到kafka主题。我还尝试用kafka-控制台生成器发布，但是对于每一行xml文件，键都被填充为
浏览 1提问于2018-05-16得票数 0
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号