Kafka clients contains few issues which should be fixed

• absence of tests
• busy waiting using the Thread.sleep()
• code is little bit confusing/not clear

During fixing these, the producer should be rewritten according to proposal mentioned in epic.