Updated Kafka northbound_producer app. This change includes