Created an Apache Kafka cluster (3 brokers, 3 controllers, 1 worker for now) for a project and have multiple topics receiving data from a 3rd party. The worker is leveraging the confluent elasticsearch plugin.