MINOR: Modify the Exception type of the testCommitOffsetAsyncNotCoordinator method
Reviewers: David Jacot
@@ -2121,7 +2121,7 @@ public abstract class ConsumerCoordinatorTest {
// async commit with not coordinator
MockCommitCallback cb = new MockCommitCallback();
- prepareOffsetCommitRequest(singletonMap(t1p, 100L), Errors.COORDINATOR_NOT_AVAILABLE);
+ prepareOffsetCommitRequest(singletonMap(t1p, 100L), Errors.NOT_COORDINATOR);
coordinator.commitOffsetsAsync(singletonMap(t1p, new OffsetAndMetadata(100L)), cb);
coordinator.invokeCompletedOffsetCommitCallbacks();
