We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a3e3338 commit c5b4931Copy full SHA for c5b4931
flex/engines/graph_db/database/wal/kafka_wal_utils.cc
@@ -71,8 +71,8 @@ std::optional<std::vector<char>> parse_uri(const std::string& wal_uri) {
71
topic = query.substr(0, top_pos);
72
query = query.substr(top_pos + 1);
73
} else {
74
- LOG(ERROR) << "Invalid uri: " << wal_uri;
75
- return std::nullopt;
+ topic = query;
+ query = "";
76
}
77
encoder.put_string(std::string("topic_name"));
78
encoder.put_string(topic);
0 commit comments