[jira] [Commented] (KAFKA-6666) OffsetOutOfRangeException: Replica Thread Stopped Resulting in Underreplicated Partitions

[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401411#comment-16401411 ] huxihx commented on KAFKA-: --- The exception is caused by the fact that high watermark was set to -1 which

[jira] [Assigned] (KAFKA-6663) Expression for GlobalKTable is not correct

[ https://issues.apache.org/jira/browse/KAFKA-6663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-6663: - Assignee: huxihx > Expression for GlobalKTable is not correct >

[jira] [Commented] (KAFKA-6663) Expression for GlobalKTable is not correct

[ https://issues.apache.org/jira/browse/KAFKA-6663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401407#comment-16401407 ] ASF GitHub Bot commented on KAFKA-6663: --- huxihx opened a new pull request #4723: KAFKA-6663: Doc for

[jira] [Commented] (KAFKA-6666) OffsetOutOfRangeException: Replica Thread Stopped Resulting in Underreplicated Partitions

[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401387#comment-16401387 ] Srinivas Dhruvakumar commented on KAFKA-: - Looking at the other issue . Is there any fix

[jira] [Commented] (KAFKA-6666) OffsetOutOfRangeException: Replica Thread Stopped Resulting in Underreplicated Partitions

[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401353#comment-16401353 ] huxihx commented on KAFKA-: --- Seems it's a duplicate of

[jira] [Commented] (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:comment-tabpanel=16401313#comment-16401313 ] ASF GitHub Bot commented on KAFKA-3978: --- lindong28 opened a new pull request #4722: MINOR KAFKA-3978

[jira] [Commented] (KAFKA-6651) SchemaBuilder should not allow Arrays or Maps to be created by type()

[ https://issues.apache.org/jira/browse/KAFKA-6651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401270#comment-16401270 ] Ewen Cheslack-Postava commented on KAFKA-6651: -- Could go either way. Based on the comment, I

[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=16401263#comment-16401263 ] Jason Gustafson commented on KAFKA-6649: [~julion] The ultimate failure sequence may be different,

[jira] [Updated] (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 updated KAFKA-3978: --- Fix Version/s: (was: 1.2.0) 1.1.0 > Cannot truncate to a negative

[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=16401255#comment-16401255 ] Ewen Cheslack-Postava commented on KAFKA-6661: -- Oh, also, I marked it as 1.1.1 release, but

[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=16401254#comment-16401254 ] Ewen Cheslack-Postava commented on KAFKA-6661: -- [~rhauch] Got this cherry-picked back to

[jira] [Updated] (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:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-6661: - Fix Version/s: 1.1.1 1.0.2 0.11.0.3

[jira] [Updated] (KAFKA-6666) OffsetOutOfRangeException: Replica Thread Stopped Resulting in Underreplicated Partitions

[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Srinivas Dhruvakumar updated KAFKA-: Priority: Critical (was: Major) > OffsetOutOfRangeException: Replica Thread

[jira] [Commented] (KAFKA-6666) OffsetOutOfRangeException: Replica Thread Stopped Resulting in Underreplicated Partitions

[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401235#comment-16401235 ] Srinivas Dhruvakumar commented on KAFKA-: - This is consistently happening in our test

[jira] [Created] (KAFKA-6666) OffsetOutOfRangeException: Replica Thread Stopped Resulting in Underreplicated Partitions

Srinivas Dhruvakumar created KAFKA-: --- Summary: OffsetOutOfRangeException: Replica Thread Stopped Resulting in Underreplicated Partitions Key: KAFKA- URL:

[jira] [Comment Edited] (KAFKA-6335) SimpleAclAuthorizerTest#testHighConcurrencyModificationOfResourceAcls fails intermittently

[ https://issues.apache.org/jira/browse/KAFKA-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16392410#comment-16392410 ] Ted Yu edited comment on KAFKA-6335 at 3/15/18 11:01 PM: - Happened again:

[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=16401219#comment-16401219 ] ASF GitHub Bot commented on KAFKA-6661: --- ewencp closed pull request #4716: KAFKA-6661: Ensure sink

[jira] [Updated] (KAFKA-6608) Add TimeoutException to KafkaConsumer#position()

[ https://issues.apache.org/jira/browse/KAFKA-6608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6608: --- Description: In KAFKA-4879, Kafka Consumer hangs indefinitely due to Fetcher's {{timeout}}

[jira] [Updated] (KAFKA-6608) Add TimeoutException to KafkaConsumer#position()

[ https://issues.apache.org/jira/browse/KAFKA-6608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6608: --- Labels: kip (was: needs-discussion needs-kip) > Add TimeoutException to

[jira] [Resolved] (KAFKA-6106) Postpone normal processing of tasks within a thread until restoration of all tasks have completed

[ https://issues.apache.org/jira/browse/KAFKA-6106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6106. Resolution: Fixed > Postpone normal processing of tasks within a thread until restoration

[jira] [Updated] (KAFKA-6106) Postpone normal processing of tasks within a thread until restoration of all tasks have completed

[ https://issues.apache.org/jira/browse/KAFKA-6106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6106: --- Fix Version/s: 1.2.0 1.1.1 > Postpone normal processing of tasks within a

[jira] [Commented] (KAFKA-6106) Postpone normal processing of tasks within a thread until restoration of all tasks have completed

[ https://issues.apache.org/jira/browse/KAFKA-6106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401033#comment-16401033 ] ASF GitHub Bot commented on KAFKA-6106: --- mjsax closed pull request #4651: KAFKA-6106: Postpone

[jira] [Assigned] (KAFKA-6664) KIP-269 Substitution Within Configuration Values

[ https://issues.apache.org/jira/browse/KAFKA-6664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ron Dagostino reassigned KAFKA-6664: Assignee: Ron Dagostino > KIP-269 Substitution Within Configuration Values >

[jira] [Assigned] (KAFKA-6562) KIP-255: OAuth Authentication via SASL/OAUTHBEARER

[ https://issues.apache.org/jira/browse/KAFKA-6562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ron Dagostino reassigned KAFKA-6562: Assignee: Ron Dagostino > KIP-255: OAuth Authentication via SASL/OAUTHBEARER >

[jira] [Updated] (KAFKA-6665) LeaderChangeListener.handleDataDeleted deadlock

[ https://issues.apache.org/jira/browse/KAFKA-6665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmitry Konstantinov updated KAFKA-6665: --- Attachment: thread_dump.txt > LeaderChangeListener.handleDataDeleted deadlock >

[jira] [Created] (KAFKA-6665) LeaderChangeListener.handleDataDeleted deadlock

Dmitry Konstantinov created KAFKA-6665: -- Summary: LeaderChangeListener.handleDataDeleted deadlock Key: KAFKA-6665 URL: https://issues.apache.org/jira/browse/KAFKA-6665 Project: Kafka

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

[ https://issues.apache.org/jira/browse/KAFKA-6660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400952#comment-16400952 ] Matt Garbis commented on KAFKA-6660: [~mjsax] – could you (or someone else) please review this when

[jira] [Updated] (KAFKA-6663) Expression for GlobalKTable is not correct

[ https://issues.apache.org/jira/browse/KAFKA-6663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6663: --- Component/s: streams > Expression for GlobalKTable is not correct >

[jira] [Commented] (KAFKA-6663) Expression for GlobalKTable is not correct

[ https://issues.apache.org/jira/browse/KAFKA-6663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400914#comment-16400914 ] Matthias J. Sax commented on KAFKA-6663: You are right. It should be `all` partitions. >

[jira] [Commented] (KAFKA-6474) Rewrite test to use new public TopologyTestDriver

[ https://issues.apache.org/jira/browse/KAFKA-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400912#comment-16400912 ] John Roesler commented on KAFKA-6474: - Hi Filipe, I hope you're doing well. I'm trying to figure out

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

[ https://issues.apache.org/jira/browse/KAFKA-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400900#comment-16400900 ] Guozhang Wang commented on KAFKA-6647: -- [~mjsax] [~gbloggs] As explained in the link I posted

[jira] [Updated] (KAFKA-6664) KIP-269 Substitution Within Configuration Values

[ https://issues.apache.org/jira/browse/KAFKA-6664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ron Dagostino updated KAFKA-6664: - Description: KIP 269 (Substitution Within Configuration Values) proposes adding support for

[jira] [Created] (KAFKA-6664) KIP-270 Substitution Within Configuration Values

Ron Dagostino created KAFKA-6664: Summary: KIP-270 Substitution Within Configuration Values Key: KAFKA-6664 URL: https://issues.apache.org/jira/browse/KAFKA-6664 Project: Kafka Issue Type:

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

[ https://issues.apache.org/jira/browse/KAFKA-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400819#comment-16400819 ] George Bloggs commented on KAFKA-6647: -- I will check this in the morning and update this issue. The

[jira] [Resolved] (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:all-tabpanel ] Jason Gustafson resolved KAFKA-6656. Resolution: Fixed Fix Version/s: 1.2.0 > Use non-zero status code when

[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=16400785#comment-16400785 ] ASF GitHub Bot commented on KAFKA-6656: --- hachikuji closed pull request #4711: KAFKA-6656; Config

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

[ https://issues.apache.org/jira/browse/KAFKA-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6647: --- Summary: KafkaStreams.cleanUp creates .lock file in directory its trying to clean (Windows

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

[ https://issues.apache.org/jira/browse/KAFKA-6655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6655: --- Description: This issue happens on Windows OS. It code works fine on Linux. This ticket is

[jira] [Reopened] (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 reopened KAFKA-6655: > CleanupThread] Failed to lock the state directory due to an unexpected > exception >

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

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

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

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

[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=16400735#comment-16400735 ] Matthias J. Sax commented on KAFKA-4392: https://issues.apache.org/jira/browse/KAFKA-6647 Seems to

[jira] [Commented] (KAFKA-6351) libs directory has duplicate javassist jars

[ https://issues.apache.org/jira/browse/KAFKA-6351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400488#comment-16400488 ] ASF GitHub Bot commented on KAFKA-6351: --- omkreddy opened a new pull request #4719: KAFKA-6351:

[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=16400336#comment-16400336 ] Srini commented on KAFKA-4392: -- [~mjsax] Yes, I did set the path and can view the contents. In fact, I

[jira] [Created] (KAFKA-6663) Expression for GlobalKTable is not correct

huxihx created KAFKA-6663: - Summary: Expression for GlobalKTable is not correct Key: KAFKA-6663 URL: https://issues.apache.org/jira/browse/KAFKA-6663 Project: Kafka Issue Type: Bug

[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=16400125#comment-16400125 ] George Bloggs commented on KAFKA-6647: -- As mentioned earlier, in our code I have implemented the

[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=16400055#comment-16400055 ] Seweryn Habdank-Wojewodzki commented on KAFKA-4392: --- I see it on my Windows workstation

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

[ https://issues.apache.org/jira/browse/KAFKA-6653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6653. Resolution: Fixed Fix Version/s: 1.1.0 > Delayed operations may not be completed

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

[ https://issues.apache.org/jira/browse/KAFKA-6653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400019#comment-16400019 ] ASF GitHub Bot commented on KAFKA-6653: --- hachikuji closed pull request #4704: KAFKA-6653: Complete

[jira] [Issue Comment Deleted] (KAFKA-6662) Consumer use offsetsForTimes() get offset return None.

[ https://issues.apache.org/jira/browse/KAFKA-6662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matt Wang updated KAFKA-6662: - Comment: was deleted (was: the pr is：https://github.com/apache/kafka/pull/4717) > Consumer use

[jira] [Commented] (KAFKA-6662) Consumer use offsetsForTimes() get offset return None.

[ https://issues.apache.org/jira/browse/KAFKA-6662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16399981#comment-16399981 ] Matt Wang commented on KAFKA-6662: -- the pr is：https://github.com/apache/kafka/pull/4717 > Consumer use

[jira] [Created] (KAFKA-6662) Consumer use offsetsForTimes() get offset return None.

Matt Wang created KAFKA-6662: Summary: Consumer use offsetsForTimes() get offset return None. Key: KAFKA-6662 URL: https://issues.apache.org/jira/browse/KAFKA-6662 Project: Kafka Issue Type: Bug

[jira] [Updated] (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:all-tabpanel ] Matthias J. Sax updated KAFKA-6054: --- Description: KIP:

[jira] [Updated] (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:all-tabpanel ] Matthias J. Sax updated KAFKA-6054: --- Fix Version/s: 1.2.0 > ERROR "SubscriptionInfo - unable to decode subscription data:

[jira] [Updated] (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:all-tabpanel ] Matthias J. Sax updated KAFKA-6054: --- Labels: kip (was: needs-kip) > ERROR "SubscriptionInfo - unable to decode subscription data: