[jira] [Commented] (KAFKA-5074) Transition to OnlinePartition without preferred leader in ISR fails

[ https://issues.apache.org/jira/browse/KAFKA-5074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16124325#comment-16124325 ] Pierre Mage commented on KAFKA-5074: Running 0.11.0 and observing similar behaviour.

[jira] [Assigned] (KAFKA-5731) Connect WorkerSinkTask out of order offset commit can lead to inconsistent state

[ https://issues.apache.org/jira/browse/KAFKA-5731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch reassigned KAFKA-5731: Assignee: Randall Hauch > Connect WorkerSinkTask out of order offset commit can lead to inc

[jira] [Created] (KAFKA-5731) Connect WorkerSinkTask out of order offset commit can lead to inconsistent state

Jason Gustafson created KAFKA-5731: -- Summary: Connect WorkerSinkTask out of order offset commit can lead to inconsistent state Key: KAFKA-5731 URL: https://issues.apache.org/jira/browse/KAFKA-5731 Pr

[jira] [Created] (KAFKA-5730) Consumer should ensure consistent ordering between sync and async offset commits

Jason Gustafson created KAFKA-5730: -- Summary: Consumer should ensure consistent ordering between sync and async offset commits Key: KAFKA-5730 URL: https://issues.apache.org/jira/browse/KAFKA-5730 Pr

[jira] [Created] (KAFKA-5729) Consumer should verify offset commits are from assigned partitions

Jason Gustafson created KAFKA-5729: -- Summary: Consumer should verify offset commits are from assigned partitions Key: KAFKA-5729 URL: https://issues.apache.org/jira/browse/KAFKA-5729 Project: Kafka

[jira] [Commented] (KAFKA-5138) MirrorMaker doesn't exit on send failure occasionally

[ https://issues.apache.org/jira/browse/KAFKA-5138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16124149#comment-16124149 ] Tamas Mate commented on KAFKA-5138: --- [~cote] Cool, thanks for the tip, I have just insta

[jira] [Commented] (KAFKA-5138) MirrorMaker doesn't exit on send failure occasionally

[ https://issues.apache.org/jira/browse/KAFKA-5138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16124106#comment-16124106 ] Dustin Cote commented on KAFKA-5138: [~tamas.mate] I've never managed to reproduce it.

[jira] [Resolved] (KAFKA-1379) Partition reassignment resets clock for time-based retention

[ https://issues.apache.org/jira/browse/KAFKA-1379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Olson resolved KAFKA-1379. - Resolution: Fixed Assignee: Jiangjie Qin Fix Version/s: 0.10.1.0 Marking this bug

[jira] [Commented] (KAFKA-4585) KIP-163: Offset fetch and commit requests use the same permissions

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

[jira] [Created] (KAFKA-5728) Stopping consumer thread cause loosing message in the partition

Vasudevan Karnan created KAFKA-5728: --- Summary: Stopping consumer thread cause loosing message in the partition Key: KAFKA-5728 URL: https://issues.apache.org/jira/browse/KAFKA-5728 Project: Kafka

[jira] [Commented] (KAFKA-5714) Allow whitespaces in the principal name

[ https://issues.apache.org/jira/browse/KAFKA-5714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16123932#comment-16123932 ] Alla Tumarkin commented on KAFKA-5714: -- Here is the scenario (actual commands below)

[jira] [Commented] (KAFKA-5727) Add the archetype project along with "write applications" web docs.

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

[jira] [Commented] (KAFKA-5727) Add the archetype project along with "write applications" web docs.

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

[jira] [Resolved] (KAFKA-5727) Add the archetype project along with "write applications" web docs.

[ https://issues.apache.org/jira/browse/KAFKA-5727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5727. -- Resolution: Fixed Fix Version/s: 1.0.0 Issue resolved by pull request 3630 [https://githu

[jira] [Created] (KAFKA-5727) Add the archetype project along with "write applications" web docs.

Guozhang Wang created KAFKA-5727: Summary: Add the archetype project along with "write applications" web docs. Key: KAFKA-5727 URL: https://issues.apache.org/jira/browse/KAFKA-5727 Project: Kafka

[jira] [Commented] (KAFKA-5676) MockStreamsMetrics should be in o.a.k.test

[ https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16123856#comment-16123856 ] Guozhang Wang commented on KAFKA-5676: -- I think StreamTaskTest#testMetrics does depen

[jira] [Commented] (KAFKA-5676) MockStreamsMetrics should be in o.a.k.test

[ https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16123846#comment-16123846 ] Guozhang Wang commented on KAFKA-5676: -- Yeah I think creating a WIP PR and communicat

[jira] [Comment Edited] (KAFKA-4682) Committed offsets should not be deleted if a consumer is still active

[ https://issues.apache.org/jira/browse/KAFKA-4682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16123742#comment-16123742 ] Vahid Hashemian edited comment on KAFKA-4682 at 8/11/17 5:56 PM: ---

[jira] [Commented] (KAFKA-4682) Committed offsets should not be deleted if a consumer is still active

[ https://issues.apache.org/jira/browse/KAFKA-4682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16123742#comment-16123742 ] Vahid Hashemian commented on KAFKA-4682: [~hachikuji] Thank you for your comments.

[jira] [Commented] (KAFKA-5724) AbstractPartitionAssignor does not take into consideration that partition number may start from non-zero

[ https://issues.apache.org/jira/browse/KAFKA-5724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16123631#comment-16123631 ] Allen Wang commented on KAFKA-5724: --- [~hachikuji] Please note that TopicCommand can take

[jira] [Commented] (KAFKA-5724) AbstractPartitionAssignor does not take into consideration that partition number may start from non-zero

[ https://issues.apache.org/jira/browse/KAFKA-5724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16123584#comment-16123584 ] Allen Wang commented on KAFKA-5724: --- [~hachikuji] We have our own topic creation tool wh

[jira] [Commented] (KAFKA-5724) AbstractPartitionAssignor does not take into consideration that partition number may start from non-zero

[ https://issues.apache.org/jira/browse/KAFKA-5724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16123563#comment-16123563 ] Jason Gustafson commented on KAFKA-5724: [~allenxwang] I fear this is not the only

[jira] [Commented] (KAFKA-5562) Do streams state directory cleanup on a single thread

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

[jira] [Updated] (KAFKA-5726) KafkaConsumer.subscribe() overload that takes just Pattern without ConsumerRebalanceListener

[ https://issues.apache.org/jira/browse/KAFKA-5726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5726: --- Description: Request: provide {{subscribe(Pattern pattern)}} overload, similar to {{subscribe(Collect

[jira] [Updated] (KAFKA-5726) KafkaConsumer.subscribe() overload that takes just Pattern without ConsumerRebalanceListener

[ https://issues.apache.org/jira/browse/KAFKA-5726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5726: --- Summary: KafkaConsumer.subscribe() overload that takes just Pattern without ConsumerRebalanceListener

[jira] [Updated] (KAFKA-5726) KafkaConsumer.subscribe() overload that takes just Pattern without ConsumerRebalanceListener

[ https://issues.apache.org/jira/browse/KAFKA-5726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5726: --- Labels: needs-kip newbie usability (was: usability) > KafkaConsumer.subscribe() overload that takes j

[jira] [Created] (KAFKA-5726) KafkaConsumer.subscribe() override that takes just Pattern without ConsumerRebalanceListener

Yeva Byzek created KAFKA-5726: - Summary: KafkaConsumer.subscribe() override that takes just Pattern without ConsumerRebalanceListener Key: KAFKA-5726 URL: https://issues.apache.org/jira/browse/KAFKA-5726

[jira] [Commented] (KAFKA-5723) Refactor BrokerApiVersionsCommand to use the new AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16123482#comment-16123482 ] Andrey Dyachkov commented on KAFKA-5723: Could I try to accomplish that task? It s

[jira] [Commented] (KAFKA-4643) Improve test coverage of StreamsKafkaClient

[ https://issues.apache.org/jira/browse/KAFKA-4643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16123436#comment-16123436 ] Andrey Dyachkov commented on KAFKA-4643: I added a couple of test case for excepti

[jira] [Commented] (KAFKA-4643) Improve test coverage of StreamsKafkaClient

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

[jira] [Created] (KAFKA-5725) Additional failure testing for streams with bouncing brokers

Eno Thereska created KAFKA-5725: --- Summary: Additional failure testing for streams with bouncing brokers Key: KAFKA-5725 URL: https://issues.apache.org/jira/browse/KAFKA-5725 Project: Kafka Iss

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

[ https://issues.apache.org/jira/browse/KAFKA-5722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Viktor Somogyi updated KAFKA-5722: -- Summary: Refactor ConfigCommand to use the new AdminClient (was: Refactor ConfigCommand to use

[jira] [Updated] (KAFKA-5723) Refactor BrokerApiVersionsCommand to use the new AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Viktor Somogyi updated KAFKA-5723: -- Summary: Refactor BrokerApiVersionsCommand to use the new AdminClient (was: Refactor BrokerApiV

[jira] [Commented] (KAFKA-3268) Refactor existing CLI scripts to use KafkaAdminClient

[ https://issues.apache.org/jira/browse/KAFKA-3268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16123279#comment-16123279 ] Viktor Somogyi commented on KAFKA-3268: --- [~ppatierno] sure, it'd be great to sync on

[jira] [Comment Edited] (KAFKA-5676) MockStreamsMetrics should be in o.a.k.test

[ https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16120968#comment-16120968 ] Chanchal Singh edited comment on KAFKA-5676 at 8/11/17 12:22 PM: ---

[jira] [Commented] (KAFKA-5702) Refactor StreamThread to separate concerns and enable better testability

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

[jira] [Commented] (KAFKA-5637) Document compatibility and release policies

[ https://issues.apache.org/jira/browse/KAFKA-5637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16123181#comment-16123181 ] Sönke Liebau commented on KAFKA-5637: - My personal expectation for a stable, public AP

[jira] [Assigned] (KAFKA-5714) Allow whitespaces in the principal name

[ https://issues.apache.org/jira/browse/KAFKA-5714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar reassigned KAFKA-5714: Assignee: Manikumar > Allow whitespaces in the principal name > ---

[jira] [Commented] (KAFKA-5714) Allow whitespaces in the principal name

[ https://issues.apache.org/jira/browse/KAFKA-5714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16123074#comment-16123074 ] Manikumar commented on KAFKA-5714: -- [~a...@confluent.io] From the code, I can see that we

[jira] [Commented] (KAFKA-5724) AbstractPartitionAssignor does not take into consideration that partition number may start from non-zero

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

[jira] [Assigned] (KAFKA-5724) AbstractPartitionAssignor does not take into consideration that partition number may start from non-zero

[ https://issues.apache.org/jira/browse/KAFKA-5724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-5724: - Assignee: huxihx > AbstractPartitionAssignor does not take into consideration that partition > number ma