Chia-Ping Tsai created KAFKA-18181: -------------------------------------- Summary: Refactor ShareConsumerTest Key: KAFKA-18181 URL: https://issues.apache.org/jira/browse/KAFKA-18181 Project: Kafka Issue Type: Improvement Reporter: Chia-Ping Tsai Assignee: Chia-Ping Tsai
1. `consumeMessages` should return `messagesConsumed` instead of wrapping it in `CompletableFuture` 2. replace `fail` by `assertDoesNotThrow` or just throw exception 3. `produceMessages`should return `messagesConsumed` instead of wrapping it in `CompletableFuture` 4. use `CompletableFuture.runAsync()` instead of ExecutorService. We don't use the interrupt so it is fine to use default executor -- This message was sent by Atlassian Jira (v8.20.10#820010)