使用spring cloud stream kafka动态改变instanceindex

【问题标题】：Dynamically changing the instanceindex with spring cloud stream kafka使用spring cloud stream kafka动态改变instanceindex
【发布时间】：2021-07-30 03:15:46
【问题描述】：

类似于：Changing spring-cloud-stream instance index/count at runtime

我对在微服务器架构中启动批处理进行了 poc，并且我正在使用 Spring 批处理和 Spring Cloud Stream Kafka。我正在寻找一种方法来动态创建消费者（处理器）应用程序的多个实例。我看到可以用

定义多个实例

spring.cloud.stream.instanceCount=n 
spring.cloud.stream.instanceIndex=[0, ..., n-1]

但是我还没有找到动态更改instanceIndex 值的方法。是否可以使用 Spring Cloud Stream kafka 动态修改此值。

感谢您的帮助。

【问题讨论】：

标签： spring-boot apache-kafka apache-kafka-streams spring-kafka spring-batch-stream

【解决方案1】：

我找到了如何自动动态更改 instanceindex 的解决方案。我在属性文件中设置 minPortNum & maxPortNum 和 instanceCount 的值，并根据 port-minPortNum 的值改变 instanceIndex，然后我想运行多少消费者就运行多少。


@component
class ServerPortCustomize implements WebServerFactoryCustomizer {
    @value("${port.number.min}")
    private Integer minPortNum;
    @value("${port.number.max}")
    private Integer maxPortNum;
    @value("${spring.cloud.stream.instanceCount}")
    private Integer instanceCount;
    
    @Override
    public void customize(final ConfigurableWebServerFactory factory) {
        final int port = SocketUtils.findAvailableTcpPort(minPortNum, maxPortNum);
        factory.setPort(port);
        System.getProperties().put("server.port", port);
        System.getProperties().put("spring.cloud.stream.instanceIndex", port-minPortNum);
    }
}

对于这个例子，我已经设置 spring.cloud.stream.instanceCount=3，所以我运行三个消费者，实例索引为值 0、1 和 2

【讨论】：