Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Duplicate
-
0.8.2.0
-
None
-
None
Description
I searched again and I do think that topicMetadataResponse.brokers is not read in Scala Producer, or I have not found where it is. (In the java producer it does seem used on the other hand).
The producer seems to only parse its static configuration (properties file on key metadata.broker.list on disk stating initial broker list), and cache it in BrokerPartitionInfo. It never updates that broker list cache when it receives a metadata response!
It really seems that only that statically configured metadata.broker.list is ever queried for metadata, not only initially but at any time e.g. this list is never refreshed with the brokers listed in the topic metadata response.