File tree 1 file changed +2
-2
lines changed
spring-kafka/src/main/java/org/springframework/kafka/support/serializer
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
194
194
String headerName , LogAccessor logger ) {
195
195
196
196
Header header = record .headers ().lastHeader (headerName );
197
- if (!(header instanceof DeserializationExceptionHeader )) {
197
+ if (header != null && !(header instanceof DeserializationExceptionHeader )) {
198
198
logger .warn (
199
199
() -> String .format ("Foreign deserialization exception header in (%s) ignored; possible attack?" ,
200
200
KafkaUtils .format (record )));
@@ -224,7 +224,7 @@ public static DeserializationException getExceptionFromHeader(final ConsumerReco
224
224
@ Nullable
225
225
public static DeserializationException byteArrayToDeserializationException (LogAccessor logger , Header header ) {
226
226
227
- if (!(header instanceof DeserializationExceptionHeader )) {
227
+ if (header != null && !(header instanceof DeserializationExceptionHeader )) {
228
228
throw new IllegalStateException ("Foreign deserialization exception header ignored; possible attack?" );
229
229
}
230
230
try {
You can’t perform that action at this time.
0 commit comments