[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

2018-02-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16381566#comment-16381566 ] ASF GitHub Bot commented on KAFKA-6054: --- mjsax opened a new pull request #4630: KAFKA-6054: Code

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

2018-02-28 Thread Matthias J. Sax (JIRA)
[ 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

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

2018-02-28 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16381457#comment-16381457 ] Matthias J. Sax commented on KAFKA-4936: Thanks for you interest in picking this up. If we

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

2018-02-28 Thread sikaijian (JIRA)
[ 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 

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

2018-02-28 Thread Matthias J. Sax (JIRA)
[ 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] [Commented] (KAFKA-6327) IllegalArgumentException in RocksDB when RocksDBException being generated

2018-02-28 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16381357#comment-16381357 ] Guozhang Wang commented on KAFKA-6327: -- This will be fixed in RocksDB release rocksdb-5.9.2 and

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

2018-02-28 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16381278#comment-16381278 ] Guozhang Wang commented on KAFKA-6555: -- First of all, as I mentioned before this change itself

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

2018-02-28 Thread Jason Gustafson (JIRA)
[ 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

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

2018-02-28 Thread Blake Miller (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16380868#comment-16380868 ] Blake Miller commented on KAFKA-4936: - IMO, such a feature does not need to support automatic topic

[jira] [Commented] (KAFKA-6598) Kafka to support using ETCD beside Zookeeper

2018-02-28 Thread Colin P. McCabe (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16380753#comment-16380753 ] Colin P. McCabe commented on KAFKA-6598: Thanks for looking at this. We're planning on removing

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

2018-02-28 Thread Andrey Bratus (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16380686#comment-16380686 ] Andrey Bratus edited comment on KAFKA-4632 at 2/28/18 5:17 PM: --- I am

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

2018-02-28 Thread Andrey Bratus (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16380686#comment-16380686 ] Andrey Bratus commented on KAFKA-4632: -- I am experiencing a similar issue, when pausing a connector

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

2018-02-28 Thread JIRA
[ 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

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

2018-02-28 Thread Damian Guy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16380293#comment-16380293 ] Damian Guy commented on KAFKA-6555: --- I think if we are going to allow stale reads from restoring tasks

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

2018-02-28 Thread Behrang Saeedzadeh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16380122#comment-16380122 ] Behrang Saeedzadeh commented on KAFKA-5828: --- Hi I think quotas could have this scenario quite

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

2018-02-28 Thread Alex Dunayevsky (JIRA)
[ 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