junaiddshaukat opened a new pull request, #39211:
URL: https://github.com/apache/beam/pull/39211
## Summary
First part of the testing-infra sub-issue (#39192): a reusable
`KafkaStreamsTestRunner` that removes the translate + drive boilerplate every
test repeated, and is the foundation for Create support and the first
`@ValidatesRunner` tests (the next two parts).
- `run(Pipeline)` translates + drives through a `TopologyTestDriver`, and
auto-discovers internal repartition topics (both a sink and a source, via
`TopologyDescription`) and round-trips them to quiescence — generalising
the
manual repartition loop `GroupByKeyTest` used to do by hand.
- `translate()` / `streamsConfig()` / `leafProcessorName()` for tests that
need
the `Topology` (to attach a capture processor before driving).
- `testOptions()` for the EMBEDDED harness + a unique app id.
Migrates 4 tests onto it; `ChainedExecutableStageTest` keeps its explicit
translate because it asserts on the prepared proto's ExecutableStage count.
## Testing
Test-only change, no runner behaviour change. `:check` green, 36 tests.
Refs #39192
cc @je-ik
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
