Skip to content

Fix consumer group response handling in topic procedures - #19047

Merged
JackieTien97 merged 1 commit into
masterfrom
fix/topic-consumer-group-response-statuses
Oct 29, 2026
Merged

Fix consumer group response handling in topic procedures#19047
JackieTien97 merged 1 commit into
masterfrom
fix/topic-consumer-group-response-statuses

Fix consumer group response handling in topic procedures

b7d3010
Select commit
Loading
Failed to load commit list.
SonarQubeCloud / SonarCloud Code Analysis failed Oct 29, 2026 in 4m 7s

Quality Gate failed

Failed conditions
C Security Rating on New Code (required ≥ A)
E Reliability Rating on New Code (required ≥ A)

See analysis details on SonarQube Cloud

Catch issues before they fail your Quality Gate with our IDE extension SonarQube for IDE

Annotations

Check warning on line 251 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/memory/MemoryPool.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

'method call' child has incorrect indentation level 14, expected level should be 16. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGFuZ4pRKC_2iiivery&open=AaGFuZ4pRKC_2iiivery&pullRequest=19047

Check warning on line 913 in iotdb-client/subscription/src/main/java/org/apache/iotdb/session/subscription/consumer/base/AbstractSubscriptionProvider.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Override the "equals" method in this class. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGFudVqRKC_2iiiveth&open=AaGFudVqRKC_2iiiveth&pullRequest=19047

Check warning on line 506 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/table/DataNodeTableCache.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 117). 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGFuaswRKC_2iiivesZ&open=AaGFuaswRKC_2iiivesZ&pullRequest=19047

Check warning on line 424 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/DataNodeMemoryConfig.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Distance between variable 'timePartitionInfoMemorySize' declaration and its first usage is 4, but allowed 3. Consider making that variable final if you still need to store its value in advance (before method calls that might have side effects on the original value). 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGFubWsRKC_2iiivesn&open=AaGFubWsRKC_2iiivesn&pullRequest=19047

Check warning on line 54 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/io/WALFormats.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Use concise character class syntax '\\d' instead of '[0-9]'. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGFuX4QRKC_2iiivequ&open=AaGFuX4QRKC_2iiivequ&pullRequest=19047

Check warning on line 1007 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/TableConfigTaskVisitor.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Expected @throws tag for 'SemanticException'. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGFuY4ZRKC_2iiiverU&open=AaGFuY4ZRKC_2iiiverU&pullRequest=19047

Check warning on line 666 in iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/relational/IoTDBRelationalDatabaseMetadata.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Refactor the code in order to not assign to this loop counter from within the loop body. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGFud2XRKC_2iiivet5&open=AaGFud2XRKC_2iiivet5&pullRequest=19047

Check warning on line 39 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/SharedExchangeBudgetEligibility.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

'}' at column 46 should be alone on a line. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGFuZUQRKC_2iiiverh&open=AaGFuZUQRKC_2iiiverh&pullRequest=19047

Check failure on line 63 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/subscription/SubscriptionReadyDataNodeTracker.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

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

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGFucldRKC_2iiivetI&open=AaGFucldRKC_2iiivetI&pullRequest=19047

Check warning on line 241 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ProcedureManager.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Make this private field "final", it is never reassigned. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGFucrnRKC_2iiivetO&open=AaGFucrnRKC_2iiivetO&pullRequest=19047

Check warning on line 503 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/table/DataNodeTableCache.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Merge the previous cases into this one using comma-separated label. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGFuaswRKC_2iiivesX&open=AaGFuaswRKC_2iiivesX&pullRequest=19047

Check warning on line 391 in iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBTablePreparedStatement.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Expected @throws tag for 'SQLException'. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGFudpORKC_2iiivetw&open=AaGFudpORKC_2iiivetw&pullRequest=19047

Check warning on line 140 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/chunk/DiskAlignedChunkLoader.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Catch Exception instead of Error. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGFuYDDRKC_2iiiveq7&open=AaGFuYDDRKC_2iiiveq7&pullRequest=19047

Check warning on line 249 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/memory/MemoryPool.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

'method call' child has incorrect indentation level 10, expected level should be 14. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGFuZ4pRKC_2iiiverw&open=AaGFuZ4pRKC_2iiiverw&pullRequest=19047

Check warning on line 1209 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Remove the "new String[]" prefix; the declaration already specifies the array type. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGFubdsRKC_2iiivesw&open=AaGFubdsRKC_2iiivesw&pullRequest=19047

Check warning on line 84 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/splitter/TsFileSplitter.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Make this private field "final", it is never reassigned. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGFuYimRKC_2iiiverL&open=AaGFuYimRKC_2iiiverL&pullRequest=19047

Check warning on line 1650 in iotdb-client/subscription/src/main/java/org/apache/iotdb/session/subscription/consumer/base/AbstractSubscriptionConsumer.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this instanceof check and cast with 'instanceof CommitException commitexception' 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGFudQaRKC_2iiivetd&open=AaGFudQaRKC_2iiivetd&pullRequest=19047

Check warning on line 273 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/utils/WALFileUtils.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Remove the "new long[]" prefix; the declaration already specifies the array type. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGFuX9lRKC_2iiiveq4&open=AaGFuX9lRKC_2iiiveq4&pullRequest=19047

Check warning on line 348 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/table/TreeToTableViewCache.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Single-line Javadoc comment should be multi-line. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGFuao5RKC_2iiivesP&open=AaGFuao5RKC_2iiivesP&pullRequest=19047

Check warning on line 105 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/io/WALReader.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Expected @throws tag for 'IllegalStateException'. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGFuXrRRKC_2iiiveqW&open=AaGFuXrRRKC_2iiiveqW&pullRequest=19047

Check warning on line 19 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/io/WALFormats.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

'package' should be separated from previous line. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGFuX4QRKC_2iiiveqw&open=AaGFuX4QRKC_2iiiveqw&pullRequest=19047

Check warning on line 550 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/ConsensusSubscriptionBroker.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this "Collections.sort()" with "List.sort()". 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGFubBARKC_2iiivesk&open=AaGFubBARKC_2iiivesk&pullRequest=19047

Check warning on line 888 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Make this private field "final", it is never reassigned. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGFubdsRKC_2iiivest&open=AaGFubdsRKC_2iiivest&pullRequest=19047

Check failure on line 466 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/splitter/AlignedChunkData.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Use try-with-resources or close this "ByteBufferOutputStream" in a "finally" clause. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGFuYpiRKC_2iiiverN&open=AaGFuYpiRKC_2iiiverN&pullRequest=19047

Check failure on line 292 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/LocalExecutionPlanContext.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

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

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGFuZW6RKC_2iiiverk&open=AaGFuZW6RKC_2iiiverk&pullRequest=19047
View more details on SonarQubeCloud