Invoke rules to process archives from a topic on kafka and produce results to a topic on kafka. - View it on GitHub