SpringCloud/spring-cloud-contract
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Handle null kafka header values (#1629)

Browse Source 
Fixes gh-1628
This commit is contained in:
bono007
2021-03-29 01:13:07 -05:00
committed by GitHub
parent 6a01e29ce5
commit 5d0154e5db
1 changed files with 9 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
spring-cloud-contract-verifier/src/main/java/org/springframework/cloud/contract/verifier/messaging/kafka/ContractVerifierKafkaConfiguration.java
View File

@@ -17,8 +17,8 @@
package org.springframework.cloud.contract.verifier.messaging.kafka;
import java.nio.charset.StandardCharsets;
import java.util.HashMap;
import java.util.Map;
import java.util.stream.Collectors;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
@@ -89,11 +89,17 @@ class ContractVerifierKafkaHelper extends ContractVerifierMessaging<Message<?>>
}
private MessageHeaders convertHeaders(Map<String, Object> headers) {
return new MessageHeaders(headers.entrySet().stream()
.collect(Collectors.toMap(Map.Entry::getKey, e -> maybeConvertValue(e.getValue()))));
final Map<String, Object> headersMap = new HashMap<>();
if (headers != null) {
headers.forEach((k, v) -> headersMap.put(k, maybeConvertValue(v)));
}
return new MessageHeaders(headersMap);
}
private Object maybeConvertValue(Object value) {
if (value == null) {
return value;
}
if (!(value instanceof byte[])) {
return value;
}