Skip to content

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

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

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

Merge branch 'main' into feat/kafka-consumer-pause-resume

fa27d6f
Select commit
Loading
Failed to load commit list.
SonarQubeCloud / SonarCloud Code Analysis succeeded Jun 19, 2026 in 1m 1s

Quality Gate passed

Issues
16 New issues
0 Accepted issues

Measures
0 Security Hotspots
86.2% Coverage on New Code
0.0% Duplication on New Code

See analysis details on SonarQube Cloud

Annotations

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 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 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 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 345 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 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 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 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

Check warning on line 486 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 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 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 535 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

Rename this variable to not match a restricted identifier. 

See more on https://sonarcloud.io/project/issues?id=Netcracker_qubership-core-java-libs&issues=AZ7egAsMudfsJkkUFX6j&open=AZ7egAsMudfsJkkUFX6j&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 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 456 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 warning on line 33 in maas-declarative-client-quarkus/maas-kafka-quarkus-client/runtime/src/test/java/com/netcracker/maas/declarative/kafka/quarkus/client/ConfigUtilsTest.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Remove this and every subsequent useless "eq(...)" invocation; pass the values directly. 

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