Axon版本(3.3)，它在SpringBoot主类中使用在我们的用例中，命令端微服务需要从kafka主题中挑选消息，而不是将其公开为Rest api。它会将事件存储在事件存储中，然后将其移动到另一个kafka主题，供查询端微服务消费。
由于KafkaAutoCOnfigu
浏览 18提问于2019-07-12得票数 0
我使用Kafka Rest代理来生成和使用Azure APIM从Kafka主题消费，因此使用Rest代理的原因。is API that fulfills A1's request using REST proxy for Kafka如果A1向B2请求数据，而B2使用卡夫卡主题C3提供的<em
浏览 2提问于2022-07-21得票数 0
2回答
我以前没有使用过Kafka，我想知道如果消息是通过Kafka发布的，有哪些可能的方法来捕获这些信息？我不需要发布信息，只需要处理从Kafka publisher收到的数据。任何提示都会有所
浏览 3提问于2020-02-22得票数 0
根据Apache的文档，Kafka在其本地API的通信中使用了二进制TCP协议，但它们也为不支持Apache的本地API的语言提供了基于URL的restful。我只是想知道本地二进制TCP协议(在本机API中支持)是否比基于restful的与代理节点的通信有什么好处？我还在想restful是否还会维护only once属性呢？编辑: restful指南在这里：，它解释了如何在restful上生成和使用Kafka的消息
浏览 1提问于2017-09-24得票数 2
回答已采纳
我创建了两个WSO2企业服务总线集成项目，一个用于Kafka消息生产者，另一个用于Kafka消息消费者。我成功地在调用REST API时创建了Kafka消息生成器，并将消息放在主题上。当我创建Kafka消息消费者时，没有像Kafka这样的传输供代理监听，并且根据文档，我们需要
浏览 30提问于2021-11-18得票数 0
回答已采纳
我使用的是kafka集群1.0.2版本，我想通过kafka控制台命令看到所有的消费组，但是看不到。.show information about consumers that use ZooKeeper (not those using the Java consumer API).console
浏览 0提问于2019-07-25得票数 0
我有Nifi集群，Kafka也安装在那里。
创建了一个带有5个分区的主题，开始使用带有一个gourp-id的主题。这样每个分区都会得到唯一的消息。现在，我创建了5个ConsumeKafka_1_0处理器，目的是在每个消费者端获得唯一的消息。但只有2个ConsumeKafka_1_0正在使用rest设置为理想的所有消息。现在我所做的是启动5个命令行Kafka使用者，所发生的是，我能够
浏览 2提问于2018-08-14得票数 0
1回答
我想知道如何通过java api在kafka中获取每个主题的消息数，我不知道如何使用下面提到的命令行工具。你知道怎么做吗？PS:我不想通过循环通过KAFKA消费者流来计算计数，我试图在开始时计算这个计数(在从Kafka消费之前)
浏览 1提问于2016-08-06得票数 0
每秒大约有70个请求通过Scrapy Cluster REST api (Producer)提交给Kafka。这是我用来查看Kafka中demo.incoming主题消息数的命令--broker-list localhost1 | awk -F ":" '{sum += $3} END {p
浏览 1提问于2019-07-07得票数 1
我已经在我的Windows10笔记本电脑上在WindowsLinux3.4.12下安装了Kafka1.1.0和ZooKeep3.4.12。我可以在ubuntu中获取和使用消息，但是当我想从windows (使用java程序或使用kafka-console-Producer.bat工具)生成消息时，我有以下错误：
2018-05-11 15:31:01,449在用键向主题测试发送消息时出错: null，值: 15字节带有错误：(org.apache.kafka.clien
浏览 0提问于2018-05-11得票数 0
供应商发布对位于供应商DC中的Kafka主题的频繁异步响应。我们要把这些信息输入我们公司。我们不想做的是：我们希望他们调用Rest (回调url)来发布信息。在将消息写入主题时，是否有任何选项可以配置(它们的) Kafka主题上的触发器来调用(外部) REST？我们希望他们调用我们的API，
浏览 0提问于2020-08-05得票数 0
让我们来讨论一种情况。
消费者收到一个Kafka流，流中的消息需要基于一些Validator Micro服务和Enricher API调用进行丰富和验证。它还将消息持久化到数据库中。流程是这样的- Kafka Stream consumer ->每个消息->调用Rule Validator Rest API ->调用富API ->通过持久化REST<
浏览 0提问于2020-03-22得票数 1
每当我尝试连接到kafka的生产者/消费者，我得到“未授权的主题test2” 如果我关闭了授权，我成功地通过了身份验证，所以身份验证可以工作，只有授权不能。在kafka.security.auth.SimpleAclAuthorizer不起作用的情况下进行ACL授权。sasl.enabled.mechanisms=PLAIN
delete.topic.enable=false 日志/kafka-authorizer [2019-04-06 13:24:05,693$b
浏览 150提问于2019-04-07得票数 1
在Kafka中，一个消费者可以订阅的主题的最大限制是什么。我在任何地方都找不到这个记录的值。
如果消费者订阅了500000个或更多的主题，性能是否会下降。
浏览 6提问于2017-09-19得票数 5
我有python脚本，并且需要使用kafka1 broker集群检索一组从kafka主题读取的消费者的当前消费者组偏移量。这些是原生kafka消费者，将偏移量存储在kafka集群中，而不是zookeeper中。
脚本本身不需要使用任何消息，只需读取其他使用者的当前偏移量。我意识到使用kafka-consumer-groups.sh可以做到这一点，但理想情况下，我希望避免依赖外壳<e
浏览 1提问于2018-03-12得票数 3
1回答
我们计划让生产者(Java rest api)和消费者(Java客户端)在多台机器上运行，并且所有消费者属于同一消费者组。1)在这种情况下，如果我在生产者发布Kafka写入随机/默认分区的消息时没有指定分区...
2)当消费者检索消息时，如果我没有提到分区，我会传递主题名称..and提交偏移量给Kafka服务器。如果我只有一个消费群体，这是一个好方法吗？3)我是否需要<e
浏览 11提问于2016-02-24得票数 2
1回答
比方说，我有一个服务，它通过kafka-rest代理来消费消息，并且总是在同一个消费者群体上。我们还可以说，它正在消耗一个有一个分区的主题。当服务启动时，它在kafka-rest代理中创建一个新的使用者，并使用生成的使用者url直到服务被关闭。当服务恢复时，它将在kafka-rest代理中创建一个新的消费者，并使用新的url (
浏览 1提问于2016-07-07得票数 2
回答已采纳
我是apache kafka的初学者，正在尝试学习confluent - kafka - rest - utils，但是我对如何使用它感到困惑。在搜索过程中，我找到了这个文档confluent kafka rest实用程序的git代码是
正在演示如何使用rest kafka。谁能给我一些建议，我如何使用rest客户端
浏览 3提问于2015-05-29得票数 8
3回答
我需要从多个主题中获取消息。为此，我需要输入每个主题的使用者组。我试过以下命令：为此，我需要提到消费者组，并检查我的主题是否属于这个组。但我不知道某些主题的消费者群体价值。
那么，是否有任何命令或编程方法来查找给定<e
浏览 13提问于2017-04-21得票数 4
Apache Beam和Apache Kafka在流处理方面有什么不同？我也在努力掌握技术和编程上的差异。
请通过您的经验报告来帮助我理解。
浏览 1提问于2018-06-15得票数 10
云服务器
ICP备案
云直播
实时音视频
即时通信 IM
腾讯云开发者
