### Question:
GroundingService { public static String extractBroker(AdapterDescription adapterDescription) { EventGrounding eventGrounding = getEventGrounding(adapterDescription); String host = eventGrounding.getTransportProtocol().getBrokerHostname(); int port = ((KafkaTransportProtocol) eventGrounding.getTransportProtocol()).getKafkaPort(); return host + ":" + port; }  static String extractBroker(AdapterDescription adapterDescription); static String extractTopic(AdapterDescription adapterDescription); static EventGrounding createEventGrounding(String kafkaHost, int kafkaPort, EventSchema eventSchema);  }### Answer:
@Test public void extractBrokerForGenericAdapterSetTest() { AdapterDescription adapterDescription = getGenericAdapterSetDescription(); String result = GroundingService.extractBroker(adapterDescription); assertEquals("localhost:1111", result); }
@Test public void extractBrokerForSpecificAdapterSetTest() { AdapterDescription adapterDescription = getSpecificAdapterSetDescription(); String result = GroundingService.extractBroker(adapterDescription); assertEquals("localhost:1111", result); }
@Test public void extractBrokerForStreamTest() { AdapterDescription adapterDescription = getAdapterStreamDescription(); String result = GroundingService.extractBroker(adapterDescription); assertEquals("localhost:1111", result); }