KafkaSource | | 4% | | 0% | 99 | 101 | 376 | 399 | 26 | 28 | 0 | 1 |
BaseDataPublisher | | 0% | | 0% | 90 | 90 | 311 | 311 | 35 | 35 | 1 | 1 |
Kafka1ConsumerClient | | 0% | | 0% | 26 | 26 | 74 | 74 | 23 | 23 | 1 | 1 |
KafkaSource.WorkUnitCreator | | 0% | | 0% | 4 | 4 | 21 | 21 | 2 | 2 | 1 | 1 |
TimePartitionedDataPublisher | | 0% | | 0% | 4 | 4 | 15 | 15 | 3 | 3 | 1 | 1 |
KafkaSource.Offsets | | 0% | | 0% | 6 | 6 | 21 | 21 | 4 | 4 | 1 | 1 |
Kafka1ConsumerClient.new ConsumerRebalanceListener() {...} | | 0% | | n/a | 5 | 5 | 5 | 5 | 5 | 5 | 1 | 1 |
Kafka1ConsumerClient.new Function() {...} | | 0% | | n/a | 2 | 2 | 4 | 4 | 2 | 2 | 1 | 1 |
Kafka1ConsumerClient.new OffsetCommitCallback() {...} | | 0% | | 0% | 3 | 3 | 5 | 5 | 2 | 2 | 1 | 1 |
Kafka1ConsumerClient.new Function() {...} | | 0% | | n/a | 2 | 2 | 3 | 3 | 2 | 2 | 1 | 1 |
Kafka1ConsumerClient.Kafka1ConsumerRecord | | 67% | | 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 |