We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent bc07101 commit 65fbc8fCopy full SHA for 65fbc8f
spring-kafka-docs/src/main/antora/modules/ROOT/pages/testing.adoc
@@ -163,16 +163,16 @@ public final class EmbeddedKafkaHolder {
163
public static EmbeddedKafkaBroker getEmbeddedKafka() {
164
if (!started) {
165
synchronized (this) {
166
- if (!started) {
167
- try {
168
- embeddedKafka.afterPropertiesSet();
169
- }
170
- catch (Exception e) {
171
- throw new KafkaException("Embedded broker failed to start", e);
172
173
- started = true;
174
175
+ if (!started) {
+ try {
+ embeddedKafka.afterPropertiesSet();
+ }
+ catch (Exception e) {
+ throw new KafkaException("Embedded broker failed to start", e);
+ started = true;
176
}
177
return embeddedKafka;
178
0 commit comments