Merge pull request #55991 from Avogar/fix-avro-schema-registry

Fix fetching schema from schema registry in AvroConfluent
This commit is contained in:
Kruglov Pavel 2023-10-30 20:45:46 +01:00 committed by GitHub
commit 58ccabf8b3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -983,8 +983,8 @@ private:
{
try
{
Poco::URI url(base_url, "/schemas/ids/" + std::to_string(id));
LOG_TRACE((&Poco::Logger::get("AvroConfluentRowInputFormat")), "Fetching schema id = {}", id);
Poco::URI url(base_url, base_url.getPath() + "/schemas/ids/" + std::to_string(id));
LOG_TRACE((&Poco::Logger::get("AvroConfluentRowInputFormat")), "Fetching schema id = {} from url {}", id, url.toString());
/// One second for connect/send/receive. Just in case.
ConnectionTimeouts timeouts({1, 0}, {1, 0}, {1, 0});