[jira] [Commented] (KAFKA-6360) RocksDB segments not removed when store is closed causes re-initialization to fail

[ https://issues.apache.org/jira/browse/KAFKA-6360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16290670#comment-16290670 ] ASF GitHub Bot commented on KAFKA-6360: --- GitHub user dguy opened a pull request:

[jira] [Commented] (KAFKA-5123) Refactor ZkUtils readData* methods

[ https://issues.apache.org/jira/browse/KAFKA-5123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16290704#comment-16290704 ] ASF GitHub Bot commented on KAFKA-5123: --- Github user baluchicken closed the pull req

[jira] [Resolved] (KAFKA-5123) Refactor ZkUtils readData* methods

[ https://issues.apache.org/jira/browse/KAFKA-5123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Balint Molnar resolved KAFKA-5123. -- Resolution: Won't Fix > Refactor ZkUtils readData* methods > --

[jira] [Updated] (KAFKA-6361) Fast leader fail over can lead to log divergence between leader and follower

[ https://issues.apache.org/jira/browse/KAFKA-6361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-6361: --- Labels: reliability (was: ) > Fast leader fail over can lead to log divergence between leader and fol

[jira] [Updated] (KAFKA-6199) Single broker with fast growing heap usage

[ https://issues.apache.org/jira/browse/KAFKA-6199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robin Tweedie updated KAFKA-6199: - Attachment: jstack-2017-12-08.scrubbed.out Apologies for the delay in uploading this, I took a sna

[jira] [Created] (KAFKA-6362) auto commit not work since coordinatorUnknown() is always true.

Renkai Ge created KAFKA-6362: Summary: auto commit not work since coordinatorUnknown() is always true. Key: KAFKA-6362 URL: https://issues.apache.org/jira/browse/KAFKA-6362 Project: Kafka Issue

[jira] [Updated] (KAFKA-6362) auto commit not work since coordinatorUnknown() is always true.

[ https://issues.apache.org/jira/browse/KAFKA-6362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renkai Ge updated KAFKA-6362: - Description: {code} [2017-12-14 20:09:23.501] [Kafka 0.10 Fetcher for Source: source_bj-docker-large (14/

[jira] [Commented] (KAFKA-6260) AbstractCoordinator not clearly handles NULL Exception

[ https://issues.apache.org/jira/browse/KAFKA-6260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16290783#comment-16290783 ] Rob Gevers commented on KAFKA-6260: --- We ran into this issue as well. In our situation th

[jira] [Resolved] (KAFKA-6350) File descriptors leak with persistent KeyValueStore

[ https://issues.apache.org/jira/browse/KAFKA-6350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alin Gheorghe resolved KAFKA-6350. -- Resolution: Not A Bug > File descriptors leak with persistent KeyValueStore > --

[jira] [Commented] (KAFKA-6350) File descriptors leak with persistent KeyValueStore

[ https://issues.apache.org/jira/browse/KAFKA-6350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16290818#comment-16290818 ] Alin Gheorghe commented on KAFKA-6350: -- Hi [~damianguy]! Thank you for your prompt re

[jira] [Commented] (KAFKA-6350) File descriptors leak with persistent KeyValueStore

[ https://issues.apache.org/jira/browse/KAFKA-6350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16290823#comment-16290823 ] Alin Gheorghe commented on KAFKA-6350: -- P.S.: We haven’t been able to reproduce the f

[jira] [Commented] (KAFKA-6252) A metric named 'XX' already exists, can't register another one.

[ https://issues.apache.org/jira/browse/KAFKA-6252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16291119#comment-16291119 ] Randall Hauch commented on KAFKA-6252: -- No, I don't think there are any workarounds,

[jira] [Resolved] (KAFKA-6360) RocksDB segments not removed when store is closed causes re-initialization to fail

[ https://issues.apache.org/jira/browse/KAFKA-6360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6360. -- Resolution: Fixed Issue resolved by pull request 4324 [https://github.com/apache/kafka/pull/4324

[jira] [Commented] (KAFKA-6360) RocksDB segments not removed when store is closed causes re-initialization to fail

[ https://issues.apache.org/jira/browse/KAFKA-6360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16291263#comment-16291263 ] ASF GitHub Bot commented on KAFKA-6360: --- Github user asfgit closed the pull request

[jira] [Created] (KAFKA-6363) Use MockAdminClient for any unit tests that depend on AdminClient

Guozhang Wang created KAFKA-6363: Summary: Use MockAdminClient for any unit tests that depend on AdminClient Key: KAFKA-6363 URL: https://issues.apache.org/jira/browse/KAFKA-6363 Project: Kafka

[jira] [Updated] (KAFKA-6363) Use MockAdminClient for any unit tests that depend on AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-6363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6363: - Labels: newbie (was: ) > Use MockAdminClient for any unit tests that depend on AdminClient >

[jira] [Commented] (KAFKA-6363) Use MockAdminClient for any unit tests that depend on AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-6363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16291310#comment-16291310 ] Guozhang Wang commented on KAFKA-6363: -- >From the previous discussion: {code} cmccab

[jira] [Created] (KAFKA-6364) Add Second Check for End Offset During Restore

Bill Bejeck created KAFKA-6364: -- Summary: Add Second Check for End Offset During Restore Key: KAFKA-6364 URL: https://issues.apache.org/jira/browse/KAFKA-6364 Project: Kafka Issue Type: Improvem

[jira] [Commented] (KAFKA-5696) SourceConnector does not commit offset on rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16291456#comment-16291456 ] Victor Chicu commented on KAFKA-5696: - Any news? I have the same issue in case of reba

[jira] [Comment Edited] (KAFKA-5696) SourceConnector does not commit offset on rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16291456#comment-16291456 ] Victor Chicu edited comment on KAFKA-5696 at 12/14/17 7:42 PM: -

[jira] [Comment Edited] (KAFKA-5696) SourceConnector does not commit offset on rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16291456#comment-16291456 ] Victor Chicu edited comment on KAFKA-5696 at 12/14/17 7:42 PM: -

[jira] [Issue Comment Deleted] (KAFKA-5696) SourceConnector does not commit offset on rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Chicu updated KAFKA-5696: Comment: was deleted (was: Any news? I have the same issue in case of rebalance if task is killed b

[jira] [Commented] (KAFKA-5696) SourceConnector does not commit offset on rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16291466#comment-16291466 ] Victor Chicu commented on KAFKA-5696: - AI faced the same issue in the following casny

[jira] [Commented] (KAFKA-5722) Refactor ConfigCommand to use the AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16291488#comment-16291488 ] Viktor Somogyi commented on KAFKA-5722: --- [~rsivaram] just wanted to update you, migh

[jira] [Created] (KAFKA-6365) How to add a client to list of available clients?

Lev Gorodinski created KAFKA-6365: - Summary: How to add a client to list of available clients? Key: KAFKA-6365 URL: https://issues.apache.org/jira/browse/KAFKA-6365 Project: Kafka Issue Type:

[jira] [Comment Edited] (KAFKA-5696) SourceConnector does not commit offset on rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16291466#comment-16291466 ] Victor Chicu edited comment on KAFKA-5696 at 12/14/17 8:07 PM: -

[jira] [Commented] (KAFKA-6365) How to add a client to list of available clients?

[ https://issues.apache.org/jira/browse/KAFKA-6365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16291524#comment-16291524 ] Jason Gustafson commented on KAFKA-6365: [~eulerfx] Do you have a username for htt

[jira] [Comment Edited] (KAFKA-5696) SourceConnector does not commit offset on rebalance

[ https://issues.apache.org/jira/browse/KAFKA-5696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16291466#comment-16291466 ] Victor Chicu edited comment on KAFKA-5696 at 12/14/17 8:11 PM: -

[jira] [Commented] (KAFKA-6366) StackOverflowError in kafka-coordinator-heartbeat-thread

[ https://issues.apache.org/jira/browse/KAFKA-6366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16291582#comment-16291582 ] Joerg Heinicke commented on KAFKA-6366: --- Ted Yu already suggested a fix on the maili

[jira] [Created] (KAFKA-6366) StackOverflowError in kafka-coordinator-heartbeat-thread

Joerg Heinicke created KAFKA-6366: - Summary: StackOverflowError in kafka-coordinator-heartbeat-thread Key: KAFKA-6366 URL: https://issues.apache.org/jira/browse/KAFKA-6366 Project: Kafka Issu

[jira] [Updated] (KAFKA-6366) StackOverflowError in kafka-coordinator-heartbeat-thread

[ https://issues.apache.org/jira/browse/KAFKA-6366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6366: -- Attachment: 6366.v1.txt First attempt for fixing the stack overflow > StackOverflowError in kafka-coordinator-h

[jira] [Commented] (KAFKA-6365) How to add a client to list of available clients?

[ https://issues.apache.org/jira/browse/KAFKA-6365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16291595#comment-16291595 ] Lev Gorodinski commented on KAFKA-6365: --- [~hachikuji] I do, it is *eulerfx*. Thanks!

[jira] [Commented] (KAFKA-5722) Refactor ConfigCommand to use the AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16291597#comment-16291597 ] Rajini Sivaram commented on KAFKA-5722: --- [~viktorsomogyi] Thank you for working on t

[jira] [Commented] (KAFKA-6365) How to add a client to list of available clients?

[ https://issues.apache.org/jira/browse/KAFKA-6365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16291615#comment-16291615 ] Jason Gustafson commented on KAFKA-6365: [~eulerfx] Cool, I've given you permissio

[jira] [Resolved] (KAFKA-6365) How to add a client to list of available clients?

[ https://issues.apache.org/jira/browse/KAFKA-6365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6365. Resolution: Resolved > How to add a client to list of available clients? > -

[jira] [Commented] (KAFKA-6366) StackOverflowError in kafka-coordinator-heartbeat-thread

[ https://issues.apache.org/jira/browse/KAFKA-6366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16291699#comment-16291699 ] Jason Gustafson commented on KAFKA-6366: [~joerg.heinicke] Thanks for reporting th

[jira] [Created] (KAFKA-6367) Fix StateRestoreListener To Use Correct Ending Offset

Bill Bejeck created KAFKA-6367: -- Summary: Fix StateRestoreListener To Use Correct Ending Offset Key: KAFKA-6367 URL: https://issues.apache.org/jira/browse/KAFKA-6367 Project: Kafka Issue Type: B

[jira] [Updated] (KAFKA-6367) Fix StateRestoreListener To Use Correct Ending Offset

[ https://issues.apache.org/jira/browse/KAFKA-6367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-6367: --- Description: {{StateRestoreListener#restoreBatchCompleted}} takes the {{nextPosition}} long but the

[jira] [Updated] (KAFKA-6367) Fix StateRestoreListener To Use Correct Ending Offset

[ https://issues.apache.org/jira/browse/KAFKA-6367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-6367: --- Description: {{StateRestoreListener#restoreBatchCompleted}} takes the {{nextPosition}} long but the

[jira] [Assigned] (KAFKA-6367) Fix StateRestoreListener To Use Correct Ending Offset

[ https://issues.apache.org/jira/browse/KAFKA-6367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-6367: -- Assignee: Bill Bejeck > Fix StateRestoreListener To Use Correct Ending Offset > ---

[jira] [Commented] (KAFKA-6311) Expose Kafka cluster ID in Connect REST API

[ https://issues.apache.org/jira/browse/KAFKA-6311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16291735#comment-16291735 ] Randall Hauch commented on KAFKA-6311: -- And KIP is available here: https://cwiki.apa

[jira] [Resolved] (KAFKA-6102) Consolidate MockTime implementations between connect and clients

[ https://issues.apache.org/jira/browse/KAFKA-6102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6102. Resolution: Fixed Fix Version/s: 1.0.1 Issue resolved by pull request 4105 [https://g

[jira] [Commented] (KAFKA-6102) Consolidate MockTime implementations between connect and clients

[ https://issues.apache.org/jira/browse/KAFKA-6102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16291749#comment-16291749 ] ASF GitHub Bot commented on KAFKA-6102: --- Github user asfgit closed the pull request

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

[ https://issues.apache.org/jira/browse/KAFKA-3821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16291750#comment-16291750 ] Randall Hauch commented on KAFKA-3821: -- [~gunnar.morling], no, there is no KIP for th

[jira] [Created] (KAFKA-6368) AdminClient should contact multiple nodes before timing out a call

Colin P. McCabe created KAFKA-6368: -- Summary: AdminClient should contact multiple nodes before timing out a call Key: KAFKA-6368 URL: https://issues.apache.org/jira/browse/KAFKA-6368 Project: Kafka

[jira] [Updated] (KAFKA-6368) AdminClient should contact multiple nodes before timing out a call

[ https://issues.apache.org/jira/browse/KAFKA-6368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-6368: --- Affects Version/s: (was: 0.10.1.0) 0.11.0.0 > AdminClient should co

[jira] [Commented] (KAFKA-6308) Connect: Struct equals/hashCode method should use Arrays#deep* methods

[ https://issues.apache.org/jira/browse/KAFKA-6308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16291794#comment-16291794 ] ASF GitHub Bot commented on KAFKA-6308: --- Github user asfgit closed the pull request

[jira] [Resolved] (KAFKA-6308) Connect: Struct equals/hashCode method should use Arrays#deep* methods

[ https://issues.apache.org/jira/browse/KAFKA-6308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6308. Resolution: Fixed Fix Version/s: 1.0.1 Issue resolved by pull request 4293 [https://g

[jira] [Commented] (KAFKA-6361) Fast leader fail over can lead to log divergence between leader and follower

[ https://issues.apache.org/jira/browse/KAFKA-6361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16291812#comment-16291812 ] Jun Rao commented on KAFKA-6361: [~hachikuji], thanks for the info. The problem in the des

[jira] [Created] (KAFKA-6369) General wildcard support for ACL's in kafka

Antony Stubbs created KAFKA-6369: Summary: General wildcard support for ACL's in kafka Key: KAFKA-6369 URL: https://issues.apache.org/jira/browse/KAFKA-6369 Project: Kafka Issue Type: New Fea

[jira] [Commented] (KAFKA-6363) Use MockAdminClient for any unit tests that depend on AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-6363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16291888#comment-16291888 ] Colin P. McCabe commented on KAFKA-6363: Thanks for working on refactoring this.

[jira] [Commented] (KAFKA-6362) auto commit not work since coordinatorUnknown() is always true.

[ https://issues.apache.org/jira/browse/KAFKA-6362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16291952#comment-16291952 ] ASF GitHub Bot commented on KAFKA-6362: --- GitHub user huxihx opened a pull request:

[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=16291962#comment-16291962 ] Peter Davis commented on KAFKA-5285: In debugging a recent performance blocker in an a

[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=16291962#comment-16291962 ] Peter Davis edited comment on KAFKA-5285 at 12/15/17 3:08 AM: --

[jira] [Created] (KAFKA-6370) MirrorMakerIntegrationTest#testCommaSeparatedRegex may fail due to NullPointerException

Ted Yu created KAFKA-6370: - Summary: MirrorMakerIntegrationTest#testCommaSeparatedRegex may fail due to NullPointerException Key: KAFKA-6370 URL: https://issues.apache.org/jira/browse/KAFKA-6370 Project: Kafk

[jira] [Commented] (KAFKA-6367) Fix StateRestoreListener To Use Correct Ending Offset

[ https://issues.apache.org/jira/browse/KAFKA-6367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16292054#comment-16292054 ] Matthias J. Sax commented on KAFKA-6367: {quote} We can't automatically use {{next