Cleaning up Kafka producer factories

spring-cloud / spring-cloud-stream-binder-kafka

Spring Cloud Stream binders for Apache Kafka and Kafka Streams

Apache License 2.0

331 stars 301 forks source link

Cleaning up Kafka producer factories #1035

Closed sobychacko closed 3 years ago

sobychacko commented 3 years ago

Calling DisposableBean.destroy() on manually created Kafka producer factories. This affects both Kafka and Kafka Streams binders (in the case of Kafka Streams binder, it only matters when using the DLQ support).

Resolves https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/1034