Skip to content

Commit 267738c

Browse files
committed
Fix new Sonar issues
1 parent 3a31b3c commit 267738c

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

spring-kafka/src/main/java/org/springframework/kafka/config/StreamsBuilderFactoryBean.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -209,7 +209,7 @@ public void setUncaughtExceptionHandler(Thread.UncaughtExceptionHandler exceptio
209209
* @since 2.8
210210
*/
211211
public void setStreamsUncaughtExceptionHandler(StreamsUncaughtExceptionHandler streamsUncaughtExceptionHandler) {
212-
this.streamsUncaughtExceptionHandler = streamsUncaughtExceptionHandler;
212+
this.streamsUncaughtExceptionHandler = streamsUncaughtExceptionHandler; // NOSONAR (sync)
213213
}
214214

215215
public void setStateRestoreListener(StateRestoreListener stateRestoreListener) {

spring-kafka/src/main/java/org/springframework/kafka/listener/RetryingBatchErrorHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -96,7 +96,7 @@ public void setAckAfterHandle(boolean ackAfterHandle) {
9696
public void handle(Exception thrownException, ConsumerRecords<?, ?> records,
9797
Consumer<?, ?> consumer, MessageListenerContainer container, Runnable invokeListener) {
9898

99-
if (records.count() == 0) {
99+
if (records == null || records.count() == 0) {
100100
LOGGER.error(thrownException, "Called with no records; consumer exception");
101101
return;
102102
}

0 commit comments

Comments
 (0)