[jira] [Resolved] (KAFKA-3978) Cannot truncate to a negative offset (-1) exception at broker startup

[ https://issues.apache.org/jira/browse/KAFKA-3978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-3978. Resolution: Fixed Fix Version/s: 1.2.0 > Cannot truncate to a negative offset (-1)

[jira] [Commented] (KAFKA-6645) Host Affinity to facilitate faster restarts of kafka streams applications

[ https://issues.apache.org/jira/browse/KAFKA-6645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16398138#comment-16398138 ] Guozhang Wang commented on KAFKA-6645: -- Hi Giridhar, could you share with us a bit more on your usage

[jira] [Created] (KAFKA-6653) Delayed operations may not be completed when there is lock contention

Rajini Sivaram created KAFKA-6653: - Summary: Delayed operations may not be completed when there is lock contention Key: KAFKA-6653 URL: https://issues.apache.org/jira/browse/KAFKA-6653 Project: Kafka

[jira] [Commented] (KAFKA-6647) KafkaStreams.cleanUp creates .lock file in directory its trying to clean

[ https://issues.apache.org/jira/browse/KAFKA-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16398133#comment-16398133 ] George Bloggs commented on KAFKA-6647: -- Yeah, I can see your thought path. The .lock file is created

[jira] [Commented] (KAFKA-6649) ReplicaFetcher stopped after non fatal exception is thrown

[ https://issues.apache.org/jira/browse/KAFKA-6649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16398134#comment-16398134 ] Jason Gustafson commented on KAFKA-6649: The root cause of this is likely KAFKA-3978, which has

[jira] [Commented] (KAFKA-6645) Host Affinity to facilitate faster restarts of kafka streams applications

[ https://issues.apache.org/jira/browse/KAFKA-6645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16398148#comment-16398148 ] Giridhar Addepalli commented on KAFKA-6645: --- Thank you for your reply [~mjsax] Can you please

[jira] [Updated] (KAFKA-6646) Add a GlobalKStream object type for stream event broadcast

[ https://issues.apache.org/jira/browse/KAFKA-6646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6646: - Labels: api needs-kip (was: needs-kip) > Add a GlobalKStream object type for stream event

[jira] [Created] (KAFKA-6654) Customize SSLContext creation

Robert Wruck created KAFKA-6654: --- Summary: Customize SSLContext creation Key: KAFKA-6654 URL: https://issues.apache.org/jira/browse/KAFKA-6654 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-4027) Leader for a cetain partition unavailable forever

[ https://issues.apache.org/jira/browse/KAFKA-4027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16398348#comment-16398348 ] Antonio Verardi commented on KAFKA-4027: [~omkreddy]: thanks for the super quick reply! As soon as

[jira] [Commented] (KAFKA-6657) Add StreamsConfig prefix for different consumers

[ https://issues.apache.org/jira/browse/KAFKA-6657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16399752#comment-16399752 ] siva santhalingam commented on KAFKA-6657: -- [~mjsax] Assigning this to myself for now. Let me

[jira] [Assigned] (KAFKA-6657) Add StreamsConfig prefix for different consumers

[ https://issues.apache.org/jira/browse/KAFKA-6657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] siva santhalingam reassigned KAFKA-6657: Assignee: siva santhalingam > Add StreamsConfig prefix for different consumers >

[jira] [Commented] (KAFKA-6661) Sink connectors that explicitly 'resume' topic partitions can resume a paused task

[ https://issues.apache.org/jira/browse/KAFKA-6661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16399573#comment-16399573 ] Randall Hauch commented on KAFKA-6661: -- The {{WorkerSinkTask}} and {{WorkerSinkTaskContext}} both

[jira] [Commented] (KAFKA-6264) Log cleaner thread may die on legacy segment containing messages whose offsets are too large

[ https://issues.apache.org/jira/browse/KAFKA-6264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16399698#comment-16399698 ] James Cheng commented on KAFKA-6264: We recently ran into this on one of our clusters. {code:java}

[jira] [Commented] (KAFKA-6657) Add StreamsConfig prefix for different consumers

[ https://issues.apache.org/jira/browse/KAFKA-6657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16399905#comment-16399905 ] Matthias J. Sax commented on KAFKA-6657: Sure. Please prepare a KIP 

[jira] [Commented] (KAFKA-6592) NullPointerException thrown when executing ConsoleCosumer with deserializer set to `WindowedDeserializer`

[ https://issues.apache.org/jira/browse/KAFKA-6592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16399675#comment-16399675 ] Guozhang Wang commented on KAFKA-6592: -- [~huxi_2b] Are you still working on this JIRA now?? >

[jira] [Commented] (KAFKA-6661) Sink connectors that explicitly 'resume' topic partitions can resume a paused task

[ https://issues.apache.org/jira/browse/KAFKA-6661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16399681#comment-16399681 ] ASF GitHub Bot commented on KAFKA-6661: --- rhauch opened a new pull request #4716: KAFKA-6661: Ensure

[jira] [Commented] (KAFKA-6661) Sink connectors that explicitly 'resume' topic partitions can resume a paused task

[ https://issues.apache.org/jira/browse/KAFKA-6661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16399567#comment-16399567 ] Randall Hauch commented on KAFKA-6661: -- After a connector is paused, the sink task worker will call

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

[ https://issues.apache.org/jira/browse/KAFKA-4831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16399672#comment-16399672 ] ASF GitHub Bot commented on KAFKA-4831: --- guozhangwang closed pull request #4686: KAFKA-4831: add

[jira] [Created] (KAFKA-6661) Sink connectors that explicitly 'resume' topic partitions can resume a paused task

Randall Hauch created KAFKA-6661: Summary: Sink connectors that explicitly 'resume' topic partitions can resume a paused task Key: KAFKA-6661 URL: https://issues.apache.org/jira/browse/KAFKA-6661

[jira] [Comment Edited] (KAFKA-6592) NullPointerException thrown when executing ConsoleCosumer with deserializer set to `WindowedDeserializer`

[ https://issues.apache.org/jira/browse/KAFKA-6592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16399675#comment-16399675 ] Guozhang Wang edited comment on KAFKA-6592 at 3/15/18 12:37 AM: [~huxi_2b]

[jira] [Reopened] (KAFKA-6592) NullPointerException thrown when executing ConsoleCosumer with deserializer set to `WindowedDeserializer`

[ https://issues.apache.org/jira/browse/KAFKA-6592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-6592: -- > NullPointerException thrown when executing ConsoleCosumer with deserializer > set to

[jira] [Created] (KAFKA-6657) Add StreamsConfig prefix for different consumers

Matthias J. Sax created KAFKA-6657: -- Summary: Add StreamsConfig prefix for different consumers Key: KAFKA-6657 URL: https://issues.apache.org/jira/browse/KAFKA-6657 Project: Kafka Issue

[jira] [Commented] (KAFKA-6649) ReplicaFetcher stopped after non fatal exception is thrown

[ https://issues.apache.org/jira/browse/KAFKA-6649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16399022#comment-16399022 ] Julio Ng commented on KAFKA-6649: - The investigation for our OutOfRangeException doesn't look like it had

[jira] [Commented] (KAFKA-6645) Host Affinity to facilitate faster restarts of kafka streams applications

[ https://issues.apache.org/jira/browse/KAFKA-6645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16399068#comment-16399068 ] Guozhang Wang commented on KAFKA-6645: -- Hi Giridhar, I think I understand your issue now. What you

[jira] [Commented] (KAFKA-6656) Use non-zero status code when kafka-configs.sh fails

[ https://issues.apache.org/jira/browse/KAFKA-6656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16399077#comment-16399077 ] ASF GitHub Bot commented on KAFKA-6656: --- hachikuji opened a new pull request #4711: KAFKA-6656;

[jira] [Created] (KAFKA-6656) Use non-zero status code when kafka-configs.sh fails

Jason Gustafson created KAFKA-6656: -- Summary: Use non-zero status code when kafka-configs.sh fails Key: KAFKA-6656 URL: https://issues.apache.org/jira/browse/KAFKA-6656 Project: Kafka Issue

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

[ https://issues.apache.org/jira/browse/KAFKA-4392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16398662#comment-16398662 ] Srini commented on KAFKA-4392: -- I am using 1.0.1. Getting this error consistently. Failed to lock the state

[jira] [Created] (KAFKA-6655) CleanupThread] Failed to lock the state directory due to an unexpected exception

Srini created KAFKA-6655: Summary: CleanupThread] Failed to lock the state directory due to an unexpected exception Key: KAFKA-6655 URL: https://issues.apache.org/jira/browse/KAFKA-6655 Project: Kafka

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

[ https://issues.apache.org/jira/browse/KAFKA-4392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16399430#comment-16399430 ] Srini commented on KAFKA-4392: -- @matthias I am running on Windows > Failed to lock the state directory due

[jira] [Updated] (KAFKA-6655) CleanupThread] Failed to lock the state directory due to an unexpected exception

[ https://issues.apache.org/jira/browse/KAFKA-6655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6655: --- Component/s: (was: clients) streams > CleanupThread] Failed to lock the

[jira] [Resolved] (KAFKA-6655) CleanupThread] Failed to lock the state directory due to an unexpected exception

[ https://issues.apache.org/jira/browse/KAFKA-6655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6655. Resolution: Duplicate > CleanupThread] Failed to lock the state directory due to an

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

[ https://issues.apache.org/jira/browse/KAFKA-4392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16399461#comment-16399461 ] Matthias J. Sax commented on KAFKA-4392: I just saw that you create KAFKA-6655 that duplicate this

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

[ https://issues.apache.org/jira/browse/KAFKA-4392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16399461#comment-16399461 ] Matthias J. Sax edited comment on KAFKA-4392 at 3/14/18 9:40 PM: - I just

[jira] [Created] (KAFKA-6658) Fix RoundTripWorkload and make k/v generation configurable

Colin P. McCabe created KAFKA-6658: -- Summary: Fix RoundTripWorkload and make k/v generation configurable Key: KAFKA-6658 URL: https://issues.apache.org/jira/browse/KAFKA-6658 Project: Kafka

[jira] [Commented] (KAFKA-6658) Fix RoundTripWorkload and make k/v generation configurable

[ https://issues.apache.org/jira/browse/KAFKA-6658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16399101#comment-16399101 ] Colin P. McCabe commented on KAFKA-6658: https://github.com/apache/kafka/pull/4710/files > Fix

[jira] [Created] (KAFKA-6660) Monitoring number of messages expired due to retention policy

Matt Garbis created KAFKA-6660: -- Summary: Monitoring number of messages expired due to retention policy Key: KAFKA-6660 URL: https://issues.apache.org/jira/browse/KAFKA-6660 Project: Kafka

[jira] [Commented] (KAFKA-6647) KafkaStreams.cleanUp creates .lock file in directory its trying to clean

[ https://issues.apache.org/jira/browse/KAFKA-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16399347#comment-16399347 ] Guozhang Wang commented on KAFKA-6647: -- Hi George, By looking into your issue, I think the root

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

[ https://issues.apache.org/jira/browse/KAFKA-4392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16399364#comment-16399364 ] Matthias J. Sax commented on KAFKA-4392: [~hana] Are you running on Linux or Windows? > Failed to

[jira] [Comment Edited] (KAFKA-6303) Potential lack of synchronization in NioEchoServer#AcceptorThread

[ https://issues.apache.org/jira/browse/KAFKA-6303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16333251#comment-16333251 ] Ted Yu edited comment on KAFKA-6303 at 3/14/18 8:36 PM: +1 was (Author:

[jira] [Commented] (KAFKA-6647) KafkaStreams.cleanUp creates .lock file in directory its trying to clean

[ https://issues.apache.org/jira/browse/KAFKA-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16399362#comment-16399362 ] Guozhang Wang commented on KAFKA-6647: -- Just another note, for locking purposes, when the apps

[jira] [Commented] (KAFKA-6645) Host Affinity to facilitate faster restarts of kafka streams applications

[ https://issues.apache.org/jira/browse/KAFKA-6645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16399360#comment-16399360 ] Matthias J. Sax commented on KAFKA-6645: About code pointer:

[jira] [Commented] (KAFKA-6647) KafkaStreams.cleanUp creates .lock file in directory its trying to clean

[ https://issues.apache.org/jira/browse/KAFKA-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16399532#comment-16399532 ] George Bloggs commented on KAFKA-6647: -- Guozhang. I have not submitted any PRs. I too commented on

[jira] [Resolved] (KAFKA-6640) Improve efficiency of KafkaAdminClient.describeTopics()

[ https://issues.apache.org/jira/browse/KAFKA-6640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6640. Resolution: Fixed Fix Version/s: 1.2.0 > Improve efficiency of

[jira] [Comment Edited] (KAFKA-6647) KafkaStreams.cleanUp creates .lock file in directory its trying to clean

[ https://issues.apache.org/jira/browse/KAFKA-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16399532#comment-16399532 ] George Bloggs edited comment on KAFKA-6647 at 3/14/18 10:16 PM: Guozhang.

[jira] [Commented] (KAFKA-6647) KafkaStreams.cleanUp creates .lock file in directory its trying to clean

[ https://issues.apache.org/jira/browse/KAFKA-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16399545#comment-16399545 ] Matthias J. Sax commented on KAFKA-6647: I just opened a related PR: