[jira] [Created] (KAFKA-6563) Kafka online backup

Werner Daehn created KAFKA-6563: --- Summary: Kafka online backup Key: KAFKA-6563 URL: https://issues.apache.org/jira/browse/KAFKA-6563 Project: Kafka Issue Type: Improvement Components:

[jira] [Commented] (KAFKA-6536) Streams quickstart pom.xml is missing versions for a bunch of plugins

[ https://issues.apache.org/jira/browse/KAFKA-6536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16365411#comment-16365411 ] Yaswanth Kumar commented on KAFKA-6536: --- Great thanks! > Streams quickstart pom.xml

[jira] [Created] (KAFKA-6564) Fix broken links in Dockerfile

Andriy Sorokhtey created KAFKA-6564: --- Summary: Fix broken links in Dockerfile Key: KAFKA-6564 URL: https://issues.apache.org/jira/browse/KAFKA-6564 Project: Kafka Issue Type: Test

[jira] [Commented] (KAFKA-6564) Fix broken links in Dockerfile

[ https://issues.apache.org/jira/browse/KAFKA-6564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16365510#comment-16365510 ] Manikumar commented on KAFKA-6564: -- This was fixed in -KAFKA-6247-  > Fix broken links i

[jira] [Resolved] (KAFKA-6240) Support dynamic updates of frequently updated broker configs

[ https://issues.apache.org/jira/browse/KAFKA-6240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-6240. --- Resolution: Fixed Fix Version/s: (was: 1.2.0) 1.1.0 > Support dy

[jira] [Commented] (KAFKA-6564) Fix broken links in Dockerfile

[ https://issues.apache.org/jira/browse/KAFKA-6564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16365551#comment-16365551 ] Andriy Sorokhtey commented on KAFKA-6564: - Hi [~omkreddy], Thanks for quick respo

[jira] [Resolved] (KAFKA-2167) ZkUtils updateEphemeralPath JavaDoc (spelling and correctness)

[ https://issues.apache.org/jira/browse/KAFKA-2167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2167. -- Resolution: Fixed > ZkUtils updateEphemeralPath JavaDoc (spelling and correctness) > ---

[jira] [Commented] (KAFKA-6512) Java Producer: Excessive memory usage with compression enabled

[ https://issues.apache.org/jira/browse/KAFKA-6512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16365989#comment-16365989 ] ASF GitHub Bot commented on KAFKA-6512: --- rajinisivaram closed pull request #4570: KA

[jira] [Commented] (KAFKA-4277) creating ephemeral node already exist

[ https://issues.apache.org/jira/browse/KAFKA-4277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366008#comment-16366008 ] Nico Meyer commented on KAFKA-4277: --- We also just encountered the same problem. Kafka 0.

[jira] [Commented] (KAFKA-6502) Kafka streams deserialization handler not committing offsets on error records

[ https://issues.apache.org/jira/browse/KAFKA-6502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366010#comment-16366010 ] Matthias J. Sax commented on KAFKA-6502: If we really change the timestamp handlin

[jira] [Comment Edited] (KAFKA-4277) creating ephemeral node already exist

[ https://issues.apache.org/jira/browse/KAFKA-4277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366008#comment-16366008 ] Nico Meyer edited comment on KAFKA-4277 at 2/15/18 5:47 PM: We

[jira] [Resolved] (KAFKA-6512) Java Producer: Excessive memory usage with compression enabled

[ https://issues.apache.org/jira/browse/KAFKA-6512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-6512. --- Resolution: Fixed Fix Version/s: (was: 1.2.0) 1.1.0 Implemented

[jira] [Updated] (KAFKA-5285) Optimize upper / lower byte range for key range scan on windowed stores

[ https://issues.apache.org/jira/browse/KAFKA-5285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5285: - Summary: Optimize upper / lower byte range for key range scan on windowed stores (was: optimize u

[jira] [Commented] (KAFKA-5285) Optimize upper / lower byte range for key range scan on windowed stores

[ https://issues.apache.org/jira/browse/KAFKA-5285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366165#comment-16366165 ] Guozhang Wang commented on KAFKA-5285: -- [~davispw] [~xvrl] Thinking about this a bit

[jira] [Issue Comment Deleted] (KAFKA-5285) Optimize upper / lower byte range for key range scan on windowed stores

[ https://issues.apache.org/jira/browse/KAFKA-5285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5285: - Comment: was deleted (was: [~davispw] [~xvrl] Thinking about this a bit more, I think we can provi

[jira] [Commented] (KAFKA-6517) ZooKeeperClient holds a lock while waiting for responses, blocking shutdown

[ https://issues.apache.org/jira/browse/KAFKA-6517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366212#comment-16366212 ] ASF GitHub Bot commented on KAFKA-6517: --- rajinisivaram closed pull request #4551: KA

[jira] [Created] (KAFKA-6565) Sudden unresponsiveness from broker + file descriptor leak

Noam Berman created KAFKA-6565: -- Summary: Sudden unresponsiveness from broker + file descriptor leak Key: KAFKA-6565 URL: https://issues.apache.org/jira/browse/KAFKA-6565 Project: Kafka Issue Ty

[jira] [Updated] (KAFKA-6565) Sudden unresponsiveness from broker + file descriptor leak

[ https://issues.apache.org/jira/browse/KAFKA-6565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Noam Berman updated KAFKA-6565: --- Environment: 3 separate clusters running 0.10.1.0 with 5 nodes + 5 zookeepers. clients are mostly jav

[jira] [Updated] (KAFKA-6565) Sudden unresponsiveness from broker + file descriptor leak

[ https://issues.apache.org/jira/browse/KAFKA-6565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Noam Berman updated KAFKA-6565: --- Description: Running 3 kafka clusters v0.10.1.0  on aws, 5 brokers each (+5 zookeepers), in the past

[jira] [Resolved] (KAFKA-6549) Deadlock while processing Controller Events

[ https://issues.apache.org/jira/browse/KAFKA-6549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-6549. --- Resolution: Fixed Fixed under KAFKA-6517. > Deadlock while processing Controller Events > ---

[jira] [Commented] (KAFKA-5285) Optimize upper / lower byte range for key range scan on windowed stores

[ https://issues.apache.org/jira/browse/KAFKA-5285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366286#comment-16366286 ] Guozhang Wang commented on KAFKA-5285: -- [~davispw] [~xvrl] Thinking about this a bit

[jira] [Updated] (KAFKA-4969) State-store workload-aware StreamsPartitionAssignor

[ https://issues.apache.org/jira/browse/KAFKA-4969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4969: - Fix Version/s: 1.0.1 > State-store workload-aware StreamsPartitionAssignor > -

[jira] [Created] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

Gunnar Morling created KAFKA-6566: - Summary: SourceTask#stop() not called after exception raised in poll() Key: KAFKA-6566 URL: https://issues.apache.org/jira/browse/KAFKA-6566 Project: Kafka

[jira] [Commented] (KAFKA-4969) State-store workload-aware StreamsPartitionAssignor

[ https://issues.apache.org/jira/browse/KAFKA-4969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366299#comment-16366299 ] Matthias J. Sax commented on KAFKA-4969: Should we really close this JIRA? I think

[jira] [Created] (KAFKA-6567) KStreamWindowReduce can be replaced by KStreamWindowAggregate

Guozhang Wang created KAFKA-6567: Summary: KStreamWindowReduce can be replaced by KStreamWindowAggregate Key: KAFKA-6567 URL: https://issues.apache.org/jira/browse/KAFKA-6567 Project: Kafka

[jira] [Commented] (KAFKA-5285) Optimize upper / lower byte range for key range scan on windowed stores

[ https://issues.apache.org/jira/browse/KAFKA-5285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366331#comment-16366331 ] ASF GitHub Bot commented on KAFKA-5285: --- guozhangwang opened a new pull request #457

[jira] [Commented] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366341#comment-16366341 ] Ted Yu commented on KAFKA-6566: --- How about the following change ? {code} diff --git a/conne

[jira] [Commented] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366357#comment-16366357 ] ASF GitHub Bot commented on KAFKA-6566: --- tedyu opened a new pull request #4577: KAFK

[jira] [Commented] (KAFKA-5660) Don't throw TopologyBuilderException during runtime

[ https://issues.apache.org/jira/browse/KAFKA-5660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366360#comment-16366360 ] Nick Afshartous commented on KAFKA-5660: Seems like the first sentence of the desc

[jira] [Created] (KAFKA-6568) LogCleanerManager.doneDeleting() should check the partition state before deleting the in progress partition

Jiangjie Qin created KAFKA-6568: --- Summary: LogCleanerManager.doneDeleting() should check the partition state before deleting the in progress partition Key: KAFKA-6568 URL: https://issues.apache.org/jira/browse/KAFKA

[jira] [Updated] (KAFKA-6568) LogCleanerManager.doneDeleting() should check the partition state before deleting the in progress partition

[ https://issues.apache.org/jira/browse/KAFKA-6568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-6568: Description: {{LogCleanerManager.doneDeleting()}} removes the partition from the {{inProgress}} map

[jira] [Updated] (KAFKA-6568) LogCleanerManager.doneDeleting() should check the partition state before deleting the in progress partition

[ https://issues.apache.org/jira/browse/KAFKA-6568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-6568: Priority: Blocker (was: Critical) > LogCleanerManager.doneDeleting() should check the partition sta

[jira] [Updated] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-6566: - Component/s: KafkaConnect > SourceTask#stop() not called after exception raised in poll() > --

[jira] [Commented] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366382#comment-16366382 ] Randall Hauch commented on KAFKA-6566: -- [~te...@apache.org], maybe we should first un

[jira] [Commented] (KAFKA-6560) Use single-point queries than range queries for windowed aggregation operators

[ https://issues.apache.org/jira/browse/KAFKA-6560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366392#comment-16366392 ] ASF GitHub Bot commented on KAFKA-6560: --- guozhangwang opened a new pull request #457

[jira] [Commented] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366390#comment-16366390 ] Randall Hauch commented on KAFKA-6566: -- Also, if we're not calling {{stop()}} on the

[jira] [Updated] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gunnar Morling updated KAFKA-6566: -- Affects Version/s: 1.0.0 > SourceTask#stop() not called after exception raised in poll() > -

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

[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366398#comment-16366398 ] Ashish Surana commented on KAFKA-6555: -- Raised PR @[https://github.com/apache/kafka/p

[jira] [Assigned] (KAFKA-5285) Optimize upper / lower byte range for key range scan on windowed stores

[ https://issues.apache.org/jira/browse/KAFKA-5285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5285: Assignee: Guozhang Wang (was: Xavier Léauté) > Optimize upper / lower byte range for key r

[jira] [Reopened] (KAFKA-4969) State-store workload-aware StreamsPartitionAssignor

[ https://issues.apache.org/jira/browse/KAFKA-4969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-4969: -- > State-store workload-aware StreamsPartitionAssignor >

[jira] [Commented] (KAFKA-4969) State-store workload-aware StreamsPartitionAssignor

[ https://issues.apache.org/jira/browse/KAFKA-4969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366399#comment-16366399 ] Guozhang Wang commented on KAFKA-4969: -- Yup, re-opening to keep track. > State-store

[jira] [Commented] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366404#comment-16366404 ] Ted Yu commented on KAFKA-6566: --- Thanks for the comment, Randall. I did a quick search but

[jira] [Resolved] (KAFKA-6541) StackOverflow exceptions in thread 'kafka-coordinator-heartbeat-thread

[ https://issues.apache.org/jira/browse/KAFKA-6541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6541. Resolution: Duplicate Closing as duplicate for now. Please reopen if you think the issue has

[jira] [Commented] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366411#comment-16366411 ] Gunnar Morling commented on KAFKA-6566: --- +1 for more exploration whether calling sto

[jira] [Commented] (KAFKA-6541) StackOverflow exceptions in thread 'kafka-coordinator-heartbeat-thread

[ https://issues.apache.org/jira/browse/KAFKA-6541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366412#comment-16366412 ] ASF GitHub Bot commented on KAFKA-6541: --- hachikuji closed pull request #4548: KAFKA-

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

[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Surana updated KAFKA-6555: - Description: State store in Kafka streams are currently only queryable when StreamTask is in RUNN

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

[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16361515#comment-16361515 ] Ashish Surana edited comment on KAFKA-6555 at 2/15/18 11:42 PM:

[jira] [Commented] (KAFKA-5660) Don't throw TopologyBuilderException during runtime

[ https://issues.apache.org/jira/browse/KAFKA-5660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366448#comment-16366448 ] Matthias J. Sax commented on KAFKA-5660: Thanks, [~nafshartous]. I updated the des

[jira] [Updated] (KAFKA-5660) Don't throw TopologyBuilderException during runtime

[ https://issues.apache.org/jira/browse/KAFKA-5660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5660: --- Description: {{TopologyBuilderException}} is a pre-runtime exception that should only be thro

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

[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366459#comment-16366459 ] Matthias J. Sax commented on KAFKA-6555: I had a quick look at the PR and I am not

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

[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-6555: -- Assignee: Ashish Surana > Making state store queryable during restoration > ---

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

[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366462#comment-16366462 ] Matthias J. Sax commented on KAFKA-6555: [~asurana] I added you to the list of con

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

[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366471#comment-16366471 ] Ashish Surana edited comment on KAFKA-6555 at 2/16/18 12:44 AM:

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

[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366471#comment-16366471 ] Ashish Surana commented on KAFKA-6555: -- Sure. This approach: Basically here we are a

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

[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366471#comment-16366471 ] Ashish Surana edited comment on KAFKA-6555 at 2/16/18 12:44 AM:

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

[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366471#comment-16366471 ] Ashish Surana edited comment on KAFKA-6555 at 2/16/18 12:45 AM:

[jira] [Comment Edited] (KAFKA-5802) ScramServerCallbackHandler#handle should check username not being null before calling credentialCache.get()

[ https://issues.apache.org/jira/browse/KAFKA-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16302643#comment-16302643 ] Ted Yu edited comment on KAFKA-5802 at 2/16/18 12:52 AM: - +1 from

[jira] [Comment Edited] (KAFKA-5285) Optimize upper / lower byte range for key range scan on windowed stores

[ https://issues.apache.org/jira/browse/KAFKA-5285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366286#comment-16366286 ] Guozhang Wang edited comment on KAFKA-5285 at 2/16/18 12:56 AM:

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

[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366493#comment-16366493 ] Matthias J. Sax commented on KAFKA-6555: Your observation is correct. Using Standb

[jira] [Commented] (KAFKA-4277) creating ephemeral node already exist

[ https://issues.apache.org/jira/browse/KAFKA-4277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366546#comment-16366546 ] Jun Rao commented on KAFKA-4277: [~nico.meyer], do you know if the conflicting ephemeral n

[jira] [Commented] (KAFKA-6568) LogCleanerManager.doneDeleting() should check the partition state before deleting the in progress partition

[ https://issues.apache.org/jira/browse/KAFKA-6568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16366569#comment-16366569 ] ASF GitHub Bot commented on KAFKA-6568: --- becketqin opened a new pull request #4580: