| Kafka1ConsumerClient(Config) |  | 0% | | n/a | 1 | 1 | 12 | 12 | 1 | 1 |
| consume(KafkaPartition, long, long) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| getEarliestOffset(KafkaPartition) | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
| getLatestOffset(KafkaPartition) | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
| static {...} | | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
| consume() | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
| commitOffsetsAsync(Map) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| committed(KafkaPartition) | | 0% | | 0% | 2 | 2 | 2 | 2 | 1 | 1 |
| kafkaToCodaHaleMetric(KafkaMetric) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| subscribe(String, GobblinConsumerRebalanceListener) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| getMetrics() | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
| subscribe(String) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| commitOffsetsSync(Map) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| canonicalMetricName(KafkaMetric) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| getTopics() | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$commitOffsetsSync$4(Map.Entry) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$commitOffsetsAsync$2(Map.Entry) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$getMetrics$1(Map, MetricName, KafkaMetric) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$consume$0(ConsumerRecord) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$commitOffsetsSync$5(Map.Entry) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$commitOffsetsAsync$3(Map.Entry) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| Kafka1ConsumerClient(Config, Consumer) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| close() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |