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 b72a37f commit 64891b3Copy full SHA for 64891b3
spring-kafka-test/src/main/java/org/springframework/kafka/test/EmbeddedKafkaBroker.java
@@ -776,7 +776,6 @@ public void onPartitionsAssigned(Collection<TopicPartition> partitions) {
776
records = consumer.poll(Duration.ofMillis(100)); // force assignment NOSONAR magic #
777
}
778
if (assigned.get() != null) {
779
- final ConsumerRecords<?, ?> theRecords = records;
780
logger.debug(() -> "Partitions assigned "
781
+ assigned.get()
782
+ "; re-seeking to "
0 commit comments