Path Lines of Code src/test/java/com/microsoft/azure/kusto/kafka/connect/sink/FileWriterTest.java 216 src/test/java/com/microsoft/azure/kusto/kafka/connect/sink/KustoSinkConnectorConfigTest.java 170 src/test/java/com/microsoft/azure/kusto/kafka/connect/sink/KustoSinkConnectorTest.java 41 src/test/java/com/microsoft/azure/kusto/kafka/connect/sink/KustoSinkTaskTest.java 305 src/test/java/com/microsoft/azure/kusto/kafka/connect/sink/TopicPartitionWriterTest.java 297 src/test/java/com/microsoft/azure/kusto/kafka/connect/sink/Utils.java 57 src/test/java/com/microsoft/azure/kusto/kafka/connect/sink/appender/TestAppender.java 22 src/test/java/com/microsoft/azure/kusto/kafka/connect/sink/formatWriter/AvroRecordWriterTest.java 58 src/test/java/com/microsoft/azure/kusto/kafka/connect/sink/formatWriter/ByteArrayWriterProviderTest.java 45 src/test/java/com/microsoft/azure/kusto/kafka/connect/sink/formatWriter/JsonRecordWriterProviderTest.java 47 src/test/java/com/microsoft/azure/kusto/kafka/connect/sink/formatWriter/StringRecordWriterProviderTest.java 44 src/test/java/com/microsoft/azure/kusto/kafka/connect/sink/it/ITCoordinates.java 27 src/test/java/com/microsoft/azure/kusto/kafka/connect/sink/it/ITSetup.java 38 src/test/java/com/microsoft/azure/kusto/kafka/connect/sink/it/KustoSinkIT.java 400 src/test/java/com/microsoft/azure/kusto/kafka/connect/sink/it/containers/KustoKafkaConnectContainer.java 146 src/test/java/com/microsoft/azure/kusto/kafka/connect/sink/it/containers/ProxyContainer.java 17 src/test/java/com/microsoft/azure/kusto/kafka/connect/sink/it/containers/SchemaRegistryContainer.java 22 src/test/resources/download-libs.sh 8 src/test/resources/it-avro.avsc 114