Create multiple KafkaConsumer topics and run simultaneously, while sending messages to predefined functions in JSON format.