Skip to content

Commit b7acbb3

Browse files
committed
Fix Checkstyle issues
1 parent 225d27c commit b7acbb3

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

spring-kafka/src/test/java/org/springframework/kafka/listener/KafkaMessageListenerContainerTests.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -124,7 +124,7 @@ public class KafkaMessageListenerContainerTests {
124124

125125
private static String topic18 = "testTopic18";
126126

127-
127+
128128
@ClassRule
129129
public static KafkaEmbedded embeddedKafka = new KafkaEmbedded(1, true, topic3, topic4, topic5,
130130
topic6, topic7, topic8, topic9, topic10, topic11, topic12, topic13, topic14, topic15, topic16, topic17,
@@ -1535,6 +1535,7 @@ public void onPartitionsAssigned(Collection<TopicPartition> partitions) {
15351535
consumer.close();
15361536
logger.info("Stop rebalance after failed record");
15371537
}
1538+
15381539
private Consumer<?, ?> spyOnConsumer(KafkaMessageListenerContainer<Integer, String> container) {
15391540
Consumer<?, ?> consumer = spy(
15401541
KafkaTestUtils.getPropertyValue(container, "listenerConsumer.consumer", Consumer.class));

0 commit comments

Comments
 (0)