kafkaex/kafka_ex

metadata cache does not get updated when producing event

yingyingtang-brex opened this issue · 1 comments

To my understanding, when we produce a message with Topic A, the client will call server for metadata of the topic here.

However, we can see sometimes (not always), the metadata returned is for the previously produced topic (e.g. Topic B), rather than the current topic (e.g. Topic A) to be reproduced.

I suspect somehow the metadata cache was not updated, but not sure the root cause since its random issue.

Suggestions are appreciated!

@dantswain any thoughts on this ^