Added error handling. Split some of the common code between Kafka 8 and Kafka 9 processing into a separate function.
Added error handling. Split some of the common code between Kafka 8 and Kafka 9 processing into a separate function.

Netuitive/netuitive-diamond,Netuitive/netuitive-diamond,Netuitive/netuitive-diamond,Netuitive/netuitive-diamond