Path	Lines of Code
core/src/main/assembly/package.xml	40
core/src/main/java/org/apache/camel/kafkaconnector/CamelConnectorConfig.java	70
core/src/main/java/org/apache/camel/kafkaconnector/CamelConnectorUtils.java	26
core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkConnector.java	42
core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkConnectorConfig.java	57
core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java	207
core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceConnector.java	42
core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceConnectorConfig.java	90
core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceRecord.java	32
core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java	305
core/src/main/java/org/apache/camel/kafkaconnector/VersionUtil.java	12
core/src/main/java/org/apache/camel/kafkaconnector/aggregator/StringAggregator.java	22
core/src/main/java/org/apache/camel/kafkaconnector/transforms/CamelTransformSupport.java	11
core/src/main/java/org/apache/camel/kafkaconnector/transforms/CamelTypeConverterTransform.java	92
core/src/main/java/org/apache/camel/kafkaconnector/transforms/ConnectRecordValueToMapTransforms.java	39
core/src/main/java/org/apache/camel/kafkaconnector/transforms/FieldsToHeadersTransform.java	156
core/src/main/java/org/apache/camel/kafkaconnector/transforms/SchemaAndStructToJsonTransform.java	48
core/src/main/java/org/apache/camel/kafkaconnector/transforms/SinkPojoToSchemaAndStructTransform.java	83
core/src/main/java/org/apache/camel/kafkaconnector/transforms/SourcePojoToSchemaAndStructTransform.java	99
core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectDataformat.java	19
core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java	297
core/src/main/java/org/apache/camel/kafkaconnector/utils/SchemaHelper.java	35
core/src/main/java/org/apache/camel/kafkaconnector/utils/TaskHelper.java	84