### Question:
KafkaMessageHandlerRegistry implements IKafkaMessageHandlerRegistry<T> { @Override public List<IKafkaMessageHandler<T>> getForTopic(String topic) { if (isEmpty()) { return null; } List<IKafkaMessageHandler<T>> handlers = new ArrayList<>(); for (IKafkaMessageHandler<T> kafkaMessageHandler : kafkaMessageHandlers) { if (kafkaMessageHandler.handles(topic)) { handlers.add(kafkaMessageHandler); } } return handlers; }  @PostConstruct @SuppressWarnings("checkstyle:MultipleStringLiterals") void init(); @Override List<IKafkaMessageHandler<T>> getForTopic(String topic); @Override List<IKafkaMessageHandler<T>> getForTopicOrFail(String topic); @Override boolean isEmpty(); @Override List<IKafkaMessageHandler<T>> getKafkaMessageHandlers();  }### Answer:
@Test void returnsCollectionOfHandlersForTopic() { assertEquals(2, kafkaMessageHandlerRegistry.getForTopic(TOPIC_A).size()); }