1回答
有n个分区和一个包含n个消费者的消费者组。Kafka系统将消息分发到消费者之间。我如何将所有消费者的消息组合在一个地方，以便我有10条消息。我使用的是Kafka和Spring。
浏览 10提问于2019-02-10得票数 0
我有一个要求暂停卡夫卡消费者，并在固定的间隔后，它应该恢复卡夫卡消费者的.Pausing如预期的那样工作，但问题是与消费者的简历。在多绑定器场景下，固定时间间隔后未触发ListenerContainerIdleEvent。如果只为单个活页夹配置相同的代码。event.getConsumer().paused()); };application.yml： port: 7778 cloud:
stream
浏览 0提问于2019-05-02得票数 0
如果文件大小大于50 Id，则调用kafka producer并传递Id作为值的列表。我可以调用服务方法来提取卡夫卡消费者中的数据吗？
浏览 2提问于2018-05-25得票数 0
回答已采纳
我想从一个kafka集群消费消息并发布到另一个kafka集群。想知道如何使用spring-kafka进行配置吗？
浏览 72提问于2021-01-08得票数 2
回答已采纳
Kafka说，偏移量是由消费者管理的，同一个组应该有同样多的用户。那么，spring消费者代码能在同一组的多台服务器上运行吗？
浏览 0提问于2016-02-04得票数 2
回答已采纳
我有两个卡夫卡消费者(组)谁处理平行的一个主题。它们以消息的形式将结果发送到主题。现在，我想要实现一个kafka消费者，它应该接受两个结果(从一个消息中计算出来)并聚合它。由于这是一个更有状态的处理，我将如何实现一个Kafka消费者(spring引导)，协调上流消费者的完成？我知道这样的事情可以在Apache Flink，Kafka和其他类似的框架中实现，不过我想看看是否还有其他选择。
浏览 4提问于2022-05-18得票数 0
=localhost:9092
spring.kafka.consumer.auto-offset-reset=earliestspring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consum
浏览 5提问于2019-10-17得票数 1
我开始在docker上使用Spring Boot Kafka和kafka集群。当我开始检查容错时，我就遇到了这个问题。但是在停止了其中一个kafka容器(我有两个kafka实例和一个zookeeper)之后，我的消费者无法与剩下的那个进行通信。我的docker组合看起来像这样：services: image: wurstmeister/zookeeper
ports:“时
浏览 2提问于2019-07-19得票数 1
是否可以在application.yml中仅为应用程序生成的主题启用spring.cloud.stream.kafka.streams.binder.auto-create-topics，而不是自动创建应用程序使用的主题我正在使用spring-cloud-stream和kafka-streams绑定器。 在更一般的意义上，这是创建kafka主题的正确方法吗？
浏览 30提问于2020-11-24得票数 0
回答已采纳
1回答
我使用的是Spring Kafka Consumer。我已经将并发设置为10，并创建了5个消费者(针对5个主题)。所以有50个Spring Kafka消费者线程。我可以为Kafka消费者提供的最大线程数是多少？如何增加这个线程池的大小？我已经看过了spring文档，但没有发现任何相关内容。
浏览 84提问于2021-08-17得票数 1
回答已采纳
如果Kafka (spring.cloud.stream.bindings..producer.partitionCount)大于1并且Kafka (spring.cloud.stream.bindings
浏览 28提问于2021-05-08得票数 0
回答已采纳
我有一个spring boot应用程序。我希望实现一个从Kafka主题消费的函数，对于每个消费的消息，它调用另一个方法对消息进行一些处理，然后将其存储在数据库中。源kafka主题有12个分区。我想在同一个消费群体下创建6到12个kafka消费者。所有的消费者都将消费来自Kafka的消息并调用该函数。我不能得到一个好的设计。有人能帮帮我吗？
浏览 1提问于2020-02-19得票数 1
我在本地运行了我的动物园管理员和3个kafka代理。我启动了一个生产者和一个消费者。我可以看到消费者正在消费消息。然后，我启动了三个具有相同消费者组名称的消费者(由于这是一个spring启动项目，所以端口不同)。但我发现所有的消费者现在都在消费(接收)消息。这是我的属性文件spring.cloud.strea
浏览 3提问于2016-09-29得票数 0
我正在尝试将单独的Serde放在我的每个消费者身上，而不是所有消费者。例如，这会将Avro反序列化程序添加到我的应用程序中的所有使用者。我只想把它放在一个消费者身上 spring.cloud.stream.kafka.binder.consumerProperties.value.deserializer=io.confluent.kafka.serializers.KafkaAvroDeserializerspring.cloud.stream.kafka</
浏览 13提问于2020-10-28得票数 0
回答已采纳
我已经设置了一个Spring Boot应用程序来接收来自现有的和工作的Kafka生产者的Kafka消息。给出的控制台消息的解决方案是显式地将--security-protocol SSL作为参数传递给生产者或消费者命令。是否可以将application.yml配置为将--security-protocol SSL传递给消费者一个参数？另外，以前有没有人
浏览 11提问于2018-02-09得票数 2
我使用Spring引导版本1.5.4，version & spring版本1.3.8。
我的卡夫卡消费者正在进行成批的100块处理。我尝试使用的主题有10个分区&我有10个Kafka使用者实例。除了特定分区中的最后一个块之外，是否可以强制获得100个固定数量的记录(尽可能多)。
浏览 7提问于2020-02-14得票数 0
回答已采纳
1回答
我的问题是如何使用Spring Cloud Stream Kafka管理多实例。让我解释一下，在Spring Cloud Stream微服务上下文(eureka，configserver，kafka)中，我希望拥有相同微服务的两个实例。${hostname}它工作得很好，但问题是，每次我启动我的服务的新实例时，它都会在kafka中创建一个新的消费者组。现在我有很多闲置的消费群体。environment:
浏览 44提问于2020-07-17得票数 2
回答已采纳
我正在尝试设置Grafana仪表板来显示kafka指标。我正在尝试将kafka指标暴露给prometheus，这样Grafana仪表板就可以获取这些指标并进一步显示它们。org.apache.kafka:kafka-clients:jar:2.5.1:compileio.micrometer:micrometer-jersey2:jar:1.5.4:compilespri
浏览 7提问于2021-04-16得票数 0
Spring (2.0.1.RELEASE)发送消息。$ListenerConsumer.run(KafkaMessageListenerContainer.java:699) ~[spring-kafka-2.1.5.RELEASE.jar:2.1.5.=xx.xx.xx.xx:50070spring.kafka.properties.security.protocol=SSL
sprin
浏览 1提问于2018-04-25得票数 1
回答已采纳
云服务器
ICP备案
实时音视频
对象存储
云直播
腾讯云开发者
