wvanbergen library changed - made relevant changes in go-kafka