path	# lines of code
CODE_OF_CONDUCT.MD	6
LICENSE.MD	17
src/docker/startup.ps1	24
src/main/java/com/azure/cosmos/kafka/connect/CosmosDBConfig.java	132
src/main/java/com/azure/cosmos/kafka/connect/TopicContainerMap.java	60
src/main/java/com/azure/cosmos/kafka/connect/sink/CosmosDBSinkConfig.java	67
src/main/java/com/azure/cosmos/kafka/connect/sink/CosmosDBSinkConnector.java	97
src/main/java/com/azure/cosmos/kafka/connect/sink/CosmosDBSinkTask.java	93
src/main/java/com/azure/cosmos/kafka/connect/sink/CosmosDBWriteException.java	9
src/main/java/com/azure/cosmos/kafka/connect/sink/StructToJsonMap.java	72
src/main/java/com/azure/cosmos/kafka/connect/sink/id/strategy/AbstractIdStrategy.java	15
src/main/java/com/azure/cosmos/kafka/connect/sink/id/strategy/AbstractIdStrategyConfig.java	12
src/main/java/com/azure/cosmos/kafka/connect/sink/id/strategy/FullKeyStrategy.java	11
src/main/java/com/azure/cosmos/kafka/connect/sink/id/strategy/IdStrategy.java	6
src/main/java/com/azure/cosmos/kafka/connect/sink/id/strategy/KafkaMetadataStrategy.java	15
src/main/java/com/azure/cosmos/kafka/connect/sink/id/strategy/KafkaMetadataStrategyConfig.java	37
src/main/java/com/azure/cosmos/kafka/connect/sink/id/strategy/ProvidedInConfig.java	37
src/main/java/com/azure/cosmos/kafka/connect/sink/id/strategy/ProvidedInKeyStrategy.java	6
src/main/java/com/azure/cosmos/kafka/connect/sink/id/strategy/ProvidedInStrategy.java	36
src/main/java/com/azure/cosmos/kafka/connect/sink/id/strategy/ProvidedInValueStrategy.java	6
src/main/java/com/azure/cosmos/kafka/connect/sink/id/strategy/TemplateStrategy.java	54
src/main/java/com/azure/cosmos/kafka/connect/sink/id/strategy/TemplateStrategyConfig.java	42
src/main/java/com/azure/cosmos/kafka/connect/source/CosmosDBSourceConfig.java	201
src/main/java/com/azure/cosmos/kafka/connect/source/CosmosDBSourceConnector.java	61
src/main/java/com/azure/cosmos/kafka/connect/source/CosmosDBSourceTask.java	240
src/main/java/com/azure/cosmos/kafka/connect/source/JsonToStruct.java	185
src/perf/cluster/charts/connect/Chart.yaml	5
src/perf/cluster/charts/connect/helm-config.yaml	17
src/perf/cluster/charts/connect/templates/_helpers.tpl	74
src/perf/cluster/charts/connect/templates/deployment.yaml	146
src/perf/cluster/charts/connect/templates/jmx-configmap.yaml	46
src/perf/cluster/charts/connect/templates/secrets.yaml	16
src/perf/cluster/charts/connect/templates/service.yaml	22
src/perf/cluster/charts/connect/values.yaml	50
src/perf/cluster/charts/sink-perf/Chart.yaml	6
src/perf/cluster/charts/sink-perf/templates/_helpers.tpl	57
src/perf/cluster/charts/sink-perf/templates/deployment.yaml	41
src/perf/cluster/charts/sink-perf/values.yaml	7
src/perf/cluster/manifests/kafka-client.yaml	12
src/perf/cluster/manifests/kafka-helm-config.yaml	20
src/perf/cluster/manifests/single-sink-perf-client.yaml	22