[ 
https://issues.apache.org/jira/browse/KAFKA-17110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864722#comment-17864722
 ] 

Lianet Magrans commented on KAFKA-17110:
----------------------------------------

Hey [~yangpoan] , thanks for taking on this one! Heads-up in case it helps, 
we've dealt with some KafkaConsumerTests that cannot be applied to the 
AsyncConsumer just because of the way the are written. In those cases, it's 
fair to leave them running for the CLASSIC only, and write a separate test on 
AsyncKafkaConsumerTest to cover the logic (other tests can definitely be 
enabled for both consumers). I had an initial take on this with KAFKA-16737 
(will close that one in favour of this one), it was blocked due to other issues 
at that time and then other priorities came over. Hope it helps!

> Enable valid test case in KafkaConsumerTest for AsyncKafkaConsumer
> ------------------------------------------------------------------
>
>                 Key: KAFKA-17110
>                 URL: https://issues.apache.org/jira/browse/KAFKA-17110
>             Project: Kafka
>          Issue Type: Sub-task
>            Reporter: PoAn Yang
>            Assignee: PoAn Yang
>            Priority: Minor
>
> Enable testResetToCommittedOffset, testResetUsingAutoResetPolicy, 
> testCommitsFetchedDuringAssign, verifyPollTimesOutDuringMetadataUpdate, 
> testFetchStableOffsetThrowInCommitted, testFetchStableOffsetThrowInPosition, 
> testNoCommittedOffsets, testPollThrowsInterruptExceptionIfInterrupted, 
> fetchResponseWithUnexpectedPartitionIsIgnored, 
> testManualAssignmentChangeWithAutoCommitEnabled, 
> testManualAssignmentChangeWithAutoCommitDisabled, 
> testOffsetOfPausedPartitions, and testCloseShouldBeIdempotent for 
> AsyncKafkaConsumer



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to