-
-
Notifications
You must be signed in to change notification settings - Fork 11
Description
Sometimes we write integration tests that care intimately about the upstream node ids. For example we may want to test metrics that are tagged with the node id. Currently since the node ids are an implementation detail of the test framework I would use an admin client to obtain the node id.
Or we may wish to test resilience of some feature by shutting down specific nodes. For example we recently had an issue with bootstrapping. I would like to be able to obtain the address for each individual node, such that I can construct a bootstrapServers list myself, and then shutdown the node corresponding to the first bootstrap address. Currently my test has an assumption that node 0 is the first bootstrap address.
I think it would be neat if I could obtain the nodeId and address of each individual node for a KafkaCluster without using any client for these odd cases where tests are interested in the nodes.