Got console producer-consumer working , but need to find better solution for socket timeout
Added TODO to investigate kafka-1733, verified it doesn't work with new producer api