Deduplicate code blocks in Kafka data source

There're bunch of methods in Kafka data source which have repeated lines in a method - especially they're tied to the number of fields in writer schema, so once we add a new field redundant code lines will be increased. This issue tracks the efforts to deduplicate them.