static boolean isKafkaStreamingTable(Table table) {
    // For kafka Streaming tables it is mandatory to set a kafka topic.
    return DruidStorageHandlerUtils.getTableProperty(table, DruidConstants.KAFKA_TOPIC) != null;
  }
Class containing some Utility methods for Kafka Ingestion.
druid-handler/src/java/org/apache/hadoop/hive/druid/DruidKafkaUtils.java