假设我有一个服务A和一个服务B。对于每个请求，A使用Reactor Kafka (生产者)发布一个事件。服务B使用Reactor Kafka (消费者)来消费这些事件。
在系统压力过大的情况下，服务B是否可以与服务A通信以减慢速度</em
浏览 3提问于2019-07-24得票数 0
3回答
有没有任何方法可以暂停或节流卡夫卡的生产者基于消费者滞后或其他消费问题？生产者是否需要确定自己是否存在消费滞后，然后进行节流？
浏览 0提问于2019-01-14得票数 5
回答已采纳
我们在一个亚马逊网络服务EC2实例上安装了kafka和zookeeper。我们有kafka生产者和消费者运行在不同的ec2实例上，它们在同一个私有网络上，与kafka实例具有相同的安全组。在生产者或消费者配置中，我们使用kafka服务器的内部IP地址来连接它。但是我们注意到，
浏览 3提问于2018-10-31得票数 0
4回答
我们在消费者和生产者服务器之间有一个局域网。生产者的产出路径已经在消费者中得到了提升。生产者和消费者之间有一个10千兆的开关，每个服务器(消费者或生产者)之间的链接是1G。每个使用者使用两个线程从随机服务器读取数据。
问题是消费者和
浏览 0提问于2017-09-19得票数 0
回答已采纳
我有以下架构：我很困惑
1) whetherI can run kafka producer, broker and consumer on sepa
浏览 6提问于2015-11-02得票数 0
回答已采纳
如果集装箱(生产者、消费者和卡夫卡)在同一个n/w桥上怎么办？我是卡夫卡的新手，只是试着做一个简单的生产者和消费者的例子。我有一个码头容器，它生成消息并将其推送给kafka (通过声明kafka:9092作为引导服务器来工作)。因为我的卡夫卡码头集装箱叫卡夫卡)
我还需要为卡夫卡申报内外港口吗？消费者不能和生产者听同一
浏览 5提问于2022-05-20得票数 0
3回答
kafka-console-consumer.bat --bootstrap-server localhost:2181 --topic baeldung kafka-console-producer.bat--broker-list localhost:9092 --topic baeldung
消息不会从生产者传递到消费者。
浏览 0提问于2018-12-20得票数 1
1回答
内部服务之间的速率限制
、、、、
我有两个服务生产者和消费者(都是spring-boot)在不同的服务器上运行。其想法是从多个来源生成聚合数据并发布消息。然后，消费者监听它们并进行一些处理。
我在这些服务之间使用RabbitMQ。问题是在动态突发中以20K/s的速度发送消息(30秒突发+ 3-4秒空闲)。消费者的工作速度</e
浏览 0提问于2018-01-04得票数 0
我做了很多googlings，但仍然没有线索:我如何能自动拾取放在文件夹中的文件作为生产者的输入，从而被消费者拾取？谢谢。作为起点，我尝试了以下代码，但它不起作用(简单地退出，没有错误)：下面是更新：
我尝试了更多与创建生产者和消费者完全相同的方法，我看到消费者逐行接收csv内容，但并不完整。然后我做了控制台生产者和消费者收到消息，在它之后我做了文件输入，消费
浏览 13提问于2017-02-21得票数 0
回答已采纳
当使用时，我可以通过设置我的kafka生产者的kafka.compression.codec属性来设置编解码器。假设我在我的生产者中使用了snappy压缩，当我使用某个kafka消费者消费kafka的消息时，我应该做一些事情来解码来自snappy的数据还是它是kafka<em
浏览 0提问于2013-11-10得票数 9
回答已采纳
1回答
我正在Linux上测试Kafka，但我不知道出了什么问题，因为测试结果与我所理解的不同。如果我要解释一下我在这里的理解，
在Kafka的</
浏览 2提问于2022-01-05得票数 2
回答已采纳
1回答
我有一个多节点的Kafka集群，用于消费和生产。"bootstrap.servers":"localhost:9092,localhost:9093,localhost:9094&q
浏览 5提问于2021-06-05得票数 0
我一直在尝试使用Apache-Kafka在运行在virtualbox上的Arch生产者和Ubuntu VM消费者之间进行通信。通过遵循下面的youtube教程，我已经能够在一台机器上建立生产者和消费者之间的通信。 https://www.youtube.com/watch?v=VbSRS7kG5Cw 基本上，我在4个独立的终端中使用这
浏览 20提问于2019-09-30得票数 1
1回答
我们计划让生产者(Java rest api)和消费者(Java客户端)在多台机器上运行，并且所有消费者属于同一消费者组。1)在这种情况下，如果我在生产者发布Kafka写入随机/默认分区的消息时没有指定分区...
2)当消费者检索消息时，如果我没有提到分区，我会传递主题名称..and提交偏移量给Kafka服务器。如果我只有一个消费群体，
浏览 11提问于2016-02-24得票数 2
对于集群中的所有节点，运行相同的生产者代码和使用者代码有什么坏处吗？如果集群中有8个节点(8个消费者、8个kafka代理和8个生产者)，那么集群中会有8个生产者同时运行吗？是否有一种方法可以修改集群，使每次只运行一个生产者？
浏览 0提问于2019-01-08得票数 0
回答已采纳
我阅读了一些文档，并观看了一个关于Spring Cloud数据流(SCDF)的网络研讨会。我了解不同的绑定选项(RabbitMQ，Kafka，...)用于此框架中不同微服务之间的通信。SCDF“只是”使用Kafka代理进行内部通信，以及-可选的-用于微服务内的业务逻辑(例如，通过使用Kafka生产者或消
浏览 0提问于2017-10-25得票数 1
很好地解释了这两个队列之间的区别，但看起来TransferQueue只是一个更好的BlockingQueue版本。有什么情况是我们应该在TransferQueue上使用BlockingQueue，还是在LinkedTransferQueue上使用LinkedBlockingQueue？
浏览 1提问于2022-01-15得票数 -1
2回答
如何生成和使用来自不同服务器的消息？我试过了Quickstart教程，但是没有关于如何设置多服务器集群的说明。我的脚步1)bin/zookeeper-server-start.sh config/zookeeper.properties服务器B
1A)bin/kafka
浏览 6提问于2017-04-03得票数 1
1回答
我需要扩展我的集群以添加2个新节点，而且由于Kafka不提供自动数据重新分区，所以我希望运行随Kafka发行版一起附带的kafka-reassign-partitions.sh，以重新平衡集群中全部7个节点中的所有主题由于集群中已经有大量的生产数据，
运行这个脚本会减慢集群/生产者<
浏览 1提问于2016-09-12得票数 6
回答已采纳
1回答
我正在寻找一些关于如何构建基于kubernetes的应用程序的建议。我有一些数据生产者，他们从文件中读取数据，并将其放入具有数百个分区的kafka主题中，基于数据的逻辑分离。然后我有一些消费者正在从这些kafka分区读取数据。一个生产者可以写入多个分区，但是一个消费者只能从一个分区读取数据。一旦文件被处理，生产者应该完成，但消费者应该永远活着，监
浏览 11提问于2019-03-01得票数 0
云服务器
ICP备案
腾讯会议
实时音视频
对象存储
腾讯云开发者
