flume-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From deng kai <dengka...@baidu.com>
Subject Review Request 55705: KafkaSink should avoid to call producer's method without timeout param
Date Thu, 19 Jan 2017 06:01:37 GMT

-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/55705/
-----------------------------------------------------------

Review request for Flume.


Repository: flume-git


Description
-------

There are several method call in kafka sink with no timeout params, in some cases, kafka sink
will await forever if no interruption.


Diffs
-----

  flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java
241e900 
  flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSinkConstants.java
7c819f5 

Diff: https://reviews.apache.org/r/55705/diff/


Testing
-------

All tests passed


Thanks,

deng kai


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message