[jira] [Commented] (KAFKA-3727) Consumer.poll() stuck in loop on non-existent topic manually assigned

[ https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15347169#comment-15347169 ] Edoardo Comar commented on KAFKA-3727: -- Thanks [~hachikuji], sure I could start a sma

[jira] [Commented] (KAFKA-3727) Consumer.poll() stuck in loop on non-existent topic manually assigned

[ https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15340699#comment-15340699 ] Edoardo Comar commented on KAFKA-3727: -- [~ijuma] and [~hachikuji] referring to your c

[jira] [Commented] (KAFKA-3727) Consumer.poll() stuck in loop on non-existent topic manually assigned

[ https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15330850#comment-15330850 ] Edoardo Comar commented on KAFKA-3727: -- Another case where poll() hangs forever is wh

[jira] [Comment Edited] (KAFKA-1894) Avoid long or infinite blocking in the consumer

[ https://issues.apache.org/jira/browse/KAFKA-1894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15330848#comment-15330848 ] Edoardo Comar edited comment on KAFKA-1894 at 6/14/16 11:17 PM:

[jira] [Commented] (KAFKA-1894) Avoid long or infinite blocking in the consumer

[ https://issues.apache.org/jira/browse/KAFKA-1894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15330848#comment-15330848 ] Edoardo Comar commented on KAFKA-1894: -- Another case that leads to the loop ```

[jira] [Comment Edited] (KAFKA-3727) Consumer.poll() stuck in loop on non-existent topic manually assigned

[ https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15324624#comment-15324624 ] Edoardo Comar edited comment on KAFKA-3727 at 6/10/16 3:26 PM: -

[jira] [Commented] (KAFKA-3727) Consumer.poll() stuck in loop on non-existent topic manually assigned

[ https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15324624#comment-15324624 ] Edoardo Comar commented on KAFKA-3727: -- would it make sense that the missing topic/pa

[jira] [Commented] (KAFKA-3727) Consumer.poll() stuck in loop on non-existent topic manually assigned

[ https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15324450#comment-15324450 ] Edoardo Comar commented on KAFKA-3727: -- I think it would be reasonable to have the po

[jira] [Assigned] (KAFKA-3727) Consumer.poll() stuck in loop on non-existent topic manually assigned

[ https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar reassigned KAFKA-3727: Assignee: Edoardo Comar > Consumer.poll() stuck in loop on non-existent topic manually assi

[jira] [Commented] (KAFKA-3727) Consumer.poll() stuck in loop on non-existent topic manually assigned

[ https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15324424#comment-15324424 ] Edoardo Comar commented on KAFKA-3727: -- [~ijuma] [~hachikuji] ... reposting here as m

[jira] [Commented] (KAFKA-3177) Kafka consumer can hang when position() is called on a non-existing partition.

[ https://issues.apache.org/jira/browse/KAFKA-3177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15301940#comment-15301940 ] Edoardo Comar commented on KAFKA-3177: -- see also Consumer.poll() stuck in loop on non

[jira] [Commented] (KAFKA-3727) Consumer.poll() stuck in loop on non-existent topic manually assigned

[ https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15301027#comment-15301027 ] Edoardo Comar commented on KAFKA-3727: -- Thanks [~ijuma] those issues are related. H

[jira] [Commented] (KAFKA-3682) ArrayIndexOutOfBoundsException thrown by SkimpyOffsetMap.get() when full

[ https://issues.apache.org/jira/browse/KAFKA-3682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15301010#comment-15301010 ] Edoardo Comar commented on KAFKA-3682: -- [~vahid] you can just run my unit test withou

[jira] [Commented] (KAFKA-3682) ArrayIndexOutOfBoundsException thrown by SkimpyOffsetMap.get() when full

[ https://issues.apache.org/jira/browse/KAFKA-3682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15300756#comment-15300756 ] Edoardo Comar commented on KAFKA-3682: -- Hi this is a pretty simple fix, backed by a u

[jira] [Updated] (KAFKA-3727) Consumer.poll() stuck in loop on non-existent topic manually assigned

[ https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar updated KAFKA-3727: - Priority: Critical (was: Major) > Consumer.poll() stuck in loop on non-existent topic manually as

[jira] [Commented] (KAFKA-3727) Consumer.poll() stuck in loop on non-existent topic manually assigned

[ https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15300482#comment-15300482 ] Edoardo Comar commented on KAFKA-3727: -- Hi can please anyone comment on this (IMHO) b

[jira] [Commented] (KAFKA-3727) Consumer.poll() stuck in loop on non-existent topic manually assigned

[ https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15296538#comment-15296538 ] Edoardo Comar commented on KAFKA-3727: -- My expectation is that with either subscribe(

[jira] [Commented] (KAFKA-3727) Consumer.poll() stuck in loop on non-existent topic manually assigned

[ https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15296398#comment-15296398 ] Edoardo Comar commented on KAFKA-3727: -- The consumer remains stuck in a loop because

[jira] [Issue Comment Deleted] (KAFKA-3727) Consumer.poll() stuck in loop on non-existent topic manually assigned

[ https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar updated KAFKA-3727: - Comment: was deleted (was: To explain better, this is a stack trace when the consumer is stuck in

[jira] [Commented] (KAFKA-3727) Consumer.poll() stuck in loop on non-existent topic manually assigned

[ https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15296394#comment-15296394 ] Edoardo Comar commented on KAFKA-3727: -- To explain better, this is a stack trace when

[jira] [Commented] (KAFKA-3567) Add --security-protocol option to console consumer and producer

[ https://issues.apache.org/jira/browse/KAFKA-3567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15296163#comment-15296163 ] Edoardo Comar commented on KAFKA-3567: -- Hi, the console producer has these options:

[jira] [Commented] (KAFKA-3728) EndToEndAuthorizationTest offsets_topic misconfigured

[ https://issues.apache.org/jira/browse/KAFKA-3728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15293272#comment-15293272 ] Edoardo Comar commented on KAFKA-3728: -- Thanks [~rsivaram] it wasn't obvious that ac

[jira] [Updated] (KAFKA-3728) EndToEndAuthorizationTest offsets_topic misconfigured

[ https://issues.apache.org/jira/browse/KAFKA-3728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar updated KAFKA-3728: - Summary: EndToEndAuthorizationTest offsets_topic misconfigured (was: inconsistent behavior of Con

[jira] [Commented] (KAFKA-3396) Unauthorized topics are returned to the user

[ https://issues.apache.org/jira/browse/KAFKA-3396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15289551#comment-15289551 ] Edoardo Comar commented on KAFKA-3396: -- I'm held back by https://issues.apache.org/j

[jira] [Created] (KAFKA-3728) inconsistent behavior of Consumer.poll() when assigned vs subscribed

Edoardo Comar created KAFKA-3728: Summary: inconsistent behavior of Consumer.poll() when assigned vs subscribed Key: KAFKA-3728 URL: https://issues.apache.org/jira/browse/KAFKA-3728 Project: Kafka

[jira] [Updated] (KAFKA-3727) Consumer.poll() stuck in loop on non-existent topic manually assigned

[ https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar updated KAFKA-3727: - Description: The behavior of a consumer on poll() for a non-existing topic is surprisingly differ

[jira] [Updated] (KAFKA-3727) inconsistent behavior of Consumer.poll() on non-existent topic when assigned vs subscribed

[ https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar updated KAFKA-3727: - Description: Inconsistent behavior of Consumer.poll() on non-existent topic when assigned vs subs

[jira] [Updated] (KAFKA-3727) Consumer.poll() stuck in loop on non-existent topic manually assigned

[ https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar updated KAFKA-3727: - Summary: Consumer.poll() stuck in loop on non-existent topic manually assigned (was: inconsistent

[jira] [Updated] (KAFKA-3727) inconsistent behavior of Consumer.poll() on non-existent topic when assigned vs subscribed

[ https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar updated KAFKA-3727: - Description: The behavior of a consumer on poll() for a non-existing topic is surprisingly differ

[jira] [Updated] (KAFKA-3727) inconsistent behavior of Consumer.poll() on non-existent topic when assigned vs subscribed

[ https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar updated KAFKA-3727: - Description: The behavior of a consumer on poll() for a non-existing topic is surprisingly differ

[jira] [Created] (KAFKA-3727) inconsistent behavior of Consumer.poll() on non-existent topic when assigned vs subscribed

Edoardo Comar created KAFKA-3727: Summary: inconsistent behavior of Consumer.poll() on non-existent topic when assigned vs subscribed Key: KAFKA-3727 URL: https://issues.apache.org/jira/browse/KAFKA-3727

[jira] [Assigned] (KAFKA-3396) Unauthorized topics are returned to the user

[ https://issues.apache.org/jira/browse/KAFKA-3396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar reassigned KAFKA-3396: Assignee: Edoardo Comar > Unauthorized topics are returned to the user > --

[jira] [Commented] (KAFKA-3396) Unauthorized topics are returned to the user

[ https://issues.apache.org/jira/browse/KAFKA-3396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287873#comment-15287873 ] Edoardo Comar commented on KAFKA-3396: -- Hi [~granthenke] we're still working on it,

[jira] [Commented] (KAFKA-3396) Unauthorized topics are returned to the user

[ https://issues.apache.org/jira/browse/KAFKA-3396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15282659#comment-15282659 ] Edoardo Comar commented on KAFKA-3396: -- Hi [~granthenke] I thought that if a user has

[jira] [Commented] (KAFKA-3396) Unauthorized topics are returned to the user

[ https://issues.apache.org/jira/browse/KAFKA-3396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15280197#comment-15280197 ] Edoardo Comar commented on KAFKA-3396: -- Hi we have worked on a simple patch that wou

[jira] [Commented] (KAFKA-3688) Unable to start broker with sasl.mechanism.inter.broker.protocol=PLAIN

[ https://issues.apache.org/jira/browse/KAFKA-3688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15278669#comment-15278669 ] Edoardo Comar commented on KAFKA-3688: -- thanks [~rsivaram] it wasn't obvious how to e

[jira] [Resolved] (KAFKA-3687) Internal Authorization Failure at startup with ACLs and security.inter.broker.protocol=PLAINTEXT

[ https://issues.apache.org/jira/browse/KAFKA-3687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar resolved KAFKA-3687. -- Resolution: Not A Bug > Internal Authorization Failure at startup with ACLs and > security.inte

[jira] [Resolved] (KAFKA-3688) Unable to start broker with sasl.mechanism.inter.broker.protocol=PLAIN

[ https://issues.apache.org/jira/browse/KAFKA-3688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar resolved KAFKA-3688. -- Resolution: Invalid > Unable to start broker with sasl.mechanism.inter.broker.protocol=PLAIN > -

[jira] [Updated] (KAFKA-3687) Internal Authorization Failure at startup with ACLs and security.inter.broker.protocol=PLAINTEXT

[ https://issues.apache.org/jira/browse/KAFKA-3687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar updated KAFKA-3687: - Summary: Internal Authorization Failure at startup with ACLs and security.inter.broker.protocol=PL

[jira] [Commented] (KAFKA-3688) Unable to start broker with sasl.mechanism.inter.broker.protocol=PLAIN

[ https://issues.apache.org/jira/browse/KAFKA-3688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15278511#comment-15278511 ] Edoardo Comar commented on KAFKA-3688: -- Hi, that's what I've done by adding the Kafka

[jira] [Created] (KAFKA-3688) Unable to start broker with sasl.mechanism.inter.broker.protocol=PLAIN

Edoardo Comar created KAFKA-3688: Summary: Unable to start broker with sasl.mechanism.inter.broker.protocol=PLAIN Key: KAFKA-3688 URL: https://issues.apache.org/jira/browse/KAFKA-3688 Project: Kafka

[jira] [Created] (KAFKA-3687) Internal Authorization Failure at startup with ACLs and security.inter.broker.protocol=PLAIN

Edoardo Comar created KAFKA-3687: Summary: Internal Authorization Failure at startup with ACLs and security.inter.broker.protocol=PLAIN Key: KAFKA-3687 URL: https://issues.apache.org/jira/browse/KAFKA-3687

[jira] [Created] (KAFKA-3682) ArrayIndexOutOfBoundsException thrown by SkimpyOffsetMap.get() when full

Edoardo Comar created KAFKA-3682: Summary: ArrayIndexOutOfBoundsException thrown by SkimpyOffsetMap.get() when full Key: KAFKA-3682 URL: https://issues.apache.org/jira/browse/KAFKA-3682 Project: Kafka

[jira] [Created] (KAFKA-3679) Allow reuse of implementation of RFC 4616 in PlainSaslServer

Edoardo Comar created KAFKA-3679: Summary: Allow reuse of implementation of RFC 4616 in PlainSaslServer Key: KAFKA-3679 URL: https://issues.apache.org/jira/browse/KAFKA-3679 Project: Kafka

[jira] [Commented] (KAFKA-3587) LogCleaner fails due to incorrect offset map computation on a replica

[ https://issues.apache.org/jira/browse/KAFKA-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15274977#comment-15274977 ] Edoardo Comar commented on KAFKA-3587: -- [~junrao] the difference between option 1 and

[jira] [Commented] (KAFKA-3587) LogCleaner fails due to incorrect offset map computation on a replica

[ https://issues.apache.org/jira/browse/KAFKA-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15274622#comment-15274622 ] Edoardo Comar commented on KAFKA-3587: -- [~junrao] thanks for your observation https:

[jira] [Commented] (KAFKA-3587) LogCleaner fails due to incorrect offset map computation on a replica

[ https://issues.apache.org/jira/browse/KAFKA-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15274204#comment-15274204 ] Edoardo Comar commented on KAFKA-3587: -- For clarity, [~mimaison] PR https://github.co

[jira] [Commented] (KAFKA-3587) LogCleaner fails due to incorrect offset map computation on a replica

[ https://issues.apache.org/jira/browse/KAFKA-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15273821#comment-15273821 ] Edoardo Comar commented on KAFKA-3587: -- [~junrao] I was thinking of two possible opti

[jira] [Commented] (KAFKA-3587) LogCleaner fails due to incorrect offset map computation on a replica

[ https://issues.apache.org/jira/browse/KAFKA-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15273482#comment-15273482 ] Edoardo Comar commented on KAFKA-3587: -- [~ishiihara] In your PR the very pessimistic

[jira] [Commented] (KAFKA-3587) LogCleaner fails due to incorrect offset map computation on a replica

[ https://issues.apache.org/jira/browse/KAFKA-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15273455#comment-15273455 ] Edoardo Comar commented on KAFKA-3587: -- [~alekar] I had a look at your patch. The app

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

[ https://issues.apache.org/jira/browse/KAFKA-2273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263195#comment-15263195 ] Edoardo Comar commented on KAFKA-2273: -- Working on this with [~vahid] - propagating t

[jira] [Assigned] (KAFKA-3587) LogCleaner fails due to incorrect offset map computation on a replica

[ https://issues.apache.org/jira/browse/KAFKA-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar reassigned KAFKA-3587: Assignee: Edoardo Comar (was: Manikumar Reddy) > LogCleaner fails due to incorrect offset

[jira] [Commented] (KAFKA-3587) LogCleaner fails due to incorrect offset map computation on a replica

[ https://issues.apache.org/jira/browse/KAFKA-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15253833#comment-15253833 ] Edoardo Comar commented on KAFKA-3587: -- Hi I was having a look at this issue too. in

[jira] [Commented] (KAFKA-3415) AdminOperationException when altering Topic with same number of partitions

[ https://issues.apache.org/jira/browse/KAFKA-3415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1510#comment-1510 ] Edoardo Comar commented on KAFKA-3415: -- As the user opening the JIRA stated, they use

[jira] [Commented] (KAFKA-3415) AdminOperationException when altering Topic with same number of partitions

[ https://issues.apache.org/jira/browse/KAFKA-3415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15199776#comment-15199776 ] Edoardo Comar commented on KAFKA-3415: -- I agree that the retcode to the shell should

[jira] [Commented] (KAFKA-2832) support exclude.internal.topics in new consumer

[ https://issues.apache.org/jira/browse/KAFKA-2832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15197454#comment-15197454 ] Edoardo Comar commented on KAFKA-2832: -- Hi all, Vahid is on vacation so I am creating

<    1   2