Spring云流分区KeyExpression SpEL
spring.cloud.stream.bindings.output.producer.partitionKeyExpression
谢谢，马尔科
共有1个答案
猫王接线员？
类似于
payload.userId ?: Math.random() * 6
？
-
spring cloud stream如何将多个Kafka分区分配给属于同一消费者组的反应流？ 我注意到，如果我使用普通的非反应流侦听器，每个线程将被分配到一个分区，这取决于使用者并发配置。然而，在流（流量输入）的情况下，我没有注意到任何这样的并行行为。似乎只定义了一个流来处理来自所有分区的消息。 我的期望是每个Kafka主题分区都有独立的流，即使在由不同线程备份的同一节点上也是如此。
-
我无法使用功能供应商发送Avro消息。SCSt尝试将消息作为JSON发送，但失败。有人能指出是否需要任何其他配置吗？ 这是供应商的功能bean 和配置
-
Spring Cloud Kafka Streams与Spring Cloud Stream、Spring Cloud Function、Spring AMQP和Spring for Apache Kafka有什么区别？
-
我的流处理器中有一个关于多个分区的主题，我只是想从一个分区进行流处理，但是不知道如何配置 我只希望此处理器处理一个分区数据，其他分区将有其他处理器 到目前为止，我的发现与https://Kafka . Apache . org/20/javadoc/org/Apache/Kafka/streams/streams CONFIG . html # PARTITION _ GROUPER _ CLAS
-
使用Spring Cloud Stream版本Chelsea. SR2，RabbitMQ作为消息代理。要拥有多个消费者，我们使用属性并发（入站消费者的并发）。 如果我们将并发设置为50。它从1开始，慢慢地增加消费者计数。有没有任何可能的解决方案可以使用更高的数字而不是一个来启动初始消费者计数，以提高消费者性能。
-
我正在尝试用《Spring的云流》和《Kafka》。下面是示例代码。但它似乎没有任何作用。它总是创建一个名为“输出”的主题。但这些价值观尚未公布。 应用亚马尔 我的目标就是创造价值。 依赖性-2.2.6。释放