Kafka - Cluster Architecture
Find the bug in this Kafka controller election monitoring code snippet:
var controllerFuture = adminClient.describeCluster().controller();
var controllerId = controllerFuture.id().get();
System.out.println("Controller ID: " + controllerId);