diff --git a/transport/kafka/kafka.go b/transport/kafka/kafka.go index 407a72cc..6624e0fa 100644 --- a/transport/kafka/kafka.go +++ b/transport/kafka/kafka.go @@ -243,7 +243,6 @@ func (d *KafkaDriver) Close() error { return nil } -// todo: deprecate? func GetServiceAddresses(srv string) (addrs []string, err error) { _, srvs, err := net.LookupSRV("", "", srv) if err != nil {