File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
spring-kafka/src/main/java/org/springframework/kafka/support/serializer Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -194,7 +194,7 @@ public static DeserializationException getExceptionFromHeader(final ConsumerReco
194194 String headerName , LogAccessor logger ) {
195195
196196 Header header = record .headers ().lastHeader (headerName );
197- if (!(header instanceof DeserializationExceptionHeader )) {
197+ if (header != null && !(header instanceof DeserializationExceptionHeader )) {
198198 logger .warn (
199199 () -> String .format ("Foreign deserialization exception header in (%s) ignored; possible attack?" ,
200200 KafkaUtils .format (record )));
@@ -224,7 +224,7 @@ public static DeserializationException getExceptionFromHeader(final ConsumerReco
224224 @ Nullable
225225 public static DeserializationException byteArrayToDeserializationException (LogAccessor logger , Header header ) {
226226
227- if (!(header instanceof DeserializationExceptionHeader )) {
227+ if (header != null && !(header instanceof DeserializationExceptionHeader )) {
228228 throw new IllegalStateException ("Foreign deserialization exception header ignored; possible attack?" );
229229 }
230230 try {
You can’t perform that action at this time.
0 commit comments