public Class<? extends Message> getMessageClass(String topic) {
        return allTopics ? messageClassForAll : messageClassByTopic.get(topic);
    }
public Class < ? extends Message > getMessageClass ( String topic ) { return allTopics ? messageClassForAll : messageClassByTopic . get ( topic ) ; }
Returns configured protobuf message class for the given Kafka topic

@param topic
Kafka topic
@return protobuf message class used by this utility instance, or
<code>null</code> in case valid class couldn't be found in the
configuration.