I have added an example for KStreamDriver to the GitHub Gist and updated the JIRA issue.
https://issues.apache.org/jira/browse/KAFKA-4461 https://gist.github.com/hrafzali/c2f50e7b957030dab13693eec1e49c13 Hamid
I have added an example for KStreamDriver to the GitHub Gist and updated the JIRA issue.
https://issues.apache.org/jira/browse/KAFKA-4461 https://gist.github.com/hrafzali/c2f50e7b957030dab13693eec1e49c13 Hamid