Modified to connect with configured Kafka zookeeper and broker on startup.