[jira] [Created] (KAFKA-7666) KIP-391: Allow Producing with Offsets for Cluster Replication

Edoardo Comar created KAFKA-7666: Summary: KIP-391: Allow Producing with Offsets for Cluster Replication Key: KAFKA-7666 URL: https://issues.apache.org/jira/browse/KAFKA-7666 Project: Kafka

[jira] [Created] (KAFKA-7720) kafka-configs script should also describe default broker entries

Edoardo Comar created KAFKA-7720: Summary: kafka-configs script should also describe default broker entries Key: KAFKA-7720 URL: https://issues.apache.org/jira/browse/KAFKA-7720 Project: Kafka

[jira] [Resolved] (KAFKA-7761) CLONE - Add broker configuration to set minimum value for segment.bytes and segment.ms

[ https://issues.apache.org/jira/browse/KAFKA-7761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar resolved KAFKA-7761. -- Resolution: Duplicate if there is a valid reason for a duplicate, feel free to repoen > CLONE

[jira] [Created] (KAFKA-6994) KafkaConsumer.poll throwing AuthorizationException timeout-dependent

Edoardo Comar created KAFKA-6994: Summary: KafkaConsumer.poll throwing AuthorizationException timeout-dependent Key: KAFKA-6994 URL: https://issues.apache.org/jira/browse/KAFKA-6994 Project: Kafka

[jira] [Created] (KAFKA-6516) KafkaProducer retries indefinitely to authenticate on SaslAuthenticationException

Edoardo Comar created KAFKA-6516: Summary: KafkaProducer retries indefinitely to authenticate on SaslAuthenticationException Key: KAFKA-6516 URL: https://issues.apache.org/jira/browse/KAFKA-6516 Proje

[jira] [Resolved] (KAFKA-6516) KafkaProducer retries indefinitely to authenticate on SaslAuthenticationException

[ https://issues.apache.org/jira/browse/KAFKA-6516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar resolved KAFKA-6516. -- Resolution: Won't Fix thanks, [~rsivaram] so my expectation was invalid then > KafkaProducer re

[jira] [Created] (KAFKA-6726) KIP-277 - Fine Grained ACL for CreateTopics A

Edoardo Comar created KAFKA-6726: Summary: KIP-277 - Fine Grained ACL for CreateTopics A Key: KAFKA-6726 URL: https://issues.apache.org/jira/browse/KAFKA-6726 Project: Kafka Issue Type: Impro

[jira] [Resolved] (KAFKA-5497) KIP-170: Enhanced CreateTopicPolicy and DeleteTopicPolicy

[ https://issues.apache.org/jira/browse/KAFKA-5497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar resolved KAFKA-5497. -- Resolution: Won't Fix superseded by  https://cwiki.apache.org/confluence/display/KAFKA/KIP-201%3

[jira] [Created] (KAFKA-6863) Kafka clients should try to use multiple DNS resolved IP addresses if the first one fails

Edoardo Comar created KAFKA-6863: Summary: Kafka clients should try to use multiple DNS resolved IP addresses if the first one fails Key: KAFKA-6863 URL: https://issues.apache.org/jira/browse/KAFKA-6863

[jira] [Resolved] (KAFKA-4206) Improve handling of invalid credentials to mitigate DOS issue (especially on SSL listeners)

[ https://issues.apache.org/jira/browse/KAFKA-4206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar resolved KAFKA-4206. -- Resolution: Won't Do > Improve handling of invalid credentials to mitigate DOS issue (especially

[jira] [Created] (KAFKA-7861) AlterConfig may change the source of another config entry if it matches the broker default

Edoardo Comar created KAFKA-7861: Summary: AlterConfig may change the source of another config entry if it matches the broker default Key: KAFKA-7861 URL: https://issues.apache.org/jira/browse/KAFKA-7861

[jira] [Resolved] (KAFKA-8564) NullPointerException when loading logs at startup

[ https://issues.apache.org/jira/browse/KAFKA-8564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar resolved KAFKA-8564. -- Resolution: Fixed Fix Version/s: 2.2.2 2.1.2 2.3.0

[jira] [Assigned] (KAFKA-5418) ZkUtils.getAllPartitions() may fail if a topic is marked for deletion

[ https://issues.apache.org/jira/browse/KAFKA-5418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar reassigned KAFKA-5418: Assignee: Edoardo Comar > ZkUtils.getAllPartitions() may fail if a topic is marked for dele

[jira] [Created] (KAFKA-5497) KIP-170: Enhanced CreateTopicPolicy and DeleteTopicPolicy

Issue Type: Improvement Reporter: Edoardo Comar Assignee: Edoardo Comar JIRA for the implementation of KIP-170 https://cwiki.apache.org/confluence/display/KAFKA/KIP-170%3A+Enhanced+TopicCreatePolicy+and+introduction+of+TopicDeletePolicy -- This message was sent by

[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] [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] [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] [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] [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: 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: - Description: The behavior of a consumer on poll() for a non-existing topic is surprisingly differ

[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] [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] [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-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] [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-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] [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=15296398#comment-15296398 ] Edoardo Comar commented on KAFKA-3727: -- The consumer remains stuck in a loop because

[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=15300482#comment-15300482 ] Edoardo Comar commented on KAFKA-3727: -- Hi can please anyone comment on this (IMHO) b

[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-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] [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-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-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=15324424#comment-15324424 ] Edoardo Comar commented on KAFKA-3727: -- [~ijuma] [~hachikuji] ... reposting here as m

[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=15324450#comment-15324450 ] Edoardo Comar commented on KAFKA-3727: -- I think it would be reasonable to have the po

[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] [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-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-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-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] [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=15347169#comment-15347169 ] Edoardo Comar commented on KAFKA-3727: -- Thanks [~hachikuji], sure I could start a sma

[jira] [Created] (KAFKA-3899) Consumer.poll() stuck in loop if wrong credentials are supplied

Edoardo Comar created KAFKA-3899: Summary: Consumer.poll() stuck in loop if wrong credentials are supplied Key: KAFKA-3899 URL: https://issues.apache.org/jira/browse/KAFKA-3899 Project: Kafka

[jira] [Commented] (KAFKA-3899) Consumer.poll() stuck in loop if wrong credentials are supplied

[ https://issues.apache.org/jira/browse/KAFKA-3899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15348164#comment-15348164 ] Edoardo Comar commented on KAFKA-3899: -- A less important use case that shows the same

[jira] [Commented] (KAFKA-3899) Consumer.poll() stuck in loop if wrong credentials are supplied

[ https://issues.apache.org/jira/browse/KAFKA-3899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15348172#comment-15348172 ] Edoardo Comar commented on KAFKA-3899: -- The Producer is instead more protected agains

[jira] [Updated] (KAFKA-3899) Consumer.poll() stuck in loop if wrong credentials are supplied

[ https://issues.apache.org/jira/browse/KAFKA-3899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar updated KAFKA-3899: - Affects Version/s: 0.10.1.0 > Consumer.poll() stuck in loop if wrong credentials are supplied > --

[jira] [Commented] (KAFKA-3899) Consumer.poll() stuck in loop if wrong credentials are supplied

[ https://issues.apache.org/jira/browse/KAFKA-3899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15348181#comment-15348181 ] Edoardo Comar commented on KAFKA-3899: -- Like in the case of issue https://issues.apac

[jira] [Commented] (KAFKA-3827) log.message.format.version should default to inter.broker.protocol.version

[ https://issues.apache.org/jira/browse/KAFKA-3827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15370562#comment-15370562 ] Edoardo Comar commented on KAFKA-3827: -- Hu [~junrao] [~ijuma] [~ewencp] given that th

[jira] [Assigned] (KAFKA-4441) Kafka Monitoring is incorrect during rapid topic creation and deletion

[ https://issues.apache.org/jira/browse/KAFKA-4441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar reassigned KAFKA-4441: Assignee: Edoardo Comar > Kafka Monitoring is incorrect during rapid topic creation and del

[jira] [Created] (KAFKA-4531) Rationalise client configuration validation

Edoardo Comar created KAFKA-4531: Summary: Rationalise client configuration validation Key: KAFKA-4531 URL: https://issues.apache.org/jira/browse/KAFKA-4531 Project: Kafka Issue Type: Improv

[jira] [Commented] (KAFKA-4180) Shared authentication with multiple active Kafka producers/consumers

[ https://issues.apache.org/jira/browse/KAFKA-4180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748758#comment-15748758 ] Edoardo Comar commented on KAFKA-4180: -- I have updated the PR based on the discussion

[jira] [Commented] (KAFKA-4180) Shared authentication with multiple active Kafka producers/consumers

[ https://issues.apache.org/jira/browse/KAFKA-4180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15780212#comment-15780212 ] Edoardo Comar commented on KAFKA-4180: -- Now that https://issues.apache.org/jira/brows

[jira] [Commented] (KAFKA-1368) Upgrade log4j

[ https://issues.apache.org/jira/browse/KAFKA-1368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15892271#comment-15892271 ] Edoardo Comar commented on KAFKA-1368: -- Yes [~ijuma] we will pick this one up. I work

[jira] [Commented] (KAFKA-4669) KafkaProducer.flush hangs when NetworkClient.handleCompletedReceives throws exception

[ https://issues.apache.org/jira/browse/KAFKA-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15897747#comment-15897747 ] Edoardo Comar commented on KAFKA-4669: -- It's easy to discard and recreate the consume

[jira] [Commented] (KAFKA-4669) KafkaProducer.flush hangs when NetworkClient.handleCompletedReceives throws exception

[ https://issues.apache.org/jira/browse/KAFKA-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15897746#comment-15897746 ] Edoardo Comar commented on KAFKA-4669: -- We've seen this same exception using 10.0.1 c

[jira] [Commented] (KAFKA-4669) KafkaProducer.flush hangs when NetworkClient.handleCompletedReceives throws exception

[ https://issues.apache.org/jira/browse/KAFKA-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15899827#comment-15899827 ] Edoardo Comar commented on KAFKA-4669: -- We have found a strong correlation between th

[jira] [Commented] (KAFKA-4669) KafkaProducer.flush hangs when NetworkClient.handleCompletedReceives throws exception

[ https://issues.apache.org/jira/browse/KAFKA-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15899847#comment-15899847 ] Edoardo Comar commented on KAFKA-4669: -- [~ijuma] It's the same NPE as https://issues

[jira] [Commented] (KAFKA-4669) KafkaProducer.flush hangs when NetworkClient.handleCompletedReceives throws exception

[ https://issues.apache.org/jira/browse/KAFKA-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15901075#comment-15901075 ] Edoardo Comar commented on KAFKA-4669: -- The NPE moved from broker1 to another broker

[jira] [Commented] (KAFKA-4669) KafkaProducer.flush hangs when NetworkClient.handleCompletedReceives throws exception

[ https://issues.apache.org/jira/browse/KAFKA-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15901349#comment-15901349 ] Edoardo Comar commented on KAFKA-4669: -- thanks [~ijuma] yes we're planning to move to

[jira] [Created] (KAFKA-4981) Add connection-accept-rate and connection-prepare-rate metrics

Edoardo Comar created KAFKA-4981: Summary: Add connection-accept-rate and connection-prepare-rate metrics Key: KAFKA-4981 URL: https://issues.apache.org/jira/browse/KAFKA-4981 Project: Kafka

[jira] [Created] (KAFKA-4982) Add listener tag to socket-server-metrics.connection-... metrics

Edoardo Comar created KAFKA-4982: Summary: Add listener tag to socket-server-metrics.connection-... metrics Key: KAFKA-4982 URL: https://issues.apache.org/jira/browse/KAFKA-4982 Project: Kafka

[jira] [Assigned] (KAFKA-4982) Add listener tag to socket-server-metrics.connection-... metrics

[ https://issues.apache.org/jira/browse/KAFKA-4982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar reassigned KAFKA-4982: Assignee: Edoardo Comar > Add listener tag to socket-server-metrics.connection-... metrics

[jira] [Commented] (KAFKA-4982) Add listener tag to socket-server-metrics.connection-... metrics

[ https://issues.apache.org/jira/browse/KAFKA-4982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949036#comment-15949036 ] Edoardo Comar commented on KAFKA-4982: -- [~ijuma] does this need a kip ? > Add listen

[jira] [Commented] (KAFKA-4981) Add connection-accept-rate and connection-prepare-rate metrics

[ https://issues.apache.org/jira/browse/KAFKA-4981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949221#comment-15949221 ] Edoardo Comar commented on KAFKA-4981: -- as per comments on the pull request, the 'pre

[jira] [Commented] (KAFKA-4981) Add connection-accept-rate and connection-prepare-rate metrics

[ https://issues.apache.org/jira/browse/KAFKA-4981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949223#comment-15949223 ] Edoardo Comar commented on KAFKA-4981: -- Thanks I know the block is skipped for PLAIN

[jira] [Commented] (KAFKA-4981) Add connection-accept-rate and connection-prepare-rate metrics

[ https://issues.apache.org/jira/browse/KAFKA-4981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949229#comment-15949229 ] Edoardo Comar commented on KAFKA-4981: -- Hi [~ijuma] for the 3rd time today :-) ... do

[jira] [Commented] (KAFKA-4982) Add listener tag to socket-server-metrics.connection-... metrics

[ https://issues.apache.org/jira/browse/KAFKA-4982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15962765#comment-15962765 ] Edoardo Comar commented on KAFKA-4982: -- KIP is https://cwiki.apache.org/confluence/di

[jira] [Commented] (KAFKA-2729) Cached zkVersion not equal to that in zookeeper, broker not recovering.

[ https://issues.apache.org/jira/browse/KAFKA-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15967735#comment-15967735 ] Edoardo Comar commented on KAFKA-2729: -- FWIW - we saw the same message {{ Cached zk

[jira] [Created] (KAFKA-5081) two versions of jackson-annotations-xxx.jar in distribution tgz

Edoardo Comar created KAFKA-5081: Summary: two versions of jackson-annotations-xxx.jar in distribution tgz Key: KAFKA-5081 URL: https://issues.apache.org/jira/browse/KAFKA-5081 Project: Kafka

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

[ https://issues.apache.org/jira/browse/KAFKA-4795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977538#comment-15977538 ] Edoardo Comar commented on KAFKA-4795: -- [~vahid] I may still see topics ??marked for

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

[ https://issues.apache.org/jira/browse/KAFKA-4795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977538#comment-15977538 ] Edoardo Comar edited comment on KAFKA-4795 at 4/20/17 9:13 PM: -

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

[ https://issues.apache.org/jira/browse/KAFKA-4795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977538#comment-15977538 ] Edoardo Comar edited comment on KAFKA-4795 at 4/20/17 9:15 PM: -

[jira] [Commented] (KAFKA-1368) Upgrade log4j

[ https://issues.apache.org/jira/browse/KAFKA-1368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15801283#comment-15801283 ] Edoardo Comar commented on KAFKA-1368: -- Moving to Log4j v2 would allow dynamic reconf

[jira] [Updated] (KAFKA-4441) Kafka Monitoring is incorrect during rapid topic creation and deletion

[ https://issues.apache.org/jira/browse/KAFKA-4441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar updated KAFKA-4441: - Priority: Major (was: Minor) > Kafka Monitoring is incorrect during rapid topic creation and dele

[jira] [Commented] (KAFKA-4441) Kafka Monitoring is incorrect during rapid topic creation and deletion

[ https://issues.apache.org/jira/browse/KAFKA-4441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15804732#comment-15804732 ] Edoardo Comar commented on KAFKA-4441: -- Raising the severity because we've seen this

[jira] [Created] (KAFKA-4605) MetricsRegistry during KafkaServerTestHarness polluted by side effects

Edoardo Comar created KAFKA-4605: Summary: MetricsRegistry during KafkaServerTestHarness polluted by side effects Key: KAFKA-4605 URL: https://issues.apache.org/jira/browse/KAFKA-4605 Project: Kafka

[jira] [Commented] (KAFKA-4441) Kafka Monitoring is incorrect during rapid topic creation and deletion

[ https://issues.apache.org/jira/browse/KAFKA-4441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15804874#comment-15804874 ] Edoardo Comar commented on KAFKA-4441: -- For the {{UnderReplicatedPartitions}} metrics

[jira] [Comment Edited] (KAFKA-4441) Kafka Monitoring is incorrect during rapid topic creation and deletion

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

[jira] [Commented] (KAFKA-4441) Kafka Monitoring is incorrect during rapid topic creation and deletion

[ https://issues.apache.org/jira/browse/KAFKA-4441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15812411#comment-15812411 ] Edoardo Comar commented on KAFKA-4441: -- Please ignore the previous comment - the {{Un

[jira] [Commented] (KAFKA-4611) Support custom authentication mechanism

[ https://issues.apache.org/jira/browse/KAFKA-4611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15814508#comment-15814508 ] Edoardo Comar commented on KAFKA-4611: -- Hi, I am not sure what you are asking is not

[jira] [Created] (KAFKA-4617) gradle-generated core eclipse project has incorrect source folder structure

Edoardo Comar created KAFKA-4617: Summary: gradle-generated core eclipse project has incorrect source folder structure Key: KAFKA-4617 URL: https://issues.apache.org/jira/browse/KAFKA-4617 Project: Ka

[jira] [Commented] (KAFKA-4617) gradle-generated core eclipse project has incorrect source folder structure

[ https://issues.apache.org/jira/browse/KAFKA-4617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15818047#comment-15818047 ] Edoardo Comar commented on KAFKA-4617: -- Hi [~dhwanikatagade], thanks I saw that threa

[jira] [Updated] (KAFKA-4617) gradle-generated core eclipse project has incorrect source folder structure

[ https://issues.apache.org/jira/browse/KAFKA-4617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar updated KAFKA-4617: - Description: The gradle-generated Eclipse Scala project for Kafka core has a classpath defined as

[jira] [Commented] (KAFKA-4617) gradle-generated core eclipse project has incorrect source folder structure

[ https://issues.apache.org/jira/browse/KAFKA-4617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824788#comment-15824788 ] Edoardo Comar commented on KAFKA-4617: -- [~dhwanikatagade] thanks for the patch, The

[jira] [Commented] (KAFKA-4617) gradle-generated core eclipse project has incorrect source folder structure

[ https://issues.apache.org/jira/browse/KAFKA-4617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15826797#comment-15826797 ] Edoardo Comar commented on KAFKA-4617: -- [~dhwanikatagade] thanks for the PR ! > grad

[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

[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-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-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] [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-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] [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-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=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=15274204#comment-15274204 ] Edoardo Comar commented on KAFKA-3587: -- For clarity, [~mimaison] PR https://github.co

  1   2   >