### Question:
GroundingService { public static String extractTopic(AdapterDescription adapterDescription) { EventGrounding eventGrounding = getEventGrounding(adapterDescription); return eventGrounding.getTransportProtocol().getTopicDefinition().getActualTopicName(); }  static String extractBroker(AdapterDescription adapterDescription); static String extractTopic(AdapterDescription adapterDescription); static EventGrounding createEventGrounding(String kafkaHost, int kafkaPort, EventSchema eventSchema);  }### Answer:
@Test public void extractTopicForGenericAdapterSetTest() { AdapterDescription adapterDescription = getGenericAdapterSetDescription(); String result = GroundingService.extractTopic(adapterDescription); assertEquals("test.topic", result); }
@Test public void extractTopicForSpecificAdapterSetTest() { AdapterDescription adapterDescription = getSpecificAdapterSetDescription(); String result = GroundingService.extractTopic(adapterDescription); assertEquals("test.topic", result); }
@Test public void extractTopicForStreamTest() { AdapterDescription adapterDescription = getAdapterStreamDescription(); String result = GroundingService.extractTopic(adapterDescription); assertEquals("test.topic", result); }