@ SuppressWarnings ( "rawtypes" ) public Class < ? extends TBase > getMessageClass ( String topic ) { return allTopics ? messageClassForAll : messageClassByTopic . get ( topic ) ; }
Returns configured thrift message class for the given Kafka topic