v0.1.1
Add Source.Ping()
method to check connectivity to configured brokers and topics. Run during Init.Source()
to ensure errors are detected on start up.
Add Source.Ping()
method to check connectivity to configured brokers and topics. Run during Init.Source()
to ensure errors are detected on start up.