Need help for implementing a Kafka Sink for Flink-Runner in Beam

[kaniska Mandal]

I am referring to this post  :
>From Emanuele Cesena <emanu...@shopkick.com>
Subject Re: Output from Beam (on Flink) to Kafka
Date Fri, 18 Mar 2016 16:45:15 GMT
source :
https://github.com/ecesena/oscars2016/blob/master/beam-twitter/src/main/java/com/shopkick/data/dataflow/TwitterDataflow.java

>> I added the KafkaIO inside
org.apache.beam.runners.flink.translation.wrappers.streaming.io

>> I have also registered KafkaIOWriteBoundStreamingTranslator with
 KafkaIO.Write.Bound.class  inside - FlinkStreamingTransformTranslators

Now I need help to invoke FlinkKafkaProducer08 to send messages from the
following method ..

public void translateNode(KafkaIO.Write.Bound<T> transform,
FlinkStreamingTranslationContext context) {...}

It would be great if someone can provide some hints.

Thanks

Kaniska