Refactor Kafka Input Operator make code more clean and api easy to use #73