[jira] [Updated] (KAFKA-5882) NullPointerException in ConsumerCoordinator

2017-09-12 Thread Seweryn Habdank-Wojewodzki (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki updated KAFKA-5882: -- Component/s: streams > NullPointerException in ConsumerCoordinator > ---

[jira] [Updated] (KAFKA-5882) NullPointerException in ConsumerCoordinator

2017-09-12 Thread Seweryn Habdank-Wojewodzki (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki updated KAFKA-5882: -- Affects Version/s: 0.11.0.0 > NullPointerException in ConsumerCoordinato

[jira] [Commented] (KAFKA-5881) Consuming from added partitions without restarting the consumer

2017-09-12 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16164211#comment-16164211 ] huxihx commented on KAFKA-5881: --- You could decrease `metadata.max.age.ms` to have consumer r

[jira] [Updated] (KAFKA-5882) NullPointerException in ConsumerCoordinator

2017-09-12 Thread Seweryn Habdank-Wojewodzki (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki updated KAFKA-5882: -- Description: It seems bugfix [KAFKA-5073|https://issues.apache.org/jira/

[jira] [Created] (KAFKA-5882) NullPointerException in ConsumerCoordinator

2017-09-12 Thread Seweryn Habdank-Wojewodzki (JIRA)
Seweryn Habdank-Wojewodzki created KAFKA-5882: - Summary: NullPointerException in ConsumerCoordinator Key: KAFKA-5882 URL: https://issues.apache.org/jira/browse/KAFKA-5882 Project: Kafka

[jira] [Commented] (KAFKA-4392) Failed to lock the state directory due to an unexpected exception

2017-09-12 Thread Seweryn Habdank-Wojewodzki (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16164190#comment-16164190 ] Seweryn Habdank-Wojewodzki commented on KAFKA-4392: --- I am using 0.11.0.0

[jira] [Updated] (KAFKA-5881) Consuming from added partitions without restarting the consumer

2017-09-12 Thread Viliam Durina (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Viliam Durina updated KAFKA-5881: - Description: Currently the {{KafkaConsumer}} is not able to return events from newly added partit

[jira] [Updated] (KAFKA-5881) Consuming from added partitions without restarting the consumer

2017-09-12 Thread Viliam Durina (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Viliam Durina updated KAFKA-5881: - Description: Currently the {{KafkaConsumer}} is not able to return events from newly added partit

[jira] [Comment Edited] (KAFKA-5861) KStream close( withTimeout ) - does not work under load conditions in the multi-threaded KStream application

2017-09-12 Thread Seweryn Habdank-Wojewodzki (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162654#comment-16162654 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-5861 at 9/13/17 6:04 AM:

[jira] [Commented] (KAFKA-5880) Transactional producer and read committed consumer causes consumer to stuck

2017-09-12 Thread Lae (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16164186#comment-16164186 ] Lae commented on KAFKA-5880: No problem I'll post the trace logging here for the consumer once

[jira] [Created] (KAFKA-5881) Consuming from added partitions without restarting the consumer

2017-09-12 Thread Viliam Durina (JIRA)
Viliam Durina created KAFKA-5881: Summary: Consuming from added partitions without restarting the consumer Key: KAFKA-5881 URL: https://issues.apache.org/jira/browse/KAFKA-5881 Project: Kafka

[jira] [Updated] (KAFKA-5880) Transactional producer and read committed consumer causes consumer to stuck

2017-09-12 Thread Lae (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lae updated KAFKA-5880: --- Description: We use transactional producers, and have configured isolation level on the consumer to only read committ

[jira] [Commented] (KAFKA-5880) Transactional producer and read committed consumer causes consumer to stuck

2017-09-12 Thread Apurva Mehta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16164149#comment-16164149 ] Apurva Mehta commented on KAFKA-5880: - Hi Lae, Thanks for reporting the issue. Can y

[jira] [Created] (KAFKA-5880) Transactional producer and read committed consumer causes consumer to stuck

2017-09-12 Thread Lae (JIRA)
Lae created KAFKA-5880: -- Summary: Transactional producer and read committed consumer causes consumer to stuck Key: KAFKA-5880 URL: https://issues.apache.org/jira/browse/KAFKA-5880 Project: Kafka Issue

[jira] [Commented] (KAFKA-5301) Improve exception handling on consumer path

2017-09-12 Thread Richard Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16164104#comment-16164104 ] Richard Yu commented on KAFKA-5301: --- Github Pull Request: https://github.com/apache/kafk

[jira] [Resolved] (KAFKA-2887) TopicMetadataRequest creates topic if it does not exist

2017-09-12 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2887. -- Resolution: Fixed > TopicMetadataRequest creates topic if it does not exist > --

[jira] [Commented] (KAFKA-5833) Reset thread interrupt state in case of InterruptedException

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

[jira] [Assigned] (KAFKA-5833) Reset thread interrupt state in case of InterruptedException

2017-09-12 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-5833: -- Assignee: Matthias J. Sax > Reset thread interrupt state in case of InterruptedExceptio

[jira] [Commented] (KAFKA-4392) Failed to lock the state directory due to an unexpected exception

2017-09-12 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16163966#comment-16163966 ] Guozhang Wang commented on KAFKA-4392: -- Which version are you using? I'm pretty confi

[jira] [Commented] (KAFKA-5825) Streams not processing when exactly once is set

2017-09-12 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16163954#comment-16163954 ] Guozhang Wang commented on KAFKA-5825: -- I looked carefully through the logs and here

[jira] [Commented] (KAFKA-5879) Controller should read the latest IsrChangeNotification znodes when handling IsrChangeNotification event

2017-09-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16163936#comment-16163936 ] ASF GitHub Bot commented on KAFKA-5879: --- GitHub user lindong28 opened a pull request

[jira] [Created] (KAFKA-5879) Controller should read the latest IsrChangeNotification znodes when handling IsrChangeNotification event

2017-09-12 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-5879: --- Summary: Controller should read the latest IsrChangeNotification znodes when handling IsrChangeNotification event Key: KAFKA-5879 URL: https://issues.apache.org/jira/browse/KAFKA-5879

[jira] [Updated] (KAFKA-5879) Controller should read the latest IsrChangeNotification znodes when handling IsrChangeNotification event

2017-09-12 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5879: Description: Currently controller can be very inefficient in handling IsrChangeNotification event because i

[jira] [Updated] (KAFKA-5879) Controller should read the latest IsrChangeNotification znodes when handling IsrChangeNotification event

2017-09-12 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5879: Description: Currently controller can be very inefficient in handling IsrChangeNotification event because i

[jira] [Commented] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

2017-09-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16163872#comment-16163872 ] ASF GitHub Bot commented on KAFKA-4468: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-5545) Kafka Streams not able to successfully restart over new broker ip

2017-09-12 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16163868#comment-16163868 ] Guozhang Wang commented on KAFKA-5545: -- The voting has passed, it should be out in no

[jira] [Commented] (KAFKA-3758) KStream job fails to recover after Kafka broker stopped

2017-09-12 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16163865#comment-16163865 ] Guozhang Wang commented on KAFKA-3758: -- This is a known issue and has been fixed sinc

[jira] [Updated] (KAFKA-5833) Reset thread interrupt state in case of InterruptedException

2017-09-12 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5833: - Component/s: streams > Reset thread interrupt state in case of InterruptedException >

[jira] [Commented] (KAFKA-5833) Reset thread interrupt state in case of InterruptedException

2017-09-12 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16163862#comment-16163862 ] Guozhang Wang commented on KAFKA-5833: -- cc [~mjsax], could you take a look at the rep

[jira] [Created] (KAFKA-5878) Add sensor for queue size of the controller-event-thread

2017-09-12 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-5878: --- Summary: Add sensor for queue size of the controller-event-thread Key: KAFKA-5878 URL: https://issues.apache.org/jira/browse/KAFKA-5878 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-5877) Controller should only update reassignment znode if there is change in the reassignment data

2017-09-12 Thread Tom Bentley (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16163696#comment-16163696 ] Tom Bentley commented on KAFKA-5877: {quote} Although I have not fully figured out th

[jira] [Commented] (KAFKA-5877) Controller should only update reassignment znode if there is change in the reassignment data

2017-09-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16163685#comment-16163685 ] ASF GitHub Bot commented on KAFKA-5877: --- GitHub user lindong28 opened a pull request

[jira] [Updated] (KAFKA-5877) Controller should only update reassignment znode if there is change in the reassignment data

2017-09-12 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5877: Description: I encountered a scenario where controller keeps printing the following stack trace repeatedly

[jira] [Created] (KAFKA-5877) Controller should only update reassignment znode if there is change in the reassignment data

2017-09-12 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-5877: --- Summary: Controller should only update reassignment znode if there is change in the reassignment data Key: KAFKA-5877 URL: https://issues.apache.org/jira/browse/KAFKA-5877 Proj

[jira] [Commented] (KAFKA-2887) TopicMetadataRequest creates topic if it does not exist

2017-09-12 Thread Andrew Winterman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16163644#comment-16163644 ] Andrew Winterman commented on KAFKA-2887: - It does, thank you! > TopicMetadata

[jira] [Resolved] (KAFKA-5621) The producer should retry expired batches when retries are enabled

2017-09-12 Thread Apurva Mehta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta resolved KAFKA-5621. - Resolution: Won't Fix > The producer should retry expired batches when retries are enabled > -

[jira] [Commented] (KAFKA-5621) The producer should retry expired batches when retries are enabled

2017-09-12 Thread Apurva Mehta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16163502#comment-16163502 ] Apurva Mehta commented on KAFKA-5621: - Thanks for the update [~sutambe]. I am closing

[jira] [Commented] (KAFKA-5621) The producer should retry expired batches when retries are enabled

2017-09-12 Thread Sumant Tambe (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16163485#comment-16163485 ] Sumant Tambe commented on KAFKA-5621: - The original ticket is about retrying timed-out

[jira] [Commented] (KAFKA-5397) streams are not recovering from LockException during rebalancing

2017-09-12 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16163424#comment-16163424 ] Matthias J. Sax commented on KAFKA-5397: Thanks for reporting [~uohzoaix] > strea

[jira] [Commented] (KAFKA-5861) KStream close( withTimeout ) - does not work under load conditions in the multi-threaded KStream application

2017-09-12 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16163419#comment-16163419 ] Matthias J. Sax commented on KAFKA-5861: [~habdank] One more hint about shutdown h

[jira] [Commented] (KAFKA-5861) KStream close( withTimeout ) - does not work under load conditions in the multi-threaded KStream application

2017-09-12 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16163404#comment-16163404 ] Matthias J. Sax commented on KAFKA-5861: Thanks for following up on this, and for

[jira] [Commented] (KAFKA-5716) Connect: When SourceTask.commit it is possible not everthing from SourceTask.poll has been sent

2017-09-12 Thread Randall Hauch (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16163338#comment-16163338 ] Randall Hauch commented on KAFKA-5716: -- {quote} If you can point me in the direction

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

2017-09-12 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5876: -- Summary: IQ should throw different exceptions for different errors Key: KAFKA-5876 URL: https://issues.apache.org/jira/browse/KAFKA-5876 Project: Kafka I

[jira] [Commented] (KAFKA-5693) TopicCreationPolicy and AlterConfigsPolicy overlap

2017-09-12 Thread Tom Bentley (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16163291#comment-16163291 ] Tom Bentley commented on KAFKA-5693: Some of KIP-179 subsequently got split into KIP-1

[jira] [Commented] (KAFKA-5872) Transient failure in SslSelectorTest.testMuteOnOOM

2017-09-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16163260#comment-16163260 ] ASF GitHub Bot commented on KAFKA-5872: --- Github user asfgit closed the pull request

[jira] [Resolved] (KAFKA-5872) Transient failure in SslSelectorTest.testMuteOnOOM

2017-09-12 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-5872. --- Resolution: Fixed Issue resolved by pull request 3836 [https://github.com/apache/kafka/pull/38

[jira] [Commented] (KAFKA-5873) Add Materialized overloads to StreamBuilder

2017-09-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16163216#comment-16163216 ] ASF GitHub Bot commented on KAFKA-5873: --- GitHub user dguy opened a pull request:

[jira] [Commented] (KAFKA-5655) Add new API methods to KGroupedTable

2017-09-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16163192#comment-16163192 ] ASF GitHub Bot commented on KAFKA-5655: --- Github user asfgit closed the pull request

[jira] [Resolved] (KAFKA-5655) Add new API methods to KGroupedTable

2017-09-12 Thread Damian Guy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-5655. --- Resolution: Fixed Fix Version/s: 1.0.0 Issue resolved by pull request 3829 [https://github.com/

[jira] [Commented] (KAFKA-5875) Consumer group repeatedly fails to join, even across JVM restarts: BufferUnderFlowException reading the {{version}} field in the consumer protocol header

2017-09-12 Thread Evan Pollan (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16163128#comment-16163128 ] Evan Pollan commented on KAFKA-5875: It's worth mentioning that we are letting the con

[jira] [Created] (KAFKA-5875) Consumer group repeatedly fails to join, even across JVM restarts: BufferUnderFlowException reading the {{version}} field in the consumer protocol header

2017-09-12 Thread Evan Pollan (JIRA)
Evan Pollan created KAFKA-5875: -- Summary: Consumer group repeatedly fails to join, even across JVM restarts: BufferUnderFlowException reading the {{version}} field in the consumer protocol header Key: KAFKA-5875 URL

[jira] [Comment Edited] (KAFKA-5649) Producer is being closed generating ssl exception

2017-09-12 Thread Elliot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162987#comment-16162987 ] Elliot edited comment on KAFKA-5649 at 9/12/17 2:04 PM: Hello. We

[jira] [Comment Edited] (KAFKA-5649) Producer is being closed generating ssl exception

2017-09-12 Thread Elliot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162987#comment-16162987 ] Elliot edited comment on KAFKA-5649 at 9/12/17 2:04 PM: Hello. We

[jira] [Commented] (KAFKA-5649) Producer is being closed generating ssl exception

2017-09-12 Thread Elliot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162987#comment-16162987 ] Elliot commented on KAFKA-5649: --- Hello. We're encountering the same issue after a short per

[jira] [Resolved] (KAFKA-5861) KStream close( withTimeout ) - does not work under load conditions in the multi-threaded KStream application

2017-09-12 Thread Seweryn Habdank-Wojewodzki (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki resolved KAFKA-5861. --- Resolution: Workaround > KStream close( withTimeout ) - does not work

[jira] [Comment Edited] (KAFKA-5861) KStream close( withTimeout ) - does not work under load conditions in the multi-threaded KStream application

2017-09-12 Thread Seweryn Habdank-Wojewodzki (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162964#comment-16162964 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-5861 at 9/12/17 1:50 PM:

[jira] [Commented] (KAFKA-5861) KStream close( withTimeout ) - does not work under load conditions in the multi-threaded KStream application

2017-09-12 Thread Seweryn Habdank-Wojewodzki (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162964#comment-16162964 ] Seweryn Habdank-Wojewodzki commented on KAFKA-5861: --- I made further inve

[jira] [Comment Edited] (KAFKA-5861) KStream close( withTimeout ) - does not work under load conditions in the multi-threaded KStream application

2017-09-12 Thread Seweryn Habdank-Wojewodzki (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162654#comment-16162654 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-5861 at 9/12/17 1:47 PM:

[jira] [Resolved] (KAFKA-1834) No Response when handle LeaderAndIsrRequest some case

2017-09-12 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1834. -- Resolution: Fixed This was fixed in newer Kafka versions. > No Response when handle LeaderAndIsrRequest

[jira] [Resolved] (KAFKA-1630) ConsumerFetcherThread locked in Tomcat

2017-09-12 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1630. -- Resolution: Cannot Reproduce Closing inactive issue. Please reopen if you think the issue still exists

[jira] [Commented] (KAFKA-5545) Kafka Streams not able to successfully restart over new broker ip

2017-09-12 Thread Yogesh BG (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162903#comment-16162903 ] Yogesh BG commented on KAFKA-5545: -- I have taken source code and verified the issue, work

[jira] [Commented] (KAFKA-2887) TopicMetadataRequest creates topic if it does not exist

2017-09-12 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162853#comment-16162853 ] Manikumar commented on KAFKA-2887: -- As of 0.11.0.0, We added a "allow_auto_topic_creati

[jira] [Commented] (KAFKA-5868) Kafka Consumer Rebalancing takes too long

2017-09-12 Thread Nandish Kotadia (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162851#comment-16162851 ] Nandish Kotadia commented on KAFKA-5868: [~guozhang] Can you please help with this

[jira] [Updated] (KAFKA-5868) Kafka Consumer Rebalancing takes too long

2017-09-12 Thread Nandish Kotadia (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nandish Kotadia updated KAFKA-5868: --- Affects Version/s: 0.10.2.0 0.10.2.1 > Kafka Consumer Rebalancing takes

[jira] [Comment Edited] (KAFKA-5861) KStream close( withTimeout ) - does not work under load conditions in the multi-threaded KStream application

2017-09-12 Thread Seweryn Habdank-Wojewodzki (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162654#comment-16162654 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-5861 at 9/12/17 12:04 PM: ---

[jira] [Updated] (KAFKA-5868) Kafka Consumer Rebalancing takes too long

2017-09-12 Thread Nandish Kotadia (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nandish Kotadia updated KAFKA-5868: --- Description: up vote 0 down vote favorite 1 I have a Kafka Streams Application which takes dat

[jira] [Comment Edited] (KAFKA-3758) KStream job fails to recover after Kafka broker stopped

2017-09-12 Thread Nandish Kotadia (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162835#comment-16162835 ] Nandish Kotadia edited comment on KAFKA-3758 at 9/12/17 12:01 PM: --

[jira] [Commented] (KAFKA-3758) KStream job fails to recover after Kafka broker stopped

2017-09-12 Thread Nandish Kotadia (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162835#comment-16162835 ] Nandish Kotadia commented on KAFKA-3758: [~guozhang] I am running the streams ins

[jira] [Commented] (KAFKA-5716) Connect: When SourceTask.commit it is possible not everthing from SourceTask.poll has been sent

2017-09-12 Thread Per Steffensen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162829#comment-16162829 ] Per Steffensen commented on KAFKA-5716: --- {quote} * Do you also use pull-request for

[jira] [Commented] (KAFKA-5716) Connect: When SourceTask.commit it is possible not everthing from SourceTask.poll has been sent

2017-09-12 Thread Per Steffensen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162824#comment-16162824 ] Per Steffensen commented on KAFKA-5716: --- Sorry for the late response. I have been bu

[jira] [Commented] (KAFKA-1921) Delete offsets for a group with kafka offset storage

2017-09-12 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162803#comment-16162803 ] Manikumar commented on KAFKA-1921: -- [~onurkaraman] Now we have a command-line tool to re

[jira] [Updated] (KAFKA-5874) Incorrect command line handling

2017-09-12 Thread Viliam Durina (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Viliam Durina updated KAFKA-5874: - Description: Extra parameters on command line are silently ignored. This leads to confusion. For

[jira] [Created] (KAFKA-5874) Incorrect command line handling

2017-09-12 Thread Viliam Durina (JIRA)
Viliam Durina created KAFKA-5874: Summary: Incorrect command line handling Key: KAFKA-5874 URL: https://issues.apache.org/jira/browse/KAFKA-5874 Project: Kafka Issue Type: Bug Compo

[jira] [Updated] (KAFKA-5872) Transient failure in SslSelectorTest.testMuteOnOOM

2017-09-12 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-5872: -- Description: There are a couple of issues: 1. `Selector.determineHandlingOrder()` currently does

[jira] [Created] (KAFKA-5873) Add Materialized overloads to StreamBuilder

2017-09-12 Thread Damian Guy (JIRA)
Damian Guy created KAFKA-5873: - Summary: Add Materialized overloads to StreamBuilder Key: KAFKA-5873 URL: https://issues.apache.org/jira/browse/KAFKA-5873 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-5872) Transient failure in SslSelectorTest.testMuteOnOOM

2017-09-12 Thread Rajini Sivaram (JIRA)
Rajini Sivaram created KAFKA-5872: - Summary: Transient failure in SslSelectorTest.testMuteOnOOM Key: KAFKA-5872 URL: https://issues.apache.org/jira/browse/KAFKA-5872 Project: Kafka Issue Type

[jira] [Commented] (KAFKA-5397) streams are not recovering from LockException during rebalancing

2017-09-12 Thread johnchou (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162689#comment-16162689 ] johnchou commented on KAFKA-5397: - I encounter the same problem,my kafka client and stream

[jira] [Comment Edited] (KAFKA-5861) KStream close( withTimeout ) - does not work under load conditions in the multi-threaded KStream application

2017-09-12 Thread Seweryn Habdank-Wojewodzki (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162654#comment-16162654 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-5861 at 9/12/17 8:24 AM:

[jira] [Comment Edited] (KAFKA-5861) KStream close( withTimeout ) - does not work under load conditions in the multi-threaded KStream application

2017-09-12 Thread Seweryn Habdank-Wojewodzki (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162654#comment-16162654 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-5861 at 9/12/17 8:24 AM:

[jira] [Comment Edited] (KAFKA-5861) KStream close( withTimeout ) - does not work under load conditions in the multi-threaded KStream application

2017-09-12 Thread Seweryn Habdank-Wojewodzki (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162654#comment-16162654 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-5861 at 9/12/17 8:23 AM:

[jira] [Comment Edited] (KAFKA-5861) KStream close( withTimeout ) - does not work under load conditions in the multi-threaded KStream application

2017-09-12 Thread Seweryn Habdank-Wojewodzki (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162654#comment-16162654 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-5861 at 9/12/17 8:22 AM:

[jira] [Comment Edited] (KAFKA-5861) KStream close( withTimeout ) - does not work under load conditions in the multi-threaded KStream application

2017-09-12 Thread Seweryn Habdank-Wojewodzki (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162654#comment-16162654 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-5861 at 9/12/17 8:20 AM:

[jira] [Commented] (KAFKA-5861) KStream close( withTimeout ) - does not work under load conditions in the multi-threaded KStream application

2017-09-12 Thread Seweryn Habdank-Wojewodzki (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162654#comment-16162654 ] Seweryn Habdank-Wojewodzki commented on KAFKA-5861: --- Property: num.strea

[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-09-12 Thread Viktor Somogyi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162640#comment-16162640 ] Viktor Somogyi commented on KAFKA-4477: --- Thanks [~ewencp], I must have missed it, th

[jira] [Assigned] (KAFKA-5018) LogCleaner tests to verify behaviour of message format v2

2017-09-12 Thread Armin Braun (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Armin Braun reassigned KAFKA-5018: -- Assignee: (was: Armin Braun) > LogCleaner tests to verify behaviour of message format v2 >

[jira] [Assigned] (KAFKA-4928) Add integration test for DumpLogSegments

2017-09-12 Thread Armin Braun (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Armin Braun reassigned KAFKA-4928: -- Assignee: (was: Armin Braun) > Add integration test for DumpLogSegments > -

[jira] [Commented] (KAFKA-5018) LogCleaner tests to verify behaviour of message format v2

2017-09-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162593#comment-16162593 ] ASF GitHub Bot commented on KAFKA-5018: --- Github user original-brownbear closed the p

[jira] [Commented] (KAFKA-4928) Add integration test for DumpLogSegments

2017-09-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16162594#comment-16162594 ] ASF GitHub Bot commented on KAFKA-4928: --- Github user original-brownbear closed the p