Kafka consumer and producer for the scheduler