Skip to content

Replace all occurences broker.id in Strimzi*Container/Cluster classes with node.id #167

@see-quick

Description

@see-quick

We should update all parts in the code where we still have broker.id, f.e.,

 StrimziKafkaContainer brokerContainer = new StrimziKafkaContainer()
                    .withBrokerId(brokerId)
                    .withKafkaConfigurationMap(kafkaConfiguration)
                    .withNetwork(this.network)
                    .withProxyContainer(proxyContainer)
                    .withKafkaVersion(kafkaVersion == null ? KafkaVersionService.getInstance().latestRelease().getVersion() : kafkaVersion)
                    .withNodeId(brokerId)
                    .withClusterId(this.clusterId)
                    .withNodeRole(KafkaNodeRole.BROKER)
                    .waitForRunning();

with just using .withNodeId(nodeId). Also, remove a few checks in the StrimziKafkaContainer related to that specific variable.

Metadata

Metadata

Assignees

No one assigned

    Type

    No type

    Projects

    No projects

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions