The way we configure the kafka consumer assume that we pass the PLAINTEXT port.
We should have a way to configure the security protocol to use when connecting to a kafka broker.

Multiple options:

• infer this from the port, 9092->PLAINTEXT, 9093 -> SSL
• accept URI like brokers: ssl://IP:PORT, plaintext://IP:PORT
• separate config option, broker_security_protocol

AC:

• the streaming updater is able to connect to kafka using the SSL protocol