kafka client with threads and a scheduler - View it on GitHub