We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
logger
KafkaEmbedded
1 parent 88a28ce commit 4968758Copy full SHA for 4968758
spring-kafka-test/src/main/java/org/springframework/kafka/test/rule/KafkaEmbedded.java
@@ -492,17 +492,13 @@ public void onPartitionsRevoked(Collection<TopicPartition> partitions) {
492
@Override
493
public void onPartitionsAssigned(Collection<TopicPartition> partitions) {
494
consumerLatch.countDown();
495
- if (logger.isDebugEnabled()) {
496
- logger.debug("partitions assigned: " + partitions);
497
- }
498
}
499
500
});
501
consumer.poll(0); // force assignment
502
assertThat(consumerLatch.await(30, TimeUnit.SECONDS))
503
.as("Failed to be assigned partitions from the embedded topics")
504
.isTrue();
505
- logger.debug("Subscription Initiated");
506
507
508
0 commit comments