require topic argument in to_kafka