fluent-plugin-kafka && kafka-rb , our personal code , I will push it to our repo : ops-baidu/fluent-plugin-kafka && ops-baidu/kafka-rb