apache / camel-kafka-connector

Intro

Unit size measurements show the distribution of size of units of code (methods, functions...).
Units are classified in four categories based on their size (lines of code): 1-20 (small units), 20-50 (medium size units), 51-100 (long units), 101+ (very long units).
You should aim at keeping units small (< 20 lines). Long units may become "bloaters", code that have increased to such gargantuan proportions that they are hard to work with.

Learn more...

Unit Size Overall

There are 1,736 units with 10,681 lines of code in units (31.6% of code).

6 very long units (884 lines of code)
5 long units (352 lines of code)
57 medium size units (1,585 lines of code)
128 small units (1,854 lines of code)
1,540 very small units (6,006 lines of code)

Legend:

101+

51-100

21-50

11-20

1-10

Unit Size per Extension

101+

51-100

21-50

11-20

1-10

Unit Size per Logical Component

primary logical decomposition

101+

51-100

21-50

11-20

1-10

Alternative Visuals

3D view of all units

Longest Units

Top 50 longest units

Unit	# lines	McCabe index	# params
protected void executeAll() in tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/GenerateCamelKafkaConnectorsMojo.java	188	22	0
private void createClasses() in tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/CamelKafkaConnectorUpdateMojo.java	171	21	4
private void createClassesAndDocumentation() in tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/CamelKafkaConnectorKameletUpdateMojo.java	149	14	4
public static ConfigDef conf() in connectors/camel-netty-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/netty/CamelNettySourceConnectorConfig.java	129	1	0
public CamelKafkaConnectMain build() in core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java	126	18	1
public static ConfigDef conf() in connectors/camel-netty-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/netty/CamelNettySinkConnectorConfig.java	121	1	0
public void start() in core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java	89	6	1
public void start() in core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java	79	8	1
private void addConnectorOptions() in tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/CamelKafkaConnectorUpdateMojo.java	68	18	9
private void addConnectorOptions() in tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/CamelKafkaConnectorKameletUpdateMojo.java	65	16	8
public static ConfigDef conf() in connectors/camel-sjms2-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/sjms2/CamelSjms2SourceConnectorConfig.java	51	1	0
public synchronized List poll() in core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java	49	14	0
public static ConfigDef conf() in connectors/camel-sjms2-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/sjms2/CamelSjms2SinkConnectorConfig.java	48	1	0
public static ConfigDef conf() in connectors/camel-cxf-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/cxf/CamelCxfSinkConnectorConfig.java	45	1	0
public static ConfigDef conf() in connectors/camel-aws2-iam-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2iam/CamelAws2iamSinkConnectorConfig.java	45	1	0
public static ConfigDef conf() in connectors/camel-aws2-kms-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2kms/CamelAws2kmsSinkConnectorConfig.java	43	1	0
public static ConfigDef conf() in connectors/camel-cxf-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/cxf/CamelCxfSourceConnectorConfig.java	39	1	0
public R apply() in core/src/main/java/org/apache/camel/kafkaconnector/transforms/SourcePojoToSchemaAndStructTransform.java	38	4	1
private void updateConnector() in tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/CamelKafkaConnectorKameletUpdateMojo.java	38	6	0
public static ConfigDef conf() in connectors/camel-cxfrs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/cxfrs/CamelCxfrsSinkConnectorConfig.java	36	1	0
private void setAdditionalHeaders() in core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java	35	14	3
public static void addDependencies() in tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/utils/MavenUtils.java	33	8	4
public static KameletModel parseKameletYaml() in tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/utils/YamlKameletMapper.java	33	10	1
private boolean updateAutoConfigureOptions() in tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/CamelKafkaConnectorUpdateMojo.java	32	5	2
private boolean updateAutoConfigureOptions() in tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/CamelKafkaConnectorKameletUpdateMojo.java	32	5	2
public R apply() in core/src/main/java/org/apache/camel/kafkaconnector/transforms/SinkPojoToSchemaAndStructTransform.java	31	6	1
public void put() in core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java	29	9	1
protected void executeComponentsReadme() in tooling/camel-kafka-connector-catalog-descriptor-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/catalog/descriptor/CollectConnectorDescriptorMojo.java	29	8	0
public static ConfigDef conf() in connectors/camel-kafka-batch-ssl-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkabatchsslsource/CamelKafkabatchsslsourceSourceConnectorConfig.java	27	1	0
private void updateConnector() in tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/CamelKafkaConnectorUpdateMojo.java	27	5	0
private boolean updateFile() in tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/CamelKafkaConnectorUpdateMojo.java	27	5	2
private void deleteConnector() in tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/CamelKafkaConnectorDeleteMojo.java	27	5	0
private boolean updateFile() in tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/CamelKafkaConnectorKameletUpdateMojo.java	27	5	2
public static ConfigDef conf() in connectors/camel-aws-s3-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3source/CamelAwss3sourceSourceConnectorConfig.java	26	1	0
public static ConfigDef conf() in connectors/camel-kafka-batch-apicurio-registry-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkabatchapicurioregistrysource/CamelKafkabatchapicurioregistrysourceSourceConnectorConfig.java	26	1	0
private void fixAdditionalDependencies() in tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/CamelKafkaConnectorUpdateMojo.java	26	6	2
private Document createBasePom() in tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/CamelKafkaConnectorUpdateMojo.java	26	3	1
private void writeJson() in tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/CamelKafkaConnectorUpdateMojo.java	26	3	8
private Document createBasePom() in tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/CamelKafkaConnectorKameletUpdateMojo.java	26	3	1
private void writeJson() in tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/CamelKafkaConnectorKameletUpdateMojo.java	26	3	8
public static ConfigDef conf() in connectors/camel-pulsar-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/pulsarsource/CamelPulsarsourceSourceConnectorConfig.java	25	1	0
public static ConfigDef conf() in connectors/camel-aws-sqs-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awssqssource/CamelAwssqssourceSourceConnectorConfig.java	25	1	0
public static ConfigDef conf() in connectors/camel-kafka-ssl-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkasslsource/CamelKafkasslsourceSourceConnectorConfig.java	24	1	0
public static void logRecordContent() in core/src/main/java/org/apache/camel/kafkaconnector/utils/TaskHelper.java	24	7	3
public static void writeXmlFormatted() in tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/utils/MavenUtils.java	24	2	3
public static ConfigDef conf() in connectors/camel-aws-s3-streaming-upload-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3streaminguploadsink/CamelAwss3streaminguploadsinkSinkConnectorConfig.java	23	1	0
public static ConfigDef conf() in connectors/camel-pulsar-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/pulsarsink/CamelPulsarsinkSinkConnectorConfig.java	23	1	0
public static ConfigDef conf() in connectors/camel-jdbc-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/jdbc/CamelJdbcSinkConnectorConfig.java	23	1	0
public static ConfigDef conf() in connectors/camel-kafka-batch-azure-schema-registry-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkabatchazureschemaregistrysource/CamelKafkabatchazureschemaregistrysourceSourceConnectorConfig.java	23	1	0
private void initCatalog() in camel-kafka-connector-catalog/src/main/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalog.java	23	8	0