Hi, Have you tried setting the METADATA_MAX_AGE_CONFIG (default: 300,000ms) smaller? It seems the consumer won't actually update the metadata info until it's out of date.
>-----Original Message----- >From: Shengnan YU [mailto:ysna...@hotmail.com] >Sent: Wednesday, April 24, 2019 1:43 PM >To: users@kafka.apache.org >Subject: kafka consumer metadata expire > >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%40hot >mail.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> >定制