I merge the default implementation to this one because only one output format is allowed which is ProducerData in Kafka lib