{"push_id":924475735,"size":1,"distinct_size":1,"ref":"refs/heads/flink3058-second-rebased-rebased","head":"d1a1659029b246cc164fe3cb274b02d87696e679","before":"6b73a8b161e8a56af453cebb221d8576b8b0606f","commits":[{"sha":"d1a1659029b246cc164fe3cb274b02d87696e679","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[FLINK-3058] Add support for Kafka 0.9.0.0\n\nFor adding Kafka 0.9.0.0 support, this commit changes the following:\n- Split up of the kafka connector into a flink-connector-kafka-(base|0.9|0.8) with different dependencies\n- The base package contains common test cases, classes and implementations (the producer for 0.9 and 0.8 relies on exactly the same code)\n- the 0.8 package contains a kafka connector implementation against the SimpleConsumer (low level) API of Kafka 0.8. There are some additional tests for the ZK offset committing\n- The 0.9 package relies on the new Consumer API of Kafka 0.9.0.0\n- Support for metrics for all producers and the 0.9 consumer through Flink's accumulators.","distinct":true,"url":"https://api.github.com/repos/rmetzger/flink/commits/d1a1659029b246cc164fe3cb274b02d87696e679"}]}