apache / sling-org-apache-sling-distribution-journal-kafkaConditional Complexity

Intro

Conditional complexity (also called cyclomatic complexity) is a term used to measure the complexity of software. The term refers to the number of possible paths through a program function. A higher value ofter means higher maintenance and testing costs (infosecinstitute.com).
Conditional complexity is calculated by counting all conditions in the program that can affect the execution path (e.g. if statement, loops, switches, and/or operators, try and catch blocks...).
Conditional complexity is measured at the unit level (methods, functions...).
Units are classified in four categories based on the measured McCabe index: 1-5 (simple units), 6-10 (medium complex units), 11-25 (complex units), 26+ (very complex units).

Learn more...

Conditional Complexity Overall

There are 42 units with 271 lines of code in units (55.3% of code).

0 very complex units (0 lines of code)
0 complex units (0 lines of code)
0 medium complex units (0 lines of code)
0 simple units (0 lines of code)
42 very simple units (271 lines of code)

Legend:

51+

26-50

11-25

6-10

1-5

Alternative Visuals

3D view of all units

Conditional Complexity per Extension

51+

26-50

11-25

6-10

1-5

Conditional Complexity per Logical Component

primary logical decomposition

51+

26-50

11-25

6-10

1-5

Most Complex Units

Top 42 most complex units

Unit	# lines	McCabe index	# params
public void run() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaPoller.java	17	4	0
public Closeable createPoller() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaClientProvider.java	17	3	4
public void assertTopic() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaClientProvider.java	11	3	1
private void closeQuietly() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaClientProvider.java	8	3	1
long getOffset() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaClientProvider.java	10	3	2
public void handle() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaPoller.java	13	3	1
public KafkaClientProvider() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaClientProvider.java	18	2	2
private Map getOffsets() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaClientProvider.java	7	2	3
private synchronized KafkaProducer buildJsonKafkaProducer() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaClientProvider.java	6	2	0
private String getMessageType() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaPoller.java	8	2	1
private void sleepAfterError() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaPoller.java	7	2	0
public void send() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaJsonMessageSender.java	15	2	2
public CLSwitch() in src/main/java/org/apache/sling/distribution/journal/kafka/CLSwitch.java	4	1	1
public void close() in src/main/java/org/apache/sling/distribution/journal/kafka/CLSwitch.java	3	1	0
public KafkaMessageInfo() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaMessageInfo.java	3	1	1
public KafkaMessageInfo() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaMessageInfo.java	7	1	2
public String getTopic() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaMessageInfo.java	3	1	0
public int getPartition() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaMessageInfo.java	3	1	0
public long getOffset() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaMessageInfo.java	3	1	0
public long getCreateTime() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaMessageInfo.java	3	1	0
public Map getProps() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaMessageInfo.java	3	1	0
public String toString() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaMessageInfo.java	4	1	0
public JsonRecordHandler() in src/main/java/org/apache/sling/distribution/journal/kafka/JsonRecordHandler.java	4	1	2
public void accept() in src/main/java/org/apache/sling/distribution/journal/kafka/JsonRecordHandler.java	6	1	1
public synchronized void close() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaClientProvider.java	3	1	0
public MessageSender createSender() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaClientProvider.java	3	1	1
public long retrieveOffset() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaClientProvider.java	7	1	2
public String assignTo() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaClientProvider.java	3	1	1
public String assignTo() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaClientProvider.java	3	1	2
protected KafkaConsumer createConsumer() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaClientProvider.java	6	1	2
private Map consumerConfig() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaClientProvider.java	10	1	3
private Map producerConfig() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaClientProvider.java	8	1	1
private Map commonConfig() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaClientProvider.java	8	1	0
public URI getServerUri() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaClientProvider.java	3	1	0
public KafkaPoller() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaPoller.java	8	1	3
private String typeName() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaPoller.java	3	1	1
JsonRecordHandler toHandler() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaPoller.java	4	1	1
public void close() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaPoller.java	5	1	0
public KafkaJsonMessageSender() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaJsonMessageSender.java	5	1	3
public void send() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaJsonMessageSender.java	3	1	1
private Header toHeader() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaJsonMessageSender.java	3	1	1
private RecordHeader header() in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaJsonMessageSender.java	3	1	2