Hi everyone
How to update kafka consumer's metadata when some topics are deleted. The 
metadata in consumer will not be expired or remove outdated topic, which leads 
to UNKNOWN_TOPIC exception when fetching metadata from the cluster. Thank you 
very mych.

<https://maas.mail.163.com/dashi-web-extend/html/proSignature.html?ftlId=1&name=ysnakie&uid=ysnakie%40hotmail.com&iconUrl=http%3A%2F%2Fmail-online.nosdn.127.net%2Fsmc8371a9788890d59e567ed336b96676b.jpg&items=%5B%22ysnakie%40hotmail.com%22%5D>
[http://mail-online.nosdn.127.net/smc8371a9788890d59e567ed336b96676b.jpg]
ysnakie

ysna...@hotmail.com

签名由 网易邮箱大师<https://mail.163.com/dashi/dlpro.html?from=mail81> 定制

Reply via email to