[jira] [Commented] (KAFKA-16664) Re-add EventAccumulator.take(timeout)

[Jeff Kim (Jira)]

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

Jeff Kim commented on KAFKA-16664:
--

[~phong260702] The removal was in a separate commit: 
[https://github.com/apache/kafka/commits/52289c92be45ba3758d07376d9c64ddadbecb544]



Opened PR [https://github.com/apache/kafka/pull/16144] to re-add this back.

> Re-add EventAccumulator.take(timeout)
> -
>
> Key: KAFKA-16664
> URL: https://issues.apache.org/jira/browse/KAFKA-16664
> Project: Kafka
>  Issue Type: Sub-task
>Reporter: Jeff Kim
>Assignee: Jeff Kim
>Priority: Major
>
> [https://github.com/apache/kafka/pull/15835] should be used with a timeout in 
> EventAccumulator#take. We added a commit to remove the timeout, we should 
> revert it



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

[jira] [Commented] (KAFKA-16664) Re-add EventAccumulator.take(timeout)

[Quoc Phong Dang (Jira)]

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

Quoc Phong Dang commented on KAFKA-16664:
-

Is this issue already fixed? I did not see any removal in the commit.

> Re-add EventAccumulator.take(timeout)
> -
>
> Key: KAFKA-16664
> URL: https://issues.apache.org/jira/browse/KAFKA-16664
> Project: Kafka
>  Issue Type: Sub-task
>Reporter: Jeff Kim
>Priority: Major
>
> [https://github.com/apache/kafka/pull/15835] should be used with a timeout in 
> EventAccumulator#take. We added a commit to remove the timeout, we should 
> revert it



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