Path	Lines of Code
src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/AutoCloseableLock.java	13
src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/FileWriter.java	293
src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/KustoSinkConfig.java	442
src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/KustoSinkConnector.java	48
src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/KustoSinkTask.java	438
src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/SourceFile.java	12
src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/TopicIngestionProperties.java	6
src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/TopicPartitionWriter.java	244
src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/TopicToTableMapping.java	93
src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/Version.java	25
src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/format/RecordWriter.java	9
src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/format/RecordWriterProvider.java	5
src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/formatWriter/AvroRecordWriterProvider.java	62
src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/formatWriter/ByteRecordWriterProvider.java	50
src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/formatWriter/JsonRecordWriterProvider.java	82
src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/formatWriter/StringRecordWriterProvider.java	40