我正在使用spring-cloud-stream-kafka编写一个小的压力测试，它会产生很多事件，并将它们发送到特定的Kafka主题。spring.cloud.stream.bindings.output.producer.partitionKeyExpression
属性来实现所需的行为？另外，我能够创建一个能做到这一点的提取器类，但我想知道是否有一种方法可以用Spel来实现这一
浏览 3提问于2017-07-20得票数 0
回答已采纳
withPayload(new Person("messageA", 1))我在属性文件中添加了： headers['pa
浏览 2提问于2018-03-13得票数 3
我正在接受以下项目的帮助：
spring: stream: ordersOut: content-type: application/json orde
浏览 0提问于2018-03-16得票数 0
=INFOlogging.file=events.logspring.cloud.stream.bindings.requestChannel.destination=events-exchangespring.cloud.st
浏览 3提问于2017-07-20得票数 1
回答已采纳
我有一个使用Kafka的基于Stream的微服务。spring: stream: SYNC_TABLE: partitionKeyExpression: payload.partitionKey
partitionCount: 4M
浏览 0提问于2017-07-04得票数 0
回答已采纳
1回答
如何以编程方式为我发送的类的每个实例设置partition-key？class Person { this.id = id; return id; this.id = id;
浏览 0提问于2018-03-13得票数 0
2回答
我已将我的生产者配置为：spring.cloud.stream.bindings.pc-abc-out-0.producer.partition-count=5
spring.cloud.stream.bindings.pc-abc-out-0.producer.header-mode=head
浏览 8提问于2022-01-24得票数 2
回答已采纳
在我的制作人application.properties中，我有spring.cloud.stream.bindings.output.producer.partitionCount=4
我的消费者application.properties看起来像这样spring.cloud.<e
浏览 0提问于2016-08-18得票数 0
使用spring-cloud-stream的kafka绑定器，如何配置并发消息消费者(在单个消费者jvm中)？s-c-s文档根本没有提到spring.cloud.stream.bindings.*.concurrency，尽管这在我上面描述的用例中似乎很重要。使用生产者配置 cloud: bindings: des
浏览 2提问于2016-03-08得票数 7
有没有什么spring.cloud.stream.kafka.bindings属性/选项可以实现这一点？
浏览 0提问于2020-02-27得票数 1
我想编写一个使用KafkaListener订阅主题的消费者方法。@KafkaListener(id = "foo", topics = "dead-out") System.out.println("DLQ:" + in);现在，在注释‘topic’中是订阅主题的名称。但是什么是'id‘字段呢？还是有更好的方法？
浏览 33提问于2020-05-13得票数 0
给定一个在Spring Cloud Stream函数中生成消息的Supplier函数，例如：Supplier<Flux<Message<PayLoad>>> sendMessage() {我假设我需要一些表单或spEl函数或其他。 application: cloud:
浏览 4提问于2021-08-26得票数 0
in case, I am adding the application.properties files if somebody needed for the answer:
spring.cloud.stream.bindings.output.destination=customers
spring.cloud.stream.bindings.output.producer.partitionKeyExpression=payload.id
浏览 9提问于2020-11-30得票数 0
我的application.properties是：
spring.cloud.stream.bindings.someCustomProcessor-in-0.destination=some-input-topicspring.cloud<
浏览 10提问于2022-11-19得票数 2
我的application.properties看起来像这样spring.cloud.stream.bindings.output.destination=greetingsspring.cloud.stream.bindings.output.partitionCo
浏览 4提问于2016-08-16得票数 0
回答已采纳
1回答
你好，我正在写一个使用spring cloud stream的kafka消费者-生产者。Cloud Streams Configurationspring.cloud.stream.kafka.binder.brokers=localhost:9092
##EventIngestionspring.cloud.stream.bindings.outputChannel.destination=Ev
浏览 33提问于2019-02-19得票数 1
1回答
(PartitionHandler.java:140) ~[spring-cloud-stream-3.2.4.jar:3.2.4] at org.s
浏览 9提问于2022-06-09得票数 0
: stream: content-type: application/*+avro
producer:(DefaultSchemaRegistryClient.java:69) ~[spring-cloud-stream-schema-2.2.1.RELEASE.jar!(AvroSchemaRegistryClientMessageConverter.java:308) ~[spring
浏览 4提问于2020-04-05得票数 0
application.yaml包含(例如)设置： kafka.streams.binder.functions.filter:
applicationId为了达到这个目的，我尝试使用SpEl。但结果表明，SpEl不能适用于apllication.yaml。
浏览 3提问于2021-04-23得票数 0
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号