[
https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15324624#comment-15324624
]
Edoardo Comar edited comment on KAFKA-3727 at 6/10/16 3:26 PM:
---
would it
[
https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15324624#comment-15324624
]
Edoardo Comar commented on KAFKA-3727:
--
would it make sense that the missing topic/partition
[
https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15324450#comment-15324450
]
Edoardo Comar commented on KAFKA-3727:
--
I think it would be reasonable to have the poll timeout
[
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
[
https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15324424#comment-15324424
]
Edoardo Comar commented on KAFKA-3727:
--
[~ijuma] [~hachikuji] ... reposting here as more on-topic
[
https://issues.apache.org/jira/browse/KAFKA-3177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15301940#comment-15301940
]
Edoardo Comar commented on KAFKA-3177:
--
see also Consumer.poll() stuck in loop on non-existent topic
[
https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15301027#comment-15301027
]
Edoardo Comar commented on KAFKA-3727:
--
Thanks [~ijuma] those issues are related.
However
[
https://issues.apache.org/jira/browse/KAFKA-3682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15301010#comment-15301010
]
Edoardo Comar commented on KAFKA-3682:
--
[~vahid] you can just run my unit test without the fix in
[
https://issues.apache.org/jira/browse/KAFKA-3682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15300756#comment-15300756
]
Edoardo Comar commented on KAFKA-3682:
--
Hi this is a pretty simple fix, backed by a unit test. May
[
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
[
https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15300482#comment-15300482
]
Edoardo Comar commented on KAFKA-3727:
--
Hi can please anyone comment on this (IMHO) buggy behavior ?
[
https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15296538#comment-15296538
]
Edoardo Comar commented on KAFKA-3727:
--
My expectation is that with either subscribe() and assign()
[
https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15296398#comment-15296398
]
Edoardo Comar commented on KAFKA-3727:
--
The consumer remains stuck in a loop because
{quote}
[
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
[
https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15296394#comment-15296394
]
Edoardo Comar commented on KAFKA-3727:
--
To explain better, this is a stack trace when the consumer is
[
https://issues.apache.org/jira/browse/KAFKA-3567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15296163#comment-15296163
]
Edoardo Comar commented on KAFKA-3567:
--
Hi, the console producer has these options:
[
https://issues.apache.org/jira/browse/KAFKA-3728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15293272#comment-15293272
]
Edoardo Comar commented on KAFKA-3728:
--
Thanks [~rsivaram]
it wasn't obvious that ack=-1 requires a
[
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
[
https://issues.apache.org/jira/browse/KAFKA-3396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15289551#comment-15289551
]
Edoardo Comar commented on KAFKA-3396:
--
I'm held back by
[
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
[
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
[
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:
[
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
[
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
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
[
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
>
[
https://issues.apache.org/jira/browse/KAFKA-3396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15287873#comment-15287873
]
Edoardo Comar commented on KAFKA-3396:
--
Hi [~granthenke] we're still working on it,
we're working to
[
https://issues.apache.org/jira/browse/KAFKA-3396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15282659#comment-15282659
]
Edoardo Comar commented on KAFKA-3396:
--
Hi [~granthenke] I thought that if a user has DESCRIBE
[
https://issues.apache.org/jira/browse/KAFKA-3396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15280197#comment-15280197
]
Edoardo Comar commented on KAFKA-3396:
--
Hi
we have worked on a simple patch that would return
[
https://issues.apache.org/jira/browse/KAFKA-3688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15278669#comment-15278669
]
Edoardo Comar commented on KAFKA-3688:
--
thanks [~rsivaram] it wasn't obvious how to express the jaas
[
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
>
[
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
>
[
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
[
https://issues.apache.org/jira/browse/KAFKA-3688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15278511#comment-15278511
]
Edoardo Comar commented on KAFKA-3688:
--
Hi, that's what I've done by adding the KafkaClient section
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
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
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:
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
[
https://issues.apache.org/jira/browse/KAFKA-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15274977#comment-15274977
]
Edoardo Comar commented on KAFKA-3587:
--
[~junrao] the difference between option 1 and option 2 is
[
https://issues.apache.org/jira/browse/KAFKA-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15274622#comment-15274622
]
Edoardo Comar commented on KAFKA-3587:
--
[~junrao] thanks for your observation
[
https://issues.apache.org/jira/browse/KAFKA-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15274204#comment-15274204
]
Edoardo Comar commented on KAFKA-3587:
--
For clarity, [~mimaison] PR
[
https://issues.apache.org/jira/browse/KAFKA-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15273821#comment-15273821
]
Edoardo Comar commented on KAFKA-3587:
--
[~junrao] I was thinking of two possible optimistic
[
https://issues.apache.org/jira/browse/KAFKA-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15273482#comment-15273482
]
Edoardo Comar commented on KAFKA-3587:
--
[~ishiihara] In your PR the very pessimistic check
val
[
https://issues.apache.org/jira/browse/KAFKA-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15273455#comment-15273455
]
Edoardo Comar commented on KAFKA-3587:
--
[~alekar] I had a look at your patch. The approach you took
[
https://issues.apache.org/jira/browse/KAFKA-2273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263195#comment-15263195
]
Edoardo Comar commented on KAFKA-2273:
--
Working on this with [~vahid] - propagating the overall
[
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
[
https://issues.apache.org/jira/browse/KAFKA-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253833#comment-15253833
]
Edoardo Comar commented on KAFKA-3587:
--
Hi I was having a look at this issue too.
in
[
https://issues.apache.org/jira/browse/KAFKA-3415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1510#comment-1510
]
Edoardo Comar commented on KAFKA-3415:
--
As the user opening the JIRA stated, they use the scripts as
[
https://issues.apache.org/jira/browse/KAFKA-3415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15199776#comment-15199776
]
Edoardo Comar commented on KAFKA-3415:
--
I agree that the retcode to the shell should be 0, not 1.
I
[
https://issues.apache.org/jira/browse/KAFKA-2832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15197454#comment-15197454
]
Edoardo Comar commented on KAFKA-2832:
--
Hi all, Vahid is on vacation so I am creating a new pull
101 - 150 of 150 matches
Mail list logo
