Skip to content

Commit

Permalink
Merge pull request #5412 from dlex/5222_consumer-offsets-topic-defaul…
Browse files Browse the repository at this point in the history
…t-partitioning

Default partitions count for `__consumer_offsets` topic increased
  • Loading branch information
dlex committed Jul 14, 2022
2 parents fe0db14 + 20c701a commit 96e2b6b
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 2 deletions.
2 changes: 1 addition & 1 deletion src/v/config/configuration.cc
Original file line number Diff line number Diff line change
Expand Up @@ -474,7 +474,7 @@ configuration::configuration()
"group_topic_partitions",
"Number of partitions in the internal group membership topic",
{.needs_restart = needs_restart::no, .visibility = visibility::tunable},
1)
16)
, default_topic_replication(
*this,
"default_topic_replications",
Expand Down
6 changes: 5 additions & 1 deletion tests/rptest/tests/group_membership_test.py
Original file line number Diff line number Diff line change
Expand Up @@ -127,7 +127,8 @@ def __init__(self, ctx, *args, **kwargs):

# Require internal_kafka topic to have an increased replication factor
extra_rp_conf = dict(default_topic_replications=3,
enable_leader_balancer=False)
enable_leader_balancer=False,
group_topic_partitions=1)
super(GroupMetricsTest, self).__init__(test_context=ctx,
num_brokers=3,
extra_rp_conf=extra_rp_conf)
Expand Down Expand Up @@ -374,6 +375,9 @@ def select_next_leader():
timeout_sec=30,
backoff_sec=5)

self.logger.debug(
f"Waiting for metrics from the single node: {new_leader.account.hostname}"
)
wait_until(lambda: metrics_from_single_node(new_leader),
timeout_sec=30,
backoff_sec=5)
Expand Down

0 comments on commit 96e2b6b

Please sign in to comment.