Skip to content

Implement Kafka consumer pause/resume feature with async processing#103

Open
Smet2133 wants to merge 7 commits into
mainfrom
feat/kafka-consumer-pause-resume
Open

Implement Kafka consumer pause/resume feature with async processing#103
Smet2133 wants to merge 7 commits into
mainfrom
feat/kafka-consumer-pause-resume

feat/kafka-consumer-pause-resume: versions fix

ecd93c7
Select commit
Loading
Failed to load commit list.
SonarQubeCloud / SonarCloud Code Analysis failed Jun 12, 2026 in 1m 1s

Quality Gate failed

Failed conditions
79.3% Coverage on New Code (required ≥ 80%)

See analysis details on SonarQube Cloud

Annotations

Check warning on line 232 in maas-declarative-client-commons/maas-kafka-client/src/main/java/com/netcracker/maas/declarative/kafka/client/impl/client/consumer/executor/MaasConsumingExecutor.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace generic exceptions with specific library exceptions or a custom exception. 

See more on https://sonarcloud.io/project/issues?id=Netcracker_qubership-core-java-libs&issues=AZ67ueV1A0wdehgM85Dy&open=AZ67ueV1A0wdehgM85Dy&pullRequest=103

Check warning on line 254 in maas-declarative-client-commons/maas-kafka-client/src/main/java/com/netcracker/maas/declarative/kafka/client/impl/client/consumer/executor/MaasConsumingExecutor.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Rename this variable to not match a restricted identifier. 

See more on https://sonarcloud.io/project/issues?id=Netcracker_qubership-core-java-libs&issues=AZ67ueV1A0wdehgM85D5&open=AZ67ueV1A0wdehgM85D5&pullRequest=103

Check warning on line 446 in maas-declarative-client-commons/maas-kafka-client/src/test/java/com/netcracker/maas/declarative/kafka/client/impl/client/consumer/executor/MaasConsumingExecutorTest.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

This block of commented-out lines of code should be removed. 

See more on https://sonarcloud.io/project/issues?id=Netcracker_qubership-core-java-libs&issues=AZ67ueStA0wdehgM85Ds&open=AZ67ueStA0wdehgM85Ds&pullRequest=103

Check failure on line 163 in maas-declarative-client-commons/maas-kafka-client/src/main/java/com/netcracker/maas/declarative/kafka/client/impl/client/consumer/executor/MaasConsumingExecutor.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Refactor this method to reduce its Cognitive Complexity from 35 to the 15 allowed. 

See more on https://sonarcloud.io/project/issues?id=Netcracker_qubership-core-java-libs&issues=AZ67ueV1A0wdehgM85D2&open=AZ67ueV1A0wdehgM85D2&pullRequest=103

Check warning on line 163 in maas-declarative-client-commons/maas-kafka-client/src/main/java/com/netcracker/maas/declarative/kafka/client/impl/client/consumer/executor/MaasConsumingExecutor.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace generic exceptions with specific library exceptions or a custom exception. 

See more on https://sonarcloud.io/project/issues?id=Netcracker_qubership-core-java-libs&issues=AZ67ueV1A0wdehgM85Dz&open=AZ67ueV1A0wdehgM85Dz&pullRequest=103

Check warning on line 246 in maas-declarative-client-commons/maas-kafka-client/src/main/java/com/netcracker/maas/declarative/kafka/client/impl/client/consumer/executor/MaasConsumingExecutor.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Reduce the total number of break and continue statements in this loop to use at most one. 

See more on https://sonarcloud.io/project/issues?id=Netcracker_qubership-core-java-libs&issues=AZ67ueV1A0wdehgM85D0&open=AZ67ueV1A0wdehgM85D0&pullRequest=103

Check warning on line 262 in maas-declarative-client-commons/maas-kafka-client/src/test/java/com/netcracker/maas/declarative/kafka/client/api/MaasKafkaClientTest.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Rename this variable to not match a restricted identifier. 

See more on https://sonarcloud.io/project/issues?id=Netcracker_qubership-core-java-libs&issues=AZ67ueVgA0wdehgM85Du&open=AZ67ueVgA0wdehgM85Du&pullRequest=103

Check warning on line 274 in maas-declarative-client-commons/maas-kafka-client/src/main/java/com/netcracker/maas/declarative/kafka/client/impl/client/consumer/executor/MaasConsumingExecutor.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Extract this nested try block into a separate method. 

See more on https://sonarcloud.io/project/issues?id=Netcracker_qubership-core-java-libs&issues=AZ67ueV1A0wdehgM85Dx&open=AZ67ueV1A0wdehgM85Dx&pullRequest=103

Check warning on line 476 in maas-declarative-client-commons/maas-kafka-client/src/test/java/com/netcracker/maas/declarative/kafka/client/impl/client/consumer/executor/MaasConsumingExecutorTest.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Remove this use of "Thread.sleep()". 

See more on https://sonarcloud.io/project/issues?id=Netcracker_qubership-core-java-libs&issues=AZ67ueStA0wdehgM85Dt&open=AZ67ueStA0wdehgM85Dt&pullRequest=103

Check warning on line 216 in maas-declarative-client-commons/maas-kafka-client/src/main/java/com/netcracker/maas/declarative/kafka/client/impl/client/consumer/executor/MaasConsumingExecutor.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Rename this variable to not match a restricted identifier. 

See more on https://sonarcloud.io/project/issues?id=Netcracker_qubership-core-java-libs&issues=AZ67ueV1A0wdehgM85D3&open=AZ67ueV1A0wdehgM85D3&pullRequest=103

Check failure on line 244 in maas-declarative-client-commons/maas-kafka-client/src/main/java/com/netcracker/maas/declarative/kafka/client/impl/client/consumer/executor/MaasConsumingExecutor.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Refactor this method to reduce its Cognitive Complexity from 19 to the 15 allowed. 

See more on https://sonarcloud.io/project/issues?id=Netcracker_qubership-core-java-libs&issues=AZ67ueV1A0wdehgM85D4&open=AZ67ueV1A0wdehgM85D4&pullRequest=103

Check warning on line 469 in maas-declarative-client-commons/maas-kafka-client/src/test/java/com/netcracker/maas/declarative/kafka/client/api/MaasKafkaClientTest.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Remove this use of "Thread.sleep()". 

See more on https://sonarcloud.io/project/issues?id=Netcracker_qubership-core-java-libs&issues=AZ67ueVgA0wdehgM85Dv&open=AZ67ueVgA0wdehgM85Dv&pullRequest=103

Check warning on line 346 in maas-declarative-client-commons/maas-kafka-client/src/test/java/com/netcracker/maas/declarative/kafka/client/impl/client/consumer/executor/MaasConsumingExecutorTest.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

This block of commented-out lines of code should be removed. 

See more on https://sonarcloud.io/project/issues?id=Netcracker_qubership-core-java-libs&issues=AZ67ueStA0wdehgM85Dr&open=AZ67ueStA0wdehgM85Dr&pullRequest=103

Check warning on line 76 in maas-declarative-client-commons/maas-kafka-client/src/main/java/com/netcracker/maas/declarative/kafka/client/impl/client/consumer/executor/MaasConsumingExecutor.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

This block of commented-out lines of code should be removed. 

See more on https://sonarcloud.io/project/issues?id=Netcracker_qubership-core-java-libs&issues=AZ67ueV1A0wdehgM85D1&open=AZ67ueV1A0wdehgM85D1&pullRequest=103

Check warning on line 260 in maas-declarative-client-commons/maas-kafka-client/src/main/java/com/netcracker/maas/declarative/kafka/client/impl/client/consumer/executor/MaasConsumingExecutor.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Extract this nested try block into a separate method. 

See more on https://sonarcloud.io/project/issues?id=Netcracker_qubership-core-java-libs&issues=AZ67ueV1A0wdehgM85Dw&open=AZ67ueV1A0wdehgM85Dw&pullRequest=103
View more details on SonarQubeCloud