public class HeaderFactory extends Object
Constructor and Description |
---|
HeaderFactory() |
Modifier and Type | Method and Description |
---|---|
static org.apache.kafka.common.header.Headers |
createHeaders(Map<String,String> mapObj)
Create Kafka headers from a map of String keys and String values.
|
Copyright © 2019. All rights reserved.