[jira] [Created] (KAFKA-9731) Increased fetch request rate with leader selector due to HW propagation

2020-03-17 Thread Vahid Hashemian (Jira)
Vahid Hashemian created KAFKA-9731: -- Summary: Increased fetch request rate with leader selector due to HW propagation Key: KAFKA-9731 URL: https://issues.apache.org/jira/browse/KAFKA-9731 Project:

[jira] [Created] (KAFKA-9205) Add an option to enforce rack-aware partition reassignment

2019-11-18 Thread Vahid Hashemian (Jira)
Vahid Hashemian created KAFKA-9205: -- Summary: Add an option to enforce rack-aware partition reassignment Key: KAFKA-9205 URL: https://issues.apache.org/jira/browse/KAFKA-9205 Project: Kafka

[jira] [Resolved] (KAFKA-8289) KTable, Long> can't be suppressed

2019-05-04 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian resolved KAFKA-8289. Resolution: Fixed > KTable, Long> can't be suppressed >

[jira] [Resolved] (KAFKA-7946) Flaky Test DeleteConsumerGroupsTest#testDeleteNonEmptyGroup

2019-05-03 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian resolved KAFKA-7946. Resolution: Fixed Fix Version/s: 2.2.1 > Flaky Test

[jira] [Resolved] (KAFKA-7962) StickyAssignor: throws NullPointerException during assignments if topic is deleted

2019-02-27 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian resolved KAFKA-7962. Resolution: Fixed Reviewer: Vahid Hashemian Fix Version/s: 2.3.0 >

[jira] [Created] (KAFKA-7993) Revert/Update the fix for KAFKA-7937 when coordinator lookup retries is implemented

2019-02-24 Thread Vahid Hashemian (JIRA)
Vahid Hashemian created KAFKA-7993: -- Summary: Revert/Update the fix for KAFKA-7937 when coordinator lookup retries is implemented Key: KAFKA-7993 URL: https://issues.apache.org/jira/browse/KAFKA-7993

[jira] [Resolved] (KAFKA-7604) Flaky Test `ConsumerCoordinatorTest.testRebalanceAfterTopicUnavailableWithPatternSubscribe`

2018-11-10 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian resolved KAFKA-7604. Resolution: Fixed > Flaky Test >

[jira] [Resolved] (KAFKA-6717) TopicPartition Assined twice to a consumer group for 2 consumer instances

2018-07-17 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian resolved KAFKA-6717. Resolution: Duplicate Marking it as duplicate to keep all the discussion in the other

[jira] [Resolved] (KAFKA-7156) Deleting topics with long names can bring all brokers to unrecoverable state

2018-07-13 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian resolved KAFKA-7156. Resolution: Duplicate > Deleting topics with long names can bring all brokers to

[jira] [Resolved] (KAFKA-7141) kafka-consumer-group doesn't describe existing group

2018-07-10 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian resolved KAFKA-7141. Resolution: Not A Problem > kafka-consumer-group doesn't describe existing group >

[jira] [Created] (KAFKA-7026) Sticky assignor could assign a partition to multiple consumers

2018-06-08 Thread Vahid Hashemian (JIRA)
Vahid Hashemian created KAFKA-7026: -- Summary: Sticky assignor could assign a partition to multiple consumers Key: KAFKA-7026 URL: https://issues.apache.org/jira/browse/KAFKA-7026 Project: Kafka

[jira] [Resolved] (KAFKA-6956) Use Java AdminClient in BrokerApiVersionsCommand

2018-05-27 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian resolved KAFKA-6956. Resolution: Duplicate > Use Java AdminClient in BrokerApiVersionsCommand >

[jira] [Created] (KAFKA-6951) Implement offset expiration semantics for unsubscribed topics

2018-05-25 Thread Vahid Hashemian (JIRA)
Vahid Hashemian created KAFKA-6951: -- Summary: Implement offset expiration semantics for unsubscribed topics Key: KAFKA-6951 URL: https://issues.apache.org/jira/browse/KAFKA-6951 Project: Kafka

[jira] [Resolved] (KAFKA-6110) Warning when running the broker on Windows

2017-11-07 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian resolved KAFKA-6110. Resolution: Duplicate Fix Version/s: 1.1.0 > Warning when running the broker on

[jira] [Created] (KAFKA-6110) Warning when running the broker on Windows

2017-10-23 Thread Vahid Hashemian (JIRA)
Vahid Hashemian created KAFKA-6110: -- Summary: Warning when running the broker on Windows Key: KAFKA-6110 URL: https://issues.apache.org/jira/browse/KAFKA-6110 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-6100) Streams quick start crashes Java on Windows

2017-10-20 Thread Vahid Hashemian (JIRA)
Vahid Hashemian created KAFKA-6100: -- Summary: Streams quick start crashes Java on Windows Key: KAFKA-6100 URL: https://issues.apache.org/jira/browse/KAFKA-6100 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-6075) Kafka cannot recover after an unclean shutdown on Windows

2017-10-17 Thread Vahid Hashemian (JIRA)
Vahid Hashemian created KAFKA-6075: -- Summary: Kafka cannot recover after an unclean shutdown on Windows Key: KAFKA-6075 URL: https://issues.apache.org/jira/browse/KAFKA-6075 Project: Kafka

[jira] [Created] (KAFKA-6055) Running tools on Windows fail due to misconfigured JVM config

2017-10-11 Thread Vahid Hashemian (JIRA)
Vahid Hashemian created KAFKA-6055: -- Summary: Running tools on Windows fail due to misconfigured JVM config Key: KAFKA-6055 URL: https://issues.apache.org/jira/browse/KAFKA-6055 Project: Kafka

[jira] [Created] (KAFKA-5639) Enhance DescribeGroups API to return additional group information

2017-07-25 Thread Vahid Hashemian (JIRA)
Vahid Hashemian created KAFKA-5639: -- Summary: Enhance DescribeGroups API to return additional group information Key: KAFKA-5639 URL: https://issues.apache.org/jira/browse/KAFKA-5639 Project: Kafka

[jira] [Created] (KAFKA-5638) Inconsistency in consumer group related ACLs

2017-07-25 Thread Vahid Hashemian (JIRA)
Vahid Hashemian created KAFKA-5638: -- Summary: Inconsistency in consumer group related ACLs Key: KAFKA-5638 URL: https://issues.apache.org/jira/browse/KAFKA-5638 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-5495) Replace the deprecated 'ConsumerOffsetChecker' in documentation

2017-06-21 Thread Vahid Hashemian (JIRA)
Vahid Hashemian created KAFKA-5495: -- Summary: Replace the deprecated 'ConsumerOffsetChecker' in documentation Key: KAFKA-5495 URL: https://issues.apache.org/jira/browse/KAFKA-5495 Project: Kafka

[jira] [Resolved] (KAFKA-3969) kafka.admin.ConsumerGroupCommand doesn't show consumer groups

2017-06-20 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian resolved KAFKA-3969. Resolution: Not A Bug [~dieter_be] Closing this JIRA as it didn't seem to be a bug. Please

[jira] [Commented] (KAFKA-5434) Console consumer hangs if not existing partition is specified

2017-06-15 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050915#comment-16050915 ] Vahid Hashemian commented on KAFKA-5434: [~ppatierno] I look at this from a different angle. In

[jira] [Updated] (KAFKA-4333) Report consumer group coordinator id when '--list' option is used

2017-06-15 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-4333: --- Fix Version/s: 0.11.1.0 > Report consumer group coordinator id when '--list' option is used >

[jira] [Updated] (KAFKA-4416) Add a '--group' option to the console consumer

2017-06-15 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-4416: --- Fix Version/s: 0.11.1.0 > Add a '--group' option to the console consumer >

[jira] [Updated] (KAFKA-5359) Exceptions from RequestFuture lack parts of the stack trace

2017-06-15 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-5359: --- Fix Version/s: 0.11.1.0 > Exceptions from RequestFuture lack parts of the stack trace >

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

2017-06-15 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050802#comment-16050802 ] Vahid Hashemian commented on KAFKA-4585: [~ewencp] I'd appreciate your feedback on the

[jira] [Commented] (KAFKA-5430) new consumers getting data for revoked partitions

2017-06-14 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049582#comment-16049582 ] Vahid Hashemian commented on KAFKA-5430: I could simulate a network failure and get the warning

[jira] [Comment Edited] (KAFKA-5348) kafka-consumer-groups.sh refuses to remove groups without ids

2017-06-13 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16048486#comment-16048486 ] Vahid Hashemian edited comment on KAFKA-5348 at 6/13/17 10:36 PM: --

[jira] [Commented] (KAFKA-5348) kafka-consumer-groups.sh refuses to remove groups without ids

2017-06-13 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16048486#comment-16048486 ] Vahid Hashemian commented on KAFKA-5348: [~bobrik] In the scenario you described I assume some

[jira] [Updated] (KAFKA-4585) Offset fetch and commit requests use the same permissions

2017-06-13 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-4585: --- Labels: kip (was: needs-kip) > Offset fetch and commit requests use the same permissions >

[jira] [Work started] (KAFKA-5370) Replace uses of old consumer with the new consumer

2017-06-13 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-5370 started by Vahid Hashemian. -- > Replace uses of old consumer with the new consumer >

[jira] [Commented] (KAFKA-5434) Console consumer hangs if not existing partition is specified

2017-06-13 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16048048#comment-16048048 ] Vahid Hashemian commented on KAFKA-5434: Yeah, I couldn't assign it to you either. You can take

[jira] [Commented] (KAFKA-5434) Console consumer hangs if not existing partition is specified

2017-06-13 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16048030#comment-16048030 ] Vahid Hashemian commented on KAFKA-5434: [~ppatierno] Sure. Feel free to assign the JIRA to

[jira] [Commented] (KAFKA-3129) Console producer issue when request-required-acks=0

2017-06-12 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16047074#comment-16047074 ] Vahid Hashemian commented on KAFKA-3129: [~pmishra01] I tried this on Ubuntu, Windows 7 and

[jira] [Assigned] (KAFKA-5434) Console consumer hangs if not existing partition is specified

2017-06-12 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian reassigned KAFKA-5434: -- Assignee: Vahid Hashemian > Console consumer hangs if not existing partition is

[jira] [Created] (KAFKA-5370) Replace uses of old consumer with the new consumer

2017-06-02 Thread Vahid Hashemian (JIRA)
Vahid Hashemian created KAFKA-5370: -- Summary: Replace uses of old consumer with the new consumer Key: KAFKA-5370 URL: https://issues.apache.org/jira/browse/KAFKA-5370 Project: Kafka Issue

[jira] [Updated] (KAFKA-5359) Exceptions from RequestFuture lack parts of the stack trace

2017-06-02 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-5359: --- Status: Patch Available (was: Open) > Exceptions from RequestFuture lack parts of the stack

[jira] [Assigned] (KAFKA-5359) Exceptions from RequestFuture lack parts of the stack trace

2017-06-01 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian reassigned KAFKA-5359: -- Assignee: Vahid Hashemian > Exceptions from RequestFuture lack parts of the stack

[jira] [Assigned] (KAFKA-5348) kafka-consumer-groups.sh refuses to remove groups without ids

2017-05-30 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian reassigned KAFKA-5348: -- Assignee: Vahid Hashemian > kafka-consumer-groups.sh refuses to remove groups without

[jira] [Created] (KAFKA-5336) The required ACL permission for ListGroup is invalid

2017-05-26 Thread Vahid Hashemian (JIRA)
Vahid Hashemian created KAFKA-5336: -- Summary: The required ACL permission for ListGroup is invalid Key: KAFKA-5336 URL: https://issues.apache.org/jira/browse/KAFKA-5336 Project: Kafka Issue

[jira] [Commented] (KAFKA-3151) kafka-consumer-groups.sh fail with sasl enabled

2017-05-26 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16026658#comment-16026658 ] Vahid Hashemian commented on KAFKA-3151: For this to work I had to also add the following line to

[jira] [Updated] (KAFKA-5282) Transactions integration test: Use factory methods to keep track of open producers and consumers and close them all on tearDown

2017-05-26 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-5282: --- Status: Patch Available (was: In Progress) > Transactions integration test: Use factory

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

2017-05-25 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16025569#comment-16025569 ] Vahid Hashemian commented on KAFKA-4585: [~ewencp] I'll work on a KIP for changing the required

[jira] [Work started] (KAFKA-4585) Offset fetch and commit requests use the same permissions

2017-05-25 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4585 started by Vahid Hashemian. -- > Offset fetch and commit requests use the same permissions >

[jira] [Work started] (KAFKA-5282) Transactions integration test: Use factory methods to keep track of open producers and consumers and close them all on tearDown

2017-05-23 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-5282 started by Vahid Hashemian. -- > Transactions integration test: Use factory methods to keep track of open

[jira] [Assigned] (KAFKA-5282) Transactions integration test: Use factory methods to keep track of open producers and consumers and close them all on tearDown

2017-05-22 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian reassigned KAFKA-5282: -- Assignee: Vahid Hashemian > Transactions integration test: Use factory methods to keep

[jira] [Commented] (KAFKA-5278) kafka-console-consumer: `--value-deserializer` is not working but `--property value.deserializer` does

2017-05-19 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017556#comment-16017556 ] Vahid Hashemian commented on KAFKA-5278: Looks like the issue reported here is a subset of

[jira] [Comment Edited] (KAFKA-5278) kafka-console-consumer: `--value-deserializer` is not working but `--property value.deserializer` does

2017-05-19 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017556#comment-16017556 ] Vahid Hashemian edited comment on KAFKA-5278 at 5/19/17 3:38 PM: - Looks

[jira] [Commented] (KAFKA-4950) ConcurrentModificationException when iterating over Kafka Metrics

2017-05-18 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016640#comment-16016640 ] Vahid Hashemian commented on KAFKA-4950: [~dpostoronca] Still no luck on my side reproducing this

[jira] [Created] (KAFKA-5277) Sticky Assignor should not cache the calculated assignment (KIP-54 follow-up)

2017-05-17 Thread Vahid Hashemian (JIRA)
Vahid Hashemian created KAFKA-5277: -- Summary: Sticky Assignor should not cache the calculated assignment (KIP-54 follow-up) Key: KAFKA-5277 URL: https://issues.apache.org/jira/browse/KAFKA-5277

[jira] [Commented] (KAFKA-4950) ConcurrentModificationException when iterating over Kafka Metrics

2017-05-10 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16005658#comment-16005658 ] Vahid Hashemian commented on KAFKA-4950: [~dpostoronca] Thanks for providing the additional

[jira] [Resolved] (KAFKA-5016) Consumer hang in poll method while rebalancing is in progress

2017-04-27 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian resolved KAFKA-5016. Resolution: Not A Bug > Consumer hang in poll method while rebalancing is in progress >

[jira] [Commented] (KAFKA-5016) Consumer hang in poll method while rebalancing is in progress

2017-04-26 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15985043#comment-15985043 ] Vahid Hashemian commented on KAFKA-5016: [~domenico74] Thanks for confirming. Can we close the

[jira] [Commented] (KAFKA-5110) ConsumerGroupCommand error handling improvement

2017-04-24 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981652#comment-15981652 ] Vahid Hashemian commented on KAFKA-5110: [~cotedm] Thanks for your response. Yes, hopefully the PR

[jira] [Comment Edited] (KAFKA-4795) Confusion around topic deletion

2017-04-21 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979597#comment-15979597 ] Vahid Hashemian edited comment on KAFKA-4795 at 4/21/17 11:40 PM: --

[jira] [Commented] (KAFKA-4795) Confusion around topic deletion

2017-04-21 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979597#comment-15979597 ] Vahid Hashemian commented on KAFKA-4795: [~ecomar] Thanks for your feedback. What I take from your

[jira] [Commented] (KAFKA-5110) ConsumerGroupCommand error handling improvement

2017-04-21 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979502#comment-15979502 ] Vahid Hashemian commented on KAFKA-5110: [~cotedm] Could you please share the steps to reproduce

[jira] [Commented] (KAFKA-5016) Consumer hang in poll method while rebalancing is in progress

2017-04-21 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979482#comment-15979482 ] Vahid Hashemian commented on KAFKA-5016: [~domenico74] I think you are seeing the difference in

[jira] [Commented] (KAFKA-5016) Consumer hang in poll method while rebalancing is in progress

2017-04-21 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979030#comment-15979030 ] Vahid Hashemian commented on KAFKA-5016: [~domenico74] Thanks for confirming. I'll update this

[jira] [Commented] (KAFKA-5016) Consumer hang in poll method while rebalancing is in progress

2017-04-20 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15977499#comment-15977499 ] Vahid Hashemian commented on KAFKA-5016: [~domenico74] Thanks a lot for sharing the executable

[jira] [Commented] (KAFKA-4291) TopicCommand --describe shows topics marked for deletion as under-replicated and unavailable

2017-04-20 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15977214#comment-15977214 ] Vahid Hashemian commented on KAFKA-4291: [~mimaison] I opened

[jira] [Commented] (KAFKA-4893) async topic deletion conflicts with max topic length

2017-04-20 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15977130#comment-15977130 ] Vahid Hashemian commented on KAFKA-4893: [~soumabrata] Thanks for checking. The solution has not

[jira] [Commented] (KAFKA-4950) ConcurrentModificationException when iterating over Kafka Metrics

2017-04-20 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15977116#comment-15977116 ] Vahid Hashemian commented on KAFKA-4950: [~dpostoronca] Would you mind sharing a bit more of your

[jira] [Commented] (KAFKA-5016) Consumer hang in poll method while rebalancing is in progress

2017-04-12 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15966278#comment-15966278 ] Vahid Hashemian commented on KAFKA-5016: [~domenico74] I have not been able to reproduce this

[jira] [Assigned] (KAFKA-4950) ConcurrentModificationException when iterating over Kafka Metrics

2017-04-10 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian reassigned KAFKA-4950: -- Assignee: Vahid Hashemian > ConcurrentModificationException when iterating over Kafka

[jira] [Commented] (KAFKA-4950) ConcurrentModificationException when iterating over Kafka Metrics

2017-04-10 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15963308#comment-15963308 ] Vahid Hashemian commented on KAFKA-4950: [~ijuma] Yup, thanks! > ConcurrentModificationException

[jira] [Assigned] (KAFKA-5016) Consumer hang in poll method while rebalancing is in progress

2017-04-10 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian reassigned KAFKA-5016: -- Assignee: Vahid Hashemian > Consumer hang in poll method while rebalancing is in

[jira] [Commented] (KAFKA-4858) Long topic names created using old kafka-topics.sh can prevent newer brokers from joining any ISRs

2017-03-16 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929196#comment-15929196 ] Vahid Hashemian commented on KAFKA-4858: [~wushujames] Thanks for bringing those use cases up. I

[jira] [Commented] (KAFKA-4893) async topic deletion conflicts with max topic length

2017-03-15 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15927303#comment-15927303 ] Vahid Hashemian commented on KAFKA-4893: [~onurkaraman] Sure, I agree that your suggestion is the

[jira] [Comment Edited] (KAFKA-4893) async topic deletion conflicts with max topic length

2017-03-15 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15927033#comment-15927033 ] Vahid Hashemian edited comment on KAFKA-4893 at 3/15/17 11:55 PM: --

[jira] [Commented] (KAFKA-4893) async topic deletion conflicts with max topic length

2017-03-15 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15927033#comment-15927033 ] Vahid Hashemian commented on KAFKA-4893: [~onurkaraman] What you suggested should work. Of course,

[jira] [Assigned] (KAFKA-4893) async topic deletion conflicts with max topic length

2017-03-13 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian reassigned KAFKA-4893: -- Assignee: Vahid Hashemian > async topic deletion conflicts with max topic length >

[jira] [Commented] (KAFKA-4858) Long topic names created using old kafka-topics.sh can prevent newer brokers from joining any ISRs

2017-03-10 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15905927#comment-15905927 ] Vahid Hashemian commented on KAFKA-4858: [~jeffwidman] Well, assuming we are using an old client

[jira] [Commented] (KAFKA-4858) Long topic names created using old kafka-topics.sh can prevent newer brokers from joining any ISRs

2017-03-09 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15904026#comment-15904026 ] Vahid Hashemian commented on KAFKA-4858: [~wushujames] [~jeffwidman] From what I can tell it all

[jira] [Commented] (KAFKA-4858) Long topic names created using old kafka-topics.sh can prevent newer brokers from joining any ISRs

2017-03-09 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15903897#comment-15903897 ] Vahid Hashemian commented on KAFKA-4858: [~wushujames], so the issue is actually the same as what

[jira] [Assigned] (KAFKA-4858) Long topic names created using old kafka-topics.sh can prevent newer brokers from joining any ISRs

2017-03-07 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian reassigned KAFKA-4858: -- Assignee: Vahid Hashemian > Long topic names created using old kafka-topics.sh can

[jira] [Commented] (KAFKA-4795) Confusion around topic deletion

2017-03-07 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900271#comment-15900271 ] Vahid Hashemian commented on KAFKA-4795: [~ijuma] [~hachikuji] I'd appreciate your clarification

[jira] [Resolved] (KAFKA-4845) KafkaConsumer.seekToEnd cannot take effect when integrating with spark streaming

2017-03-07 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian resolved KAFKA-4845. Resolution: Duplicate > KafkaConsumer.seekToEnd cannot take effect when integrating with

[jira] [Commented] (KAFKA-4845) KafkaConsumer.seekToEnd cannot take effect when integrating with spark streaming

2017-03-07 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15899634#comment-15899634 ] Vahid Hashemian commented on KAFKA-4845: Great, then I'll mark this one as a duplicate of

[jira] [Comment Edited] (KAFKA-4845) KafkaConsumer.seekToEnd cannot take effect when integrating with spark streaming

2017-03-06 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15898258#comment-15898258 ] Vahid Hashemian edited comment on KAFKA-4845 at 3/6/17 10:20 PM: - [~DanC],

[jira] [Commented] (KAFKA-4845) KafkaConsumer.seekToEnd cannot take effect when integrating with spark streaming

2017-03-06 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15898258#comment-15898258 ] Vahid Hashemian commented on KAFKA-4845: [~DanC], The issue you raised sounds very similar to the

[jira] [Assigned] (KAFKA-4845) KafkaConsumer.seekToEnd cannot take effect when integrating with spark streaming

2017-03-06 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian reassigned KAFKA-4845: -- Assignee: Vahid Hashemian > KafkaConsumer.seekToEnd cannot take effect when

[jira] [Commented] (KAFKA-4845) KafkaConsumer.seekToEnd cannot take effect when integrating with spark streaming

2017-03-06 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15897780#comment-15897780 ] Vahid Hashemian commented on KAFKA-4845: [~ijuma], sure, I'll take a look. >

[jira] [Updated] (KAFKA-4795) Confusion around topic deletion

2017-03-03 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-4795: --- Description: The topic deletion works like this in 0.10.2.0: #

[jira] [Commented] (KAFKA-4795) Confusion around topic deletion

2017-03-03 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15895220#comment-15895220 ] Vahid Hashemian commented on KAFKA-4795: [~omkreddy] Thanks for your comment. I had looked at the

[jira] [Commented] (KAFKA-4095) When a topic is deleted and then created with the same name, 'committed' offsets are not reset

2017-02-28 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15889127#comment-15889127 ] Vahid Hashemian commented on KAFKA-4095: [~jeffwidman] This JIRA applies to the old (ZooKeeper

[jira] [Created] (KAFKA-4795) Confusion around topic deletion

2017-02-23 Thread Vahid Hashemian (JIRA)
Vahid Hashemian created KAFKA-4795: -- Summary: Confusion around topic deletion Key: KAFKA-4795 URL: https://issues.apache.org/jira/browse/KAFKA-4795 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-2273) KIP-54: Add rebalance with a minimal number of reassignments to server-defined strategy list

2017-02-21 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-2273: --- Summary: KIP-54: Add rebalance with a minimal number of reassignments to server-defined

[jira] [Updated] (KAFKA-2273) Kip-54: Add rebalance with a minimal number of reassignments to server-defined strategy list

2017-02-21 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-2273: --- Summary: Kip-54: Add rebalance with a minimal number of reassignments to server-defined

[jira] [Updated] (KAFKA-2273) Add rebalance with a minimal number of reassignments to server-defined strategy list

2017-02-21 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-2273: --- Status: Patch Available (was: In Progress) > Add rebalance with a minimal number of

[jira] [Updated] (KAFKA-2273) Add rebalance with a minimal number of reassignments to server-defined strategy list

2017-02-21 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-2273: --- Labels: kip (was: kip newbie++ newbiee) > Add rebalance with a minimal number of

[jira] [Updated] (KAFKA-4665) Inconsistent handling of non-existing topics in offset fetch handling

2017-02-14 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-4665: --- Status: Patch Available (was: In Progress) > Inconsistent handling of non-existing topics in

[jira] [Updated] (KAFKA-3264) Mark the old Scala consumer and related classes as deprecated

2017-02-13 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-3264: --- Status: Patch Available (was: Open) > Mark the old Scala consumer and related classes as

[jira] [Updated] (KAFKA-2857) ConsumerGroupCommand throws GroupCoordinatorNotAvailableException when describing a non-existent group before the offset topic is created

2017-02-13 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-2857: --- Status: Patch Available (was: Open) > ConsumerGroupCommand throws

[jira] [Commented] (KAFKA-2857) ConsumerGroupCommand throws GroupCoordinatorNotAvailableException when describing a non-existent group before the offset topic is created

2017-02-06 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855052#comment-15855052 ] Vahid Hashemian commented on KAFKA-2857: Sorry, you are right. This would become a config option

[jira] [Commented] (KAFKA-2857) ConsumerGroupCommand throws GroupCoordinatorNotAvailableException when describing a non-existent group before the offset topic is created

2017-02-06 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855001#comment-15855001 ] Vahid Hashemian commented on KAFKA-2857: [~hachikuji] Great. I assume you are suggesting adding a

[jira] [Commented] (KAFKA-2857) ConsumerGroupCommand throws GroupCoordinatorNotAvailableException when describing a non-existent group before the offset topic is created

2017-02-01 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15848972#comment-15848972 ] Vahid Hashemian commented on KAFKA-2857: [~hachikuji] I am thinking about the two options you

[jira] [Commented] (KAFKA-4665) Inconsistent handling of non-existing topics in offset fetch handling

2017-01-26 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15840346#comment-15840346 ] Vahid Hashemian commented on KAFKA-4665: {quote} Note also that currently the consumer raises

[jira] [Work started] (KAFKA-4665) Inconsistent handling of non-existing topics in offset fetch handling

2017-01-26 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4665 started by Vahid Hashemian. -- > Inconsistent handling of non-existing topics in offset fetch handling >

  1   2   3   4   5   >