[jira] [Commented] (KAFKA-6348) Kafka consumer can't restore from coordinator failure

[ https://issues.apache.org/jira/browse/KAFKA-6348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16379922#comment-16379922 ] sikaijian commented on KAFKA-6348: -- I got the same problem. In my case, I use kafka for l

[jira] [Updated] (KAFKA-6597) Issues with Zookeeper and Kafka startup in Windows environment

[ https://issues.apache.org/jira/browse/KAFKA-6597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Dunayevsky updated KAFKA-6597: --- Environment: MS Windows 7 Corporate Edition > Issues with Zookeeper and Kafka startup in Windo

[jira] [Commented] (KAFKA-5828) Allow explicitly setting polling interval for Kafka connectors

[ https://issues.apache.org/jira/browse/KAFKA-5828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16380122#comment-16380122 ] Behrang Saeedzadeh commented on KAFKA-5828: --- Hi I think quotas could have this

[jira] [Commented] (KAFKA-6555) Making state store queryable during restoration

[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16380293#comment-16380293 ] Damian Guy commented on KAFKA-6555: --- I think if we are going to allow stale reads from r

[jira] [Resolved] (KAFKA-6601) Kafka manager does not provide consumer offset producer rate with kafka v2.10-0.10.2.0

[ https://issues.apache.org/jira/browse/KAFKA-6601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sönke Liebau resolved KAFKA-6601. - Resolution: Cannot Reproduce Hi [~raj6329], I've just tested this with kafka_2.10_0.10.2.0 and t

[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

[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-6598) Kafka to support using ETCD beside Zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-6598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16380753#comment-16380753 ] Colin P. McCabe commented on KAFKA-6598: Thanks for looking at this. We're planni

[jira] [Commented] (KAFKA-4936) Allow dynamic routing of output records

[ https://issues.apache.org/jira/browse/KAFKA-4936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16380868#comment-16380868 ] Blake Miller commented on KAFKA-4936: - IMO, such a feature does not need to support au

[jira] [Updated] (KAFKA-6593) Coordinator disconnect in heartbeat thread can cause commitSync to block indefinitely

[ https://issues.apache.org/jira/browse/KAFKA-6593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-6593: --- Priority: Critical (was: Major) > Coordinator disconnect in heartbeat thread can cause commit

[jira] [Commented] (KAFKA-6555) Making state store queryable during restoration

[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16381278#comment-16381278 ] Guozhang Wang commented on KAFKA-6555: -- First of all, as I mentioned before this chan

[jira] [Commented] (KAFKA-6327) IllegalArgumentException in RocksDB when RocksDBException being generated

[ https://issues.apache.org/jira/browse/KAFKA-6327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16381357#comment-16381357 ] Guozhang Wang commented on KAFKA-6327: -- This will be fixed in RocksDB release rocksdb

[jira] [Updated] (KAFKA-6499) Avoid creating dummy checkpoint files with no state stores

[ https://issues.apache.org/jira/browse/KAFKA-6499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6499: --- Fix Version/s: (was: 1.2.0) > Avoid creating dummy checkpoint files with no state stores >

[jira] [Issue Comment Deleted] (KAFKA-6348) Kafka consumer can't restore from coordinator failure

[ https://issues.apache.org/jira/browse/KAFKA-6348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sikaijian updated KAFKA-6348: - Comment: was deleted (was: I got the same problem. In my case, I use kafka for logs. So I killed one  bro

[jira] [Commented] (KAFKA-4936) Allow dynamic routing of output records

[ https://issues.apache.org/jira/browse/KAFKA-4936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16381457#comment-16381457 ] Matthias J. Sax commented on KAFKA-4936: Thanks for you interest in picking this u

[jira] [Updated] (KAFKA-4831) Extract WindowedSerde to public APIs

[ https://issues.apache.org/jira/browse/KAFKA-4831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4831: --- Labels: needs-kip newbie user-experience (was: newbie user-experience) > Extract WindowedSerd

[jira] [Commented] (KAFKA-6054) ERROR "SubscriptionInfo - unable to decode subscription data: version=2" when upgrading from 0.10.0.0 to 0.10.2.1

[ https://issues.apache.org/jira/browse/KAFKA-6054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16381566#comment-16381566 ] ASF GitHub Bot commented on KAFKA-6054: --- mjsax opened a new pull request #4630: KAFK