[ https://issues.apache.org/jira/browse/KAFKA-15081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jun Rao resolved KAFKA-15081. ----------------------------- Fix Version/s: 3.7.0 Resolution: Fixed merged the PR to trunk > Implement new consumer offsetsForTimes > -------------------------------------- > > Key: KAFKA-15081 > URL: https://issues.apache.org/jira/browse/KAFKA-15081 > Project: Kafka > Issue Type: Task > Components: clients, consumer > Reporter: Lianet Magrans > Assignee: Lianet Magrans > Priority: Major > Labels: consumer-threading-refactor > Fix For: 3.7.0 > > > Implement offsetForTimes for the kafka consumer based on the new threading > model, using the OffsetsRequestManager. No changes at the consumer API level. > A call to the offsetsForTime consumer functionality should generate a > ListOffsetsApplicationEvent with the timestamps to search provided in > parameters. The ListOffsetsApplicationEvent is then handled by the > OffsetsRequestManager, that builds the ListOffsets requests and processes the > response when received. -- This message was sent by Atlassian Jira (v8.20.10#820010)