lianetm commented on code in PR #16638:
URL: https://github.com/apache/kafka/pull/16638#discussion_r1686689029
##########
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java:
##########
@@ -2093,14 +2093,27 @@ public void
testEndOffsetsAuthenticationFailure(GroupProtocol groupProtocol) {
assertThrows(AuthenticationException.class, () ->
consumer.endOffsets(Collections.singleton(tp0)));
}
- // TODO: this test requires rebalance logic which is not yet implemented
in the CONSUMER group protocol.
- // Once it is implemented, this should use both group protocols.
@ParameterizedTest
- @EnumSource(value = GroupProtocol.class, names = "CLASSIC")
- public void testPollAuthenticationFailure(GroupProtocol groupProtocol) {
+ @EnumSource(GroupProtocol.class)
+ public void testPollAuthenticationFailure(GroupProtocol groupProtocol)
throws InterruptedException {
final KafkaConsumer<String, String> consumer =
consumerWithPendingAuthenticationError(groupProtocol);
consumer.subscribe(singleton(topic));
- assertThrows(AuthenticationException.class, () ->
consumer.poll(Duration.ZERO));
+
+ if (isAyncConsumer(groupProtocol)) {
+ // New consumer poll(ZERO) needs to wait for the event added by a
call to poll, to be processed
+ // by the background thread, so it can realize there is
authentication fail and then
+ // throw the AuthenticationException
+ TestUtils.waitForCondition(() -> {
+ try {
+ consumer.poll(Duration.ZERO);
+ return false;
+ } catch (AuthenticationException e) {
+ return true;
+ }
+ }, "Consumer was not able to update fetch positions on continuous
calls with 0 timeout");
Review Comment:
the message should be a bit different in this case I would say. Even though
it's all called from the `updateFechPositions`, the situation here is that we
need to allow for the authentication exception (that is discovered in the
background, when polling the
`networkClientDelegate.maybePropagateMetadataError`), to appear in the app
thread as an ErrorEvent (so that the AuthenticationException can be thrown on
poll `processBackgroundEvents`). So maybe something like _Consumer was not able
to discover metadata errors on continuous..._?
--
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]
