1回答
在Kafka中的交易是什么意思？performed (using one or more SQL statements) on a database as a single logical unit of work 那么，这是否意味着可以向Kafka
浏览 18提问于2020-03-27得票数 2
回答已采纳
我正在使用Spark2.2.0和Kafka0.10火花流库从满是kafka应用程序的主题中读取。Kafka Broker版本为0.11，Kafka-streams版本为0.11.0.2。当我在Kafka应用程序中设置EXACTLY_ONCE保证时：
p.put(StreamsConfig.PROCESSING_GUARANTEE_CONFIG, StreamsConfig.EXACTLY_ONCE当我运行kafka.tools.GetOffsetShell时，它给出了
浏览 0提问于2018-01-19得票数 2
回答已采纳
我正在以kafka模式向正在运行的网络中添加一个新的订单者。问题是，如果kafka集群是新建的或者已经删除了一些事务的早期数据日志，那么新添加的排序者似乎无法获取排序者加入之前生成的块的数据，这意味着新的排序者不能为网络提供服务，并可能触发其他排序者报告协议者错误，从而停止网络中的整个排序者服务
我测试了在没有添加排序操作的情况下运行新构建的kafka集群。我搞不懂为什么新添加的排序者不能从现有的排序者中提取数据。如果OSN是这样工作的，当我们移动kafka</
浏览 0提问于2019-05-05得票数 0
在Kafka -2.x中消费消息时，我检查了信息但不能确定ConsumeKafkaRecord_2_0是否支持事务?如果不支持，这意味着一旦消息被Nifi消费，Kafka中的offest就已经改变了，即使事务没有提交，如何改进？
浏览 0提问于2020-05-23得票数 1
我们有一个应用程序，它使用来自Kafka主题(3个分区)的消息，并丰富数据并将记录保存在DB ( Spring JPA)中，然后将消息发布到另一个kafka主题(在同一代理上)，所有这些都是通过使用Camel我们希望为kafka消费者-生产者组合实现“恰好一次”语义。end();
但是当存在异常处理场景时，我们无法让kafka生产者提交消息。我遗漏了什么，正确的方法是<em
浏览 24提问于2020-05-06得票数 0
我对kafka很陌生，我使用Kafka生产者Java。面对这个问题，卡夫卡，Kafka: Invalid transition attempted from state COMMITTING_TRANSACTION to state ABORTING_TRANSACTION人们已经写到，只有在没有交易的情况下，才应该调用producer.abortTransaction() .知道如何检查飞行中是否有交易吗？以及如何清除/阻止它们？= null){
logger.info(&q
浏览 2提问于2020-09-10得票数 2
回答已采纳
我正在运行Stream应用程序，在该应用程序中，我从Kafka主题读取事务，处理事务，然后将它们发送到IBM。当没有与IBM的连接时，我试图处理这个错误，以防止事务丢失。期望的行为是事务保持在Kafka主题中，而流侦听器再次读取它。然而，消息似乎只被消耗了一次，并且没有发生“回滚”。要做到这一点，以下是我的心声： cloud: kafka: input:consumer:
浏览 1提问于2019-08-02得票数 1
回答已采纳
有人熟悉Kafka和银行的实时交易预订功能吗？您能否推荐kafka用于每周处理相当于$billions的金融txns的交易系统的全天候正常运行时间、高耐用性、每秒10k msg、多区域、无限制数据保留处理(真相来源)？
浏览 27提问于2019-06-16得票数 0
回答已采纳
2回答
我们正在考虑使用kafka进行分布式开发，但也希望将其用作数据库。具体情况:我们用kafka写“交易”主题，并希望依赖它来存储所有的交易。问题是:在这个设计中是否需要一个恢复计划，卡夫卡会不会因为崩溃、磁盘故障而丢失数据？或者卡夫卡有自己的恢复机制，所以用户不需要自己的恢复计划？
浏览 0提问于2018-04-06得票数 3
回答已采纳
项目这些数据被输入到了卡夫卡的话题中。我正在考虑将大量的kafka主题分成日常主题，以便在大多数数据修复的情况下只需要重播一天的主题。
我的问题是
浏览 1提问于2018-11-06得票数 1
回答已采纳
我正在探索基于Kafka排序的Hyperledger fabric，当我尝试使用CLI创建通道时，我需要传递排序程序。
我现在已经使用Kafka创建了两个订单器，但是如何在创建通道时传递两个订单器。
浏览 0提问于2019-03-02得票数 0
2回答
最近，我开始使用Kafka，并为很少的用例评估Kafka。由于在代理端不可能进行过滤，实现以下情况的最佳方法是：
如果筛选条件是特定于使用者的。如果过滤标准(基于
浏览 4提问于2016-11-02得票数 1
1回答
对于KTable本身由一个Kafka主题定义的KSQL查询，我得到了意想不到的结果。KTABLE是“贸易”，它的背后是紧凑的主题"localhost.dbo.TradeHistory“。它应该包含由TradeId键控的股票交易的最新信息。主题的关键是TradeId。每个交易都有一个AccountId，我正在构建一个查询，以获得按帐户分组的交易金额的总和。贸易的定义
ksql> create table Trades(TradeId int, Accoun
浏览 3提问于2019-10-12得票数 1
回答已采纳
1回答
我认为在引擎盖下看设计可能是不可能的，但我想确认一下:如果消费者和生产者连接到不同的Kafka集群，那么有可能进行Kafka交易吗？这意味着我正在消费的主题和我正在推送的主题是在两个独立的Kafka集群上。
浏览 20提问于2019-04-26得票数 2
回答已采纳
我在rest端点调用中使用了idempotence启用(没有完全启用一次语义或事务)的kafka生产者。我之所以启用它，是因为我不想要卡夫卡重试造成的任何重复。以下是我关注的问题：
我读过kafka文档，启用幂等功能将使重试无限(什么?)如果我没有在交易中使用幂等效应，我真的需要它吗？
浏览 1提问于2020-11-21得票数 5
回答已采纳
我试图使用kafka streams库来使用kafka的一次功能。我只将proessing.guarantee配置为exactly_once。我的问题是，如何自定义主题的名称？如果kafka集群被多个消费者共享，每个客户是否需要不同的交易管理主题？
谢谢Murthy
浏览 2提问于2018-08-16得票数 0
我正在设计一个基于Kafka的基于事件源的架构，并使用Flink进行流处理。
一个用例将是查询(过滤和排序结果)历史交易数据，这些数据随着时间的推移通过Kafka主题。例如：“给我在过去5年的所有交易与这些属性，按xx排序”。总贸易历史将在1000万左右，以每年100万的速度增长。对于这样的历史查询，Flink本身是否是正确的工具，并且能够以合理的性能(几秒钟)做到这一点？或者，我更好地将Kafka中的事件输入到MongoDB/RDBMS等可索引/可查询的数据存储中，
浏览 0提问于2018-05-22得票数 0
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
