[prev in list] [next in list] [prev in thread] [next in thread] 

List:       flume-dev
Subject:    =?utf-8?q?=5BGitHub=5D_=5Bflume=5D_wanghangyu817_opened_a_new_pull_request_?= =?utf-8?q?=23346=3A_Re
From:       GitBox <git () apache ! org>
Date:       2021-07-06 14:24:32
Message-ID: flume.346.MDExOlB1bGxSZXF1ZXN0Njg0NDI0Njc4.gitbox () gitbox ! apache ! org
[Download RAW message or body]


wanghangyu817 opened a new pull request #346:
URL: https://github.com/apache/flume/pull/346


   When using memory-channel, the header is retrieved from sink and the metadata \
information of Kafka is retrieved from it, but when using kafka-channel, it is not \
retrieved  
   `       System.out.println("***************************");
   
           Map<String, String> headers = event.getHeaders();
           String rain = headers.get("rain");
           String topic = headers.get("topic");
           String key = headers.get("key");
           String offset = headers.get("offset");
   
           System.out.println("rain = " + rain);
           System.out.println("topic = " + topic);
           System.out.println("key = " + key);
           System.out.println("offset = " + offset);
   
           System.out.println("***************************");`
   
   In the above code, the printed value is empty, so this solves the problem
   
   
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: dev-unsubscribe@flume.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


[prev in list] [next in list] [prev in thread] [next in thread]