diff --git a/pkg/admin/connector.go b/pkg/admin/connector.go index 9e626044..b7c59514 100644 --- a/pkg/admin/connector.go +++ b/pkg/admin/connector.go @@ -168,6 +168,8 @@ func NewConnector(config ConnectorConfig) (*Connector, error) { Dial: connector.Dialer.DialFunc, SASL: mechanismClient, TLS: tlsConfig, + // Hotfix for https://github.com/segmentio/topicctl/issues/112 + MetadataTTL: 10 * time.Minute, }, }