Major Description
Noticed a test failure in DynamicBrokerReconfigurationTest where the test accessing `KafkaConfig#listeners` during dynamic update of listeners threw an exception. In general, most dynamic configs can be updated independently, but listeners and listener security protocol map need to be updated together when new listeners that are not in the map are added or an entry is removed from the map along with the listener. We don't expect to see this failure in the implementation code because dynamic config updates are on a single thread and SocketServer processes the full update together and validates the full config prior to applying the changes. But we should ensure that KafkaConfig#listeners, KafkaConfig#advertisedListeners etc. work even if a dynamic update occurs during the call since these methods are used in tests and could potentially be used in implementation code in future from different threads.
Attachments
Issue Links
- links to