Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

GH-2978: Propagate number of partitions to KRaft broker #2983

Merged
merged 1 commit into from
Jan 17, 2024

Commits on Jan 11, 2024

  1. spring-projectsGH-2978: Propagate number of partitions to KRaft broker

    Fixes: spring-projects#2978
    
    If we don't create topics manually, that can be done automatically on the broker side
    according to its configuration.
    
    For that goal the `EmbeddedKafkaKraftBroker` is missing to populate
    `KafkaConfig.NumPartitionsProp(): "" + this.partitionsPerTopic` broker property from
    `@EmbeddedKafka` configuration
    
    * Propagate `partitionsPerTopic` option down to the embedded broker(s) in the `EmbeddedKafkaKraftBroker`
    * Some other simple refactoring in the `EmbeddedKafkaKraftBroker`
    * Verify the option propagated via new unit test in the `KafkaTestUtilsTests.topicAutomaticallyCreatedWithProperNumberOfPartitions()`
    artembilan committed Jan 11, 2024
    Configuration menu
    Copy the full SHA
    03b3f7c View commit details
    Browse the repository at this point in the history