我正在尝试使用供应者/使用者生成和使用Kinesis数据流中的消息。是否有办法动态添加分区键？spring.cloud.stream.bindings.channel1.producer.partitionKeyExpression
@Bean public Supplier<String> produceMessages() { return "Testing"; }
无法添加分区密钥！
yfwxisqw1#
我们不知道channel1是什么，但根据Spring Cloud Stream文档，它必须是这样的：
channel1
spring.cloud.stream.bindings.produceMessages-out-0.producer.partitionKeyExpression='some-key'
https://docs.spring.io/spring-cloud-stream/docs/current/reference/html/spring-cloud-stream.html#_producer_properties您可以在这里找到样品：https://github.com/spring-cloud/spring-cloud-stream-samples/tree/main/kinesis-samples/kinesis-produce-consume
1条答案
按热度按时间yfwxisqw1#
我们不知道
channel1是什么，但根据Spring Cloud Stream文档，它必须是这样的：https://docs.spring.io/spring-cloud-stream/docs/current/reference/html/spring-cloud-stream.html#_producer_properties
您可以在这里找到样品：https://github.com/spring-cloud/spring-cloud-stream-samples/tree/main/kinesis-samples/kinesis-produce-consume