Check out the KIP that added headers: https://cwiki.apache.org/confluence/display/KAFKA/KIP-82+-+Add+Record+Headers
-Matthias On 6/8/18 8:23 PM, ???????????? wrote: > Hi team: > When I reading KafkaProducer doSend() and I found each record have a > Header[] headers . > But I don't know why we should use the headers ? > Someone could help me ? > thanks a lot ~ >
signature.asc
Description: OpenPGP digital signature