Skip to content

Commit 6423fdc

Browse files
committed
chore(demo-kafka): fix org.apache.kafka.common.errors.TimeoutException
1 parent f0574e7 commit 6423fdc

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

demo-kafka/src/test/java/com/helltractor/demo/messaging/MessagingTest.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@
1111
import org.slf4j.LoggerFactory;
1212
import org.springframework.beans.factory.annotation.Autowired;
1313
import org.springframework.boot.test.context.SpringBootTest;
14+
import org.springframework.context.annotation.Lazy;
1415

1516
import java.util.List;
1617
import java.util.concurrent.atomic.AtomicInteger;
@@ -22,6 +23,7 @@ public class MessagingTest {
2223

2324
final static Logger logger = LoggerFactory.getLogger(MessagingTest.class);
2425

26+
@Lazy
2527
@Autowired
2628
MessagingFactory messagingFactory;
2729

0 commit comments

Comments
 (0)