[jira] [Updated] (KAFKA-5886) Introduce delivery.timeout.ms producer config (KIP-91)

2017-10-06 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5886: - Fix Version/s: (was: 1.0.0) 1.1.0 > Introduce delivery.timeout.ms producer

[jira] [Updated] (KAFKA-5565) Add a broker metric specifying the number of consumer group rebalances in progress

2017-10-06 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5565: - Fix Version/s: (was: 1.0.0) 1.1.0 > Add a broker metric specifying the

[jira] [Commented] (KAFKA-5541) Streams should not re-throw if suspending/closing tasks fails

2017-10-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16195551#comment-16195551 ] ASF GitHub Bot commented on KAFKA-5541: --- Github user asfgit closed the pull request at:

[jira] [Updated] (KAFKA-5541) Streams should not re-throw if suspending/closing tasks fails

2017-10-06 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5541: - Fix Version/s: (was: 1.0.0) > Streams should not re-throw if suspending/closing tasks fails >

[jira] [Updated] (KAFKA-5541) Streams should not re-throw if suspending/closing tasks fails

2017-10-06 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5541: - Priority: Major (was: Blocker) > Streams should not re-throw if suspending/closing tasks fails >

[jira] [Updated] (KAFKA-5105) ReadOnlyKeyValueStore range scans are not ordered

2017-10-06 Thread siva santhalingam (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] siva santhalingam updated KAFKA-5105: - Description: _emphasized text_Following up with this thread

[jira] [Commented] (KAFKA-5541) Streams should not re-throw if suspending/closing tasks fails

2017-10-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16195489#comment-16195489 ] ASF GitHub Bot commented on KAFKA-5541: --- GitHub user mjsax opened a pull request:

[jira] [Commented] (KAFKA-5362) Add EOS system tests for Streams API

2017-10-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16195486#comment-16195486 ] ASF GitHub Bot commented on KAFKA-5362: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-5829) Speedup broker startup after unclean shutdown by reducing unnecessary snapshot files deletion

2017-10-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16195447#comment-16195447 ] ASF GitHub Bot commented on KAFKA-5829: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-5651) KIP-182: Reduce Streams DSL overloads and allow easier use of custom storage engines

2017-10-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16195381#comment-16195381 ] ASF GitHub Bot commented on KAFKA-5651: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-5876) IQ should throw different exceptions for different errors

2017-10-06 Thread Vito Jeng (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16195313#comment-16195313 ] Vito Jeng commented on KAFKA-5876: -- Thanks. I'll write my first KIP. ;) > IQ should throw different

[jira] [Commented] (KAFKA-6015) NPE in RecordAccumulator

2017-10-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16195314#comment-16195314 ] ASF GitHub Bot commented on KAFKA-6015: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-5829) Speedup broker startup after unclean shutdown by reducing unnecessary snapshot files deletion

2017-10-06 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16195302#comment-16195302 ] Guozhang Wang commented on KAFKA-5829: -- Thanks for the update Ismael, please let me know if you feel

[jira] [Assigned] (KAFKA-5876) IQ should throw different exceptions for different errors

2017-10-06 Thread Vito Jeng (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vito Jeng reassigned KAFKA-5876: Assignee: Vito Jeng > IQ should throw different exceptions for different errors >

[jira] [Updated] (KAFKA-6020) Broker side filtering

2017-10-06 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6020: --- Issue Type: New Feature (was: Improvement) > Broker side filtering > - >

[jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

2017-10-06 Thread JIRA
[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16195250#comment-16195250 ] Håkon Åmdal commented on KAFKA-4477: [~mlesyk] It seems like we're also experiencing the same issues

[jira] [Commented] (KAFKA-3359) Parallel log-recovery of un-flushed segments on startup

2017-10-06 Thread Ivan Babrou (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16195247#comment-16195247 ] Ivan Babrou commented on KAFKA-3359: [~ijuma], good to know, I'll bump the setting for our cluster. Is

[jira] [Commented] (KAFKA-5829) Speedup broker startup after unclean shutdown by reducing unnecessary snapshot files deletion

2017-10-06 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16195240#comment-16195240 ] Ismael Juma commented on KAFKA-5829: I have submitted an alternative PR that also includes a number of

[jira] [Commented] (KAFKA-4307) Inconsistent parameters between console producer and consumer

2017-10-06 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16195236#comment-16195236 ] Ismael Juma commented on KAFKA-4307: Unfortunately, this won't make it to 1.0.0. However, I'll try to

[jira] [Commented] (KAFKA-6020) Broker side filtering

2017-10-06 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16195223#comment-16195223 ] Ted Yu commented on KAFKA-6020: --- This needs a KIP, right ? > Broker side filtering > -

[jira] [Created] (KAFKA-6020) Broker side filtering

2017-10-06 Thread Pavel Micka (JIRA)
Pavel Micka created KAFKA-6020: -- Summary: Broker side filtering Key: KAFKA-6020 URL: https://issues.apache.org/jira/browse/KAFKA-6020 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-5547) Return topic authorization failed if no topic describe access

2017-10-06 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5547. Resolution: Fixed Fix Version/s: (was: 1.1.0) 1.0.0 Issue

[jira] [Commented] (KAFKA-5547) Return topic authorization failed if no topic describe access

2017-10-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16195192#comment-16195192 ] ASF GitHub Bot commented on KAFKA-5547: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-5953) Connect classloader isolation may be broken for JDBC drivers

2017-10-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16195018#comment-16195018 ] ASF GitHub Bot commented on KAFKA-5953: --- Github user asfgit closed the pull request at:

[jira] [Resolved] (KAFKA-5953) Connect classloader isolation may be broken for JDBC drivers

2017-10-06 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-5953. -- Resolution: Fixed Fix Version/s: 1.0.0 1.1.0 Issue

[jira] [Created] (KAFKA-6019) Sentry permissions bug on CDH

2017-10-06 Thread Jorge Machado (JIRA)
Jorge Machado created KAFKA-6019: Summary: Sentry permissions bug on CDH Key: KAFKA-6019 URL: https://issues.apache.org/jira/browse/KAFKA-6019 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-5876) IQ should throw different exceptions for different errors

2017-10-06 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194959#comment-16194959 ] Matthias J. Sax commented on KAFKA-5876: Sure. Please assign the ticket to yourself and create a

[jira] [Commented] (KAFKA-4794) Add access to OffsetStorageReader from SourceConnector

2017-10-06 Thread Randall Hauch (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194885#comment-16194885 ] Randall Hauch commented on KAFKA-4794: -- [~olkuznsmith], when I said the connector can't read offsets,

[jira] [Commented] (KAFKA-6003) Replication Fetcher thread for a partition with no data fails to start

2017-10-06 Thread Apurva Mehta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194868#comment-16194868 ] Apurva Mehta commented on KAFKA-6003: - Hi [~schizhov] : I update the fix version to include 0.11.0.2.

[jira] [Updated] (KAFKA-6003) Replication Fetcher thread for a partition with no data fails to start

2017-10-06 Thread Apurva Mehta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta updated KAFKA-6003: Fix Version/s: 0.11.0.2 > Replication Fetcher thread for a partition with no data fails to start >

[jira] [Resolved] (KAFKA-5916) Upgrade rocksdb dependency to 5.8

2017-10-06 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved KAFKA-5916. --- Resolution: Duplicate With KAFKA-5576 > Upgrade rocksdb dependency to 5.8 >

[jira] [Updated] (KAFKA-3821) Allow Kafka Connect source tasks to produce offset without writing to topics

2017-10-06 Thread Randall Hauch (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-3821: - Fix Version/s: 1.1.0 > Allow Kafka Connect source tasks to produce offset without writing to

[jira] [Updated] (KAFKA-4794) Add access to OffsetStorageReader from SourceConnector

2017-10-06 Thread Randall Hauch (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-4794: - Fix Version/s: 1.1.0 > Add access to OffsetStorageReader from SourceConnector >

[jira] [Reopened] (KAFKA-6017) Cannot get broker ids from Kafka using kafka-connect

2017-10-06 Thread Jorge Machado (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jorge Machado reopened KAFKA-6017: -- This seems not to be totally fixed. Now I get : {code} [2017-10-06 12:13:18,509] WARN Error

[jira] [Commented] (KAFKA-6003) Replication Fetcher thread for a partition with no data fails to start

2017-10-06 Thread Stanislav Chizhov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194469#comment-16194469 ] Stanislav Chizhov commented on KAFKA-6003: -- OK, I see. Thank you. Just wondering: if there is a

[jira] [Commented] (KAFKA-6018) Make KafkaFuture.Function java 8 lambda compatible

2017-10-06 Thread Steven Aerts (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194427#comment-16194427 ] Steven Aerts commented on KAFKA-6018: - I do not mind to create a KIP for this or start a [DISCUSS]

[jira] [Commented] (KAFKA-6017) Cannot get broker ids from Kafka using kafka-connect

2017-10-06 Thread Jorge Machado (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194420#comment-16194420 ] Jorge Machado commented on KAFKA-6017: -- So I found out the fix. Make sure that if you are using

[jira] [Commented] (KAFKA-6018) Make KafkaFuture.Function java 8 lambda compatible

2017-10-06 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194413#comment-16194413 ] Ismael Juma commented on KAFKA-6018: cc [~cmccabe] > Make KafkaFuture.Function java 8 lambda

[jira] [Commented] (KAFKA-6018) Make KafkaFuture.Function java 8 lambda compatible

2017-10-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194414#comment-16194414 ] ASF GitHub Bot commented on KAFKA-6018: --- GitHub user steven-aerts opened a pull request:

[jira] [Commented] (KAFKA-6018) Make KafkaFuture.Function java 8 lambda compatible

2017-10-06 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194411#comment-16194411 ] Ismael Juma commented on KAFKA-6018: Hmm, this is unfortunate. The change would require a KIP:

[jira] [Commented] (KAFKA-6018) Make KafkaFuture.Function java 8 lambda compatible

2017-10-06 Thread Steven Aerts (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194404#comment-16194404 ] Steven Aerts commented on KAFKA-6018: - This does not work, as you cannot use java 8 lambdas with

[jira] [Updated] (KAFKA-6018) Make KafkaFuture.Function java 8 lambda compatible

2017-10-06 Thread Steven Aerts (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Aerts updated KAFKA-6018: Summary: Make KafkaFuture.Function java 8 lambda compatible (was: Make from KafkaFuture.Function

[jira] [Commented] (KAFKA-6003) Replication Fetcher thread for a partition with no data fails to start

2017-10-06 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194382#comment-16194382 ] Ismael Juma commented on KAFKA-6003: There is a PR open for the 0.11.0 branch:

[jira] [Comment Edited] (KAFKA-6018) Make from KafkaFuture.Function java 8 lambda compatible

2017-10-06 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194376#comment-16194376 ] Ismael Juma edited comment on KAFKA-6018 at 10/6/17 9:54 AM: - Lambdas can be

[jira] [Commented] (KAFKA-6018) Make from KafkaFuture.Function java 8 lambda compatible

2017-10-06 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194376#comment-16194376 ] Ismael Juma commented on KAFKA-6018: Lambdas can be used with abstract classes if they have a single

[jira] [Created] (KAFKA-6018) Make from KafkaFuture.Function java 8 lambda compatible

2017-10-06 Thread Steven Aerts (JIRA)
Steven Aerts created KAFKA-6018: --- Summary: Make from KafkaFuture.Function java 8 lambda compatible Key: KAFKA-6018 URL: https://issues.apache.org/jira/browse/KAFKA-6018 Project: Kafka Issue

[jira] [Comment Edited] (KAFKA-6003) Replication Fetcher thread for a partition with no data fails to start

2017-10-06 Thread Stanislav Chizhov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194347#comment-16194347 ] Stanislav Chizhov edited comment on KAFKA-6003 at 10/6/17 9:28 AM: --- Hi

[jira] [Comment Edited] (KAFKA-6003) Replication Fetcher thread for a partition with no data fails to start

2017-10-06 Thread Stanislav Chizhov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194347#comment-16194347 ] Stanislav Chizhov edited comment on KAFKA-6003 at 10/6/17 9:26 AM: --- Hi

[jira] [Commented] (KAFKA-6003) Replication Fetcher thread for a partition with no data fails to start

2017-10-06 Thread Stanislav Chizhov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194347#comment-16194347 ] Stanislav Chizhov commented on KAFKA-6003: -- Hi [~apurva]]. So now there are no plans to have that

[jira] [Commented] (KAFKA-5876) IQ should throw different exceptions for different errors

2017-10-06 Thread Vito Jeng (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194325#comment-16194325 ] Vito Jeng commented on KAFKA-5876: -- Could I work on this issue? > IQ should throw different exceptions

[jira] [Closed] (KAFKA-5576) Support Power platform by updating rocksdb version

2017-10-06 Thread Yussuf Shaikh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yussuf Shaikh closed KAFKA-5576. Thanks [~guozhang] for working on the upgrade. Confirmed with latest code that the rocksdb issues are

[jira] [Commented] (KAFKA-5953) Connect classloader isolation may be broken for JDBC drivers

2017-10-06 Thread Konstantine Karantasis (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194261#comment-16194261 ] Konstantine Karantasis commented on KAFKA-5953: --- This issue is specific to any JDBC drivers

[jira] [Commented] (KAFKA-5576) Support Power platform by updating rocksdb version

2017-10-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194252#comment-16194252 ] ASF GitHub Bot commented on KAFKA-5576: --- Github user yussufsh closed the pull request at:

[jira] [Commented] (KAFKA-5953) Connect classloader isolation may be broken for JDBC drivers

2017-10-06 Thread Jiri Pechanec (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194195#comment-16194195 ] Jiri Pechanec commented on KAFKA-5953: -- Is this issue limited only to JDBC drivers or to anything