Path	Lines of Code
samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java	63
samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKeySerde.java	36
samza-kafka/src/main/java/org/apache/samza/config/KafkaConsumerConfig.java	130
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaConsumerProxy.java	320
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaConsumerProxyFactory.java	4
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaStreamSpec.java	84
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemAdmin.java	670
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemConsumer.java	224
samza-kafka/src/main/java/org/apache/samza/system/kafka/descriptors/KafkaInputDescriptor.java	38
samza-kafka/src/main/java/org/apache/samza/system/kafka/descriptors/KafkaOutputDescriptor.java	10
samza-kafka/src/main/java/org/apache/samza/system/kafka/descriptors/KafkaSystemDescriptor.java	99
samza-kafka/src/main/java/org/apache/samza/util/KafkaUtil.java	29
samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala	291
samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManagerFactory.scala	32
samza-kafka/src/main/scala/org/apache/samza/config/KafkaConfig.scala	247
samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemConsumerMetrics.scala	58
samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemFactory.scala	73
samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemProducer.scala	148
samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemProducerMetrics.scala	13