Path	Lines of Code
statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/Constants.java	10
statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaEgressBuilder.java	66
statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaEgressSerializer.java	6
statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaEgressSpec.java	51
statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaIngressAutoResetPosition.java	10
statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaIngressBuilder.java	108
statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaIngressDeserializer.java	6
statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaIngressSpec.java	74
statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaIngressStartupPosition.java	144
statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaProducerSemantic.java	51
statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaTopicPartition.java	70