Skip to content

Commit 6fc037e

Browse files
committed
Fix NPE
Previous Sonar commit.
1 parent 77444ab commit 6fc037e

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

Diff for: spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -706,10 +706,10 @@ private final class ListenerConsumer implements SchedulingAwareRunnable, Consume
706706

707707
private final Map<TopicPartition, Boolean> wasIdlePartition;
708708

709-
private final Header infoHeader = new RecordHeader(KafkaHeaders.LISTENER_INFO, this.listenerinfo);
710-
711709
private final byte[] listenerinfo = getListenerInfo();
712710

711+
private final Header infoHeader = new RecordHeader(KafkaHeaders.LISTENER_INFO, this.listenerinfo);
712+
713713
private final Set<TopicPartition> pausedForNack = new HashSet<>();
714714

715715
private Map<TopicPartition, OffsetMetadata> definedPartitions;

0 commit comments

Comments
 (0)