We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 286557a commit c9ea749Copy full SHA for c9ea749
1 file changed
broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRocksdbStore.java
@@ -164,8 +164,8 @@ protected void preShutdown() {
164
if (this.deleteOptions != null) {
165
this.deleteOptions.close();
166
}
167
- if (this.defaultCFHandle != null) {
168
- this.defaultCFHandle.close();
+ if (this.columnFamilyHandle != null) {
+ this.columnFamilyHandle.close();
169
170
171
0 commit comments