我是否有可能在SpringKafka向制作者和消费者提供运行时的配置细节？

Question

我们正在使用Spring boot将我们的项目迁移到微服务。我有一个要求，我应该能够使用配置详细信息（例如用户在运行时提供的引导服务器和键值服务器）运行生产者和消费者。

在之前的项目中，我可以使用java Apache Kafka API实现这一点，但我看不到使用spring Kafka API实现这一点的任何方法，因为它只允许通过spring java配置类或应用程序定义与生产者或消费者相关的配置。财产。

Answer 1

您可以在运行时为消费者和生产者覆盖您想要的任何属性。

使用ConcurrentKafkaListenerContainerFactory创建侦听器容器：

@Autowired
ConcurrentKafkaListenerContainerFactory<String, String> factory;

...

    ConcurrentMessageListenerContainer<String, String> container = factory.createContainer("someTopic");
    container.getContainerProperties()
            .getKafkaConsumerProperties()
            .setProperty(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "...");
    ...
    container.getContainerProperties().setMessageListener(someListener);
    container.start();

在生产者方面，使用以下构造函数：

/**
 * Create an instance using the supplied producer factory and properties, with
 * autoFlush false. If the configOverrides is not null or empty, a new
 * {@link DefaultKafkaProducerFactory} will be created with merged producer properties
 * with the overrides being applied after the supplied factory's properties.
 * @param producerFactory the producer factory.
 * @param configOverrides producer configuration properties to override.
 * @since 2.5
 */
public KafkaTemplate(ProducerFactory<K, V> producerFactory, @Nullable Map<String, Object> configOverrides) {
    this(producerFactory, false, configOverrides);
}