Details
-
Test
-
Status: Closed
-
Major
-
Resolution: Not A Problem
-
None
Description
This task involves removing the temporary `PlaintextAsyncConsumer` file containing duplicated integration tests for the new consumer. The copy was generated to catch regressions and validate functionality in the new consumer while in development. It should be deleted when the new consumer is fully implemented and the existing integration tests (`PlaintextConsumerTest`) can be executed for both implementations.
Context:
For the current KafkaConsumer, a set of integration tests exist in the file PlaintextConsumerTest. Those tests cannot be executed as such for the new consumer implementation for 2 main reasons
- the new consumer is being developed as a new PrototypeAsyncConsumer class, in parallel to the existing KafkaConsumer.
- the new consumer is under development, so it does not support all the consumer functionality yet.
In order to be able to run the subsets of tests that the new consumer supports while the implementation completes, it was decided to :
- to make a copy of the `PlaintextAsyncConsumer` class, named PlaintextAsyncConsumer. - leave all the existing integration tests that cover the simple consumer case unchanged, and disable the tests that are not yet supported by the new consumer. Disabled tests will be enabled as the async consumer
evolves.
Attachments
Issue Links
- is part of
-
KAFKA-14246 Update threading model for Consumer
- Resolved