[jira] [Commented] (KAFKA-7748) Add wall clock TimeDefinition for suppression of intermediate events

[ https://issues.apache.org/jira/browse/KAFKA-7748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17322023#comment-17322023 ] Andrey Bratus commented on KAFKA-7748: -- Hi [~cosbor11], for a simple use case I wor

[jira] [Comment Edited] (KAFKA-4632) Kafka Connect WorkerSinkTask.closePartitions doesn't handle WakeupException

[ https://issues.apache.org/jira/browse/KAFKA-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16380686#comment-16380686 ] Andrey Bratus edited comment on KAFKA-4632 at 2/28/18 5:17 PM: -

[jira] [Commented] (KAFKA-4632) Kafka Connect WorkerSinkTask.closePartitions doesn't handle WakeupException

[ https://issues.apache.org/jira/browse/KAFKA-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16380686#comment-16380686 ] Andrey Bratus commented on KAFKA-4632: -- I am experiencing a similar issue, when pausi