Skip to content

Commit

Permalink
Merge pull request #7561 from vbotbuildovich/backport-fixes-to-v22.1.…
Browse files Browse the repository at this point in the history
…x-345

[v22.1.x] schema_registry: Explicitly set _schemas topic to retain forever.
  • Loading branch information
BenPope committed Nov 30, 2022
2 parents 952b414 + 08a9a72 commit b69df77
Showing 1 changed file with 6 additions and 1 deletion.
7 changes: 6 additions & 1 deletion src/v/pandaproxy/schema_registry/service.cc
Original file line number Diff line number Diff line change
Expand Up @@ -162,6 +162,7 @@ ss::future<> service::create_internal_topic() {
replication_factor);

auto make_internal_topic = [replication_factor]() {
constexpr std::string_view retain_forever = "-1";
return kafka::creatable_topic{
.name{model::schema_registry_internal_tp.topic},
.num_partitions = 1,
Expand All @@ -171,7 +172,11 @@ ss::future<> service::create_internal_topic() {
{.name{ss::sstring{kafka::topic_property_cleanup_policy}},
.value{"compact"}},
{.name{ss::sstring{kafka::topic_property_compression}},
.value{ssx::sformat("{}", model::compression::none)}}}};
.value{ssx::sformat("{}", model::compression::none)}},
{.name{ss::sstring{kafka::topic_property_retention_bytes}},
.value{retain_forever}},
{.name{ss::sstring{kafka::topic_property_retention_duration}},
.value{retain_forever}}}};
};
auto res = co_await _client.local().create_topic(make_internal_topic());
if (res.data.topics.size() != 1) {
Expand Down

0 comments on commit b69df77

Please sign in to comment.