my kafka spout is pretty much same to the example except the following properties i added:
props.put("ssl.truststore.location", "<cacerts>"); // on the cluster
props.put("sasl.jaas.config", "<client_jaas.conf>"); // on the cluster
i was able to submit the topology but it returned this error on storm web ui and no worker logs were generated
Unable to get offset lags for kafka. Reason: org.apache.kafka.shaded.common.errors.TimeoutException: Timeout expired while fetching topic metadata
What version of storm are you running and what version of storm-kafka-client are you depending on in your topology pom? Do you see anything in ui.log from storm's ui server when you refresh that page in storm ui?