KafkaSource | ![1,849 1,849](../jacoco-resources/redbar.gif) ![88 88](../jacoco-resources/greenbar.gif) | 4% | ![146 146](../jacoco-resources/redbar.gif) | 0% | 99 | 101 | 376 | 399 | 26 | 28 | 0 | 1 |
BaseDataPublisher | ![1,530 1,530](../jacoco-resources/redbar.gif) | 0% | ![110 110](../jacoco-resources/redbar.gif) | 0% | 90 | 90 | 311 | 311 | 35 | 35 | 1 | 1 |
Kafka1ConsumerClient | ![397 397](../jacoco-resources/redbar.gif) | 0% | ![6 6](../jacoco-resources/redbar.gif) | 0% | 26 | 26 | 74 | 74 | 23 | 23 | 1 | 1 |
KafkaSource.WorkUnitCreator | ![111 111](../jacoco-resources/redbar.gif) | 0% | ![4 4](../jacoco-resources/redbar.gif) | 0% | 4 | 4 | 21 | 21 | 2 | 2 | 1 | 1 |
TimePartitionedDataPublisher | ![90 90](../jacoco-resources/redbar.gif) | 0% | ![2 2](../jacoco-resources/redbar.gif) | 0% | 4 | 4 | 15 | 15 | 3 | 3 | 1 | 1 |
KafkaSource.Offsets | ![82 82](../jacoco-resources/redbar.gif) | 0% | ![4 4](../jacoco-resources/redbar.gif) | 0% | 6 | 6 | 21 | 21 | 4 | 4 | 1 | 1 |
Kafka1ConsumerClient.new ConsumerRebalanceListener() {...} | ![53 53](../jacoco-resources/redbar.gif) | 0% | | n/a | 5 | 5 | 5 | 5 | 5 | 5 | 1 | 1 |
Kafka1ConsumerClient.new Function() {...} | ![25 25](../jacoco-resources/redbar.gif) | 0% | | n/a | 2 | 2 | 4 | 4 | 2 | 2 | 1 | 1 |
Kafka1ConsumerClient.new OffsetCommitCallback() {...} | ![21 21](../jacoco-resources/redbar.gif) | 0% | ![2 2](../jacoco-resources/redbar.gif) | 0% | 3 | 3 | 5 | 5 | 2 | 2 | 1 | 1 |
Kafka1ConsumerClient.new Function() {...} | ![18 18](../jacoco-resources/redbar.gif) | 0% | | n/a | 2 | 2 | 3 | 3 | 2 | 2 | 1 | 1 |
Kafka1ConsumerClient.Kafka1ConsumerRecord | ![27 27](../jacoco-resources/greenbar.gif) | 67% | ![2 2](../jacoco-resources/redbar.gif) | 0% | 3 | 7 | 2 | 8 | 2 | 6 | 0 | 1 |
Kafka1ConsumerClient.Factory | | 0% | | n/a | 2 | 2 | 2 | 2 | 2 | 2 | 1 | 1 |
KafkaSource.new Function() {...} | | 0% | | n/a | 2 | 2 | 2 | 2 | 2 | 2 | 1 | 1 |