Skip to content

Commit 6c65f51

Browse files
authored
[ISSUE #808] register broker data version null (#809)
1 parent d1d82ac commit 6c65f51

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

rocketmq-namesrv/src/route/route_info_manager.rs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -251,10 +251,11 @@ impl RouteInfoManager {
251251
}
252252
}
253253
}
254+
let default_data_version = DataVersion::default();
254255
let data_version = topic_config_serialize_wrapper
255256
.data_version()
256257
.as_ref()
257-
.unwrap();
258+
.unwrap_or(&default_data_version);
258259
for topic_config in tc_table.values() {
259260
let mut config = topic_config.clone();
260261
if (register_first

0 commit comments

Comments
 (0)