@Test public void buildScanFormPartitionPredicateEq() {
    Map
        actual =
        KafkaScanTrimmer.buildScanFromPartitionPredicate(fullHouse, PredicateLeaf.Operator.EQUALS, 3, false, false);
    TopicPartition topicPartition = new TopicPartition(topic, 3);
    Assert.assertEquals(fullHouse.get(topicPartition), actual.get(topicPartition));
  }
Test Class for Kafka Trimmer Class.
kafka-handler/src/test/org/apache/hadoop/hive/kafka/KafkaScanTrimmerTest.java