We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 600c3be commit af5fcbeCopy full SHA for af5fcbe
jpo-ode-svcs/src/test/java/us/dot/its/jpo/ode/test/utilities/EmbeddedKafkaHolder.java
@@ -42,15 +42,13 @@ public final class EmbeddedKafkaHolder {
42
public static EmbeddedKafkaBroker getEmbeddedKafka() {
43
if (!started) {
44
synchronized (EmbeddedKafkaHolder.class) {
45
- if (!started) {
46
- try {
47
- embeddedKafka.kafkaPorts(4242);
48
- embeddedKafka.afterPropertiesSet();
49
- } catch (Exception e) {
50
- throw new KafkaException("Embedded broker failed to start", e);
51
- }
52
- started = true;
+ try {
+ embeddedKafka.kafkaPorts(4242);
+ embeddedKafka.afterPropertiesSet();
+ } catch (Exception e) {
+ throw new KafkaException("Embedded broker failed to start", e);
53
}
+ started = true;
54
55
56
return embeddedKafka;
0 commit comments