EmbeddedKafka usage improvements in Kafka Streams binder

spring-cloud / spring-cloud-stream

Framework for building Event-Driven Microservices

http://cloud.spring.io/spring-cloud-stream

Apache License 2.0

993 stars 606 forks source link

EmbeddedKafka usage improvements in Kafka Streams binder #2942

Closed sobychacko closed 5 months ago

sobychacko commented 5 months ago

Currently, EmbeddedKafka is initialized as part of the class initialization. This is preventing individual JUnit tests from being executed from an IDE (IntelliJ, for example). If we move this initialization to the JUnit BeforeAll method, then that seems to be working.