Skip to content

EmbeddedKafka.partitions() is ignored in EmbeddedKafkaCondition #1563

@doffid

Description

@doffid

Affects Version(s): 2.5.5.RELEASE

🐞 Bug report

When using @EmbeddedKafka annotation in a plain junit 5 test (w.o. spring-test) the partitions() attribute of the annotation is igonred, and always defaults to 2.
The problem seems in EmbeddedKafkaCondition.createBroker() where embedded.partitions() is not passed to the constructor of EmbeddedKafkaBroker

Metadata

Metadata

Assignees

Type

No type

Projects

No projects

Milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions