[jira] [Created] (KAFKA-10220) NPE when describing resources

2020-06-30 Thread Edoardo Comar (Jira)
Edoardo Comar created KAFKA-10220: - Summary: NPE when describing resources Key: KAFKA-10220 URL: https://issues.apache.org/jira/browse/KAFKA-10220 Project: Kafka Issue Type: Bug

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

2019-06-20 Thread Edoardo Comar (JIRA)
[ 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] [Created] (KAFKA-7861) AlterConfig may change the source of another config entry if it matches the broker default

2019-01-23 Thread Edoardo Comar (JIRA)
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-7761) CLONE - Add broker configuration to set minimum value for segment.bytes and segment.ms

2018-12-24 Thread Edoardo Comar (JIRA)
[ 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-7720) kafka-configs script should also describe default broker entries

2018-12-11 Thread Edoardo Comar (JIRA)
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] [Created] (KAFKA-7666) KIP-391: Allow Producing with Offsets for Cluster Replication

2018-11-21 Thread Edoardo Comar (JIRA)
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-6994) KafkaConsumer.poll throwing AuthorizationException timeout-dependent

2018-06-05 Thread Edoardo Comar (JIRA)
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-6863) Kafka clients should try to use multiple DNS resolved IP addresses if the first one fails

2018-05-04 Thread Edoardo Comar (JIRA)
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-5497) KIP-170: Enhanced CreateTopicPolicy and DeleteTopicPolicy

2018-04-26 Thread Edoardo Comar (JIRA)
[ 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 

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

2018-03-29 Thread Edoardo Comar (JIRA)
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:

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

2018-02-01 Thread Edoardo Comar (JIRA)
[ 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

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

2018-02-01 Thread Edoardo Comar (JIRA)
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

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

2017-09-29 Thread Edoardo Comar (JIRA)
[ 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

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

2017-06-22 Thread Edoardo Comar (JIRA)
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

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

2017-06-12 Thread Edoardo Comar (JIRA)
[ 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

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

2017-06-09 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar updated KAFKA-5418: - Description: Running {{ZkUtils.getAllPartitions()}} on a cluster which had a topic stuck in the

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

2017-06-09 Thread Edoardo Comar (JIRA)
Edoardo Comar created KAFKA-5418: Summary: ZkUtils.getAllPartitions() may fail if a topic is marked for deletion Key: KAFKA-5418 URL: https://issues.apache.org/jira/browse/KAFKA-5418 Project: Kafka

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

2017-06-09 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar updated KAFKA-5418: - Description: Running {{ZkUtils.getAllPartitions()}} on a cluster which had a topic stuck in the

[jira] [Commented] (KAFKA-5290) docs need clarification on meaning of 'committed' to the log

2017-05-30 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16029248#comment-16029248 ] Edoardo Comar commented on KAFKA-5290: -- https://github.com/apache/kafka/pull/3035 > docs need

[jira] [Updated] (KAFKA-5290) docs need clarification on meaning of 'committed' to the log

2017-05-19 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar updated KAFKA-5290: - Description: The docs around http://kafka.apache.org/documentation/#semantics

[jira] [Updated] (KAFKA-5290) docs need clarification on meaning of 'committed' to the log

2017-05-19 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar updated KAFKA-5290: - Description: The docs around http://kafka.apache.org/documentation/#semantics

[jira] [Created] (KAFKA-5290) docs need clarification on meaning of 'committed' to the log

2017-05-19 Thread Edoardo Comar (JIRA)
Edoardo Comar created KAFKA-5290: Summary: docs need clarification on meaning of 'committed' to the log Key: KAFKA-5290 URL: https://issues.apache.org/jira/browse/KAFKA-5290 Project: Kafka

[jira] [Updated] (KAFKA-5200) If a replicated topic is deleted with one broker down, it can't be recreated

2017-05-15 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar updated KAFKA-5200: - Summary: If a replicated topic is deleted with one broker down, it can't be recreated (was:

[jira] [Commented] (KAFKA-5200) Deleting topic when one broker is down will prevent topic to be re-creatable

2017-05-15 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010608#comment-16010608 ] Edoardo Comar commented on KAFKA-5200: -- I am actually hoping for someone familiar with the non-open

[jira] [Comment Edited] (KAFKA-5200) Deleting topic when one broker is down will prevent topic to be re-creatable

2017-05-15 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010608#comment-16010608 ] Edoardo Comar edited comment on KAFKA-5200 at 5/15/17 2:29 PM: --- I am

[jira] [Commented] (KAFKA-5200) Deleting topic when one broker is down will prevent topic to be re-creatable

2017-05-15 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010601#comment-16010601 ] Edoardo Comar commented on KAFKA-5200: -- Thanks [~huxi_2b] unfortunately such steps would imply

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

2017-05-12 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008499#comment-16008499 ] Edoardo Comar commented on KAFKA-4982: -- Thanks [~ijuma] following the discussion in the PR thread,

[jira] [Commented] (KAFKA-5200) Deleting topic when one broker is down will prevent topic to be re-creatable

2017-05-12 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007893#comment-16007893 ] Edoardo Comar commented on KAFKA-5200: -- [~huxi_2b] if we could restart the broker that's down there

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

2017-05-10 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16004675#comment-16004675 ] Edoardo Comar commented on KAFKA-4982: -- The implementation took the slight deviation from the KIP

[jira] [Commented] (KAFKA-5201) Compacted topic could be misused to fill up a disk but deletion policy can't retain legitimate keys

2017-05-09 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16002885#comment-16002885 ] Edoardo Comar commented on KAFKA-5201: -- Thanks [~mihbor] Sure there is no concept of legitimate vs

[jira] [Resolved] (KAFKA-5201) Compacted topic could be misused to fill up a disk but deletion policy can't retain legitimate keys

2017-05-09 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar resolved KAFKA-5201. -- Resolution: Not A Problem > Compacted topic could be misused to fill up a disk but deletion

[jira] [Updated] (KAFKA-5201) Compacted topic could be misused to fill up a disk but deletion policy can't retain legitimate keys

2017-05-08 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar updated KAFKA-5201: - Summary: Compacted topic could be misused to fill up a disk but deletion policy can't retain

[jira] [Created] (KAFKA-5201) Compacted topic could be misused up to fill a disk;

2017-05-08 Thread Edoardo Comar (JIRA)
Edoardo Comar created KAFKA-5201: Summary: Compacted topic could be misused up to fill a disk; Key: KAFKA-5201 URL: https://issues.apache.org/jira/browse/KAFKA-5201 Project: Kafka Issue

[jira] [Created] (KAFKA-5200) Deleting topic when one broker is down will prevent topic to be re-creatable

2017-05-08 Thread Edoardo Comar (JIRA)
Edoardo Comar created KAFKA-5200: Summary: Deleting topic when one broker is down will prevent topic to be re-creatable Key: KAFKA-5200 URL: https://issues.apache.org/jira/browse/KAFKA-5200 Project:

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

2017-04-20 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15977538#comment-15977538 ] Edoardo Comar edited comment on KAFKA-4795 at 4/20/17 9:15 PM: --- [~vahid] I

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

2017-04-20 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15977538#comment-15977538 ] Edoardo Comar edited comment on KAFKA-4795 at 4/20/17 9:13 PM: --- [~vahid] I

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

2017-04-20 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15977538#comment-15977538 ] Edoardo Comar commented on KAFKA-4795: -- [~vahid] I may still see topics ??marked for deletion?? when

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

2017-04-18 Thread Edoardo Comar (JIRA)
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-2729) Cached zkVersion not equal to that in zookeeper, broker not recovering.

2017-04-13 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15967735#comment-15967735 ] Edoardo Comar commented on KAFKA-2729: -- FWIW - we saw the same message {{ Cached zkVersion [66] not

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

2017-04-10 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15962765#comment-15962765 ] Edoardo Comar commented on KAFKA-4982: -- KIP is

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

2017-03-30 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15949229#comment-15949229 ] Edoardo Comar commented on KAFKA-4981: -- Hi [~ijuma] for the 3rd time today :-) ... does this need a

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

2017-03-30 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15949223#comment-15949223 ] Edoardo Comar commented on KAFKA-4981: -- Thanks I know the block is skipped for PLAINTEXT. Actually

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

2017-03-30 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15949221#comment-15949221 ] Edoardo Comar commented on KAFKA-4981: -- as per comments on the pull request, the 'prepared' metric

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

2017-03-30 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15949036#comment-15949036 ] Edoardo Comar commented on KAFKA-4982: -- [~ijuma] does this need a kip ? > Add listener tag to

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

2017-03-30 Thread Edoardo Comar (JIRA)
[ 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] [Created] (KAFKA-4982) Add listener tag to socket-server-metrics.connection-... metrics

2017-03-30 Thread Edoardo Comar (JIRA)
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] [Created] (KAFKA-4981) Add connection-accept-rate and connection-prepare-rate metrics

2017-03-30 Thread Edoardo Comar (JIRA)
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] [Commented] (KAFKA-4669) KafkaProducer.flush hangs when NetworkClient.handleCompletedReceives throws exception

2017-03-08 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901349#comment-15901349 ] Edoardo Comar commented on KAFKA-4669: -- thanks [~ijuma] yes we're planning to move to 0.10.2 very

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

2017-03-08 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901075#comment-15901075 ] Edoardo Comar commented on KAFKA-4669: -- The NPE moved from broker1 to another broker when the former

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

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

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

2017-03-07 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15899827#comment-15899827 ] Edoardo Comar commented on KAFKA-4669: -- We have found a strong correlation between the clients

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

2017-03-06 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15897746#comment-15897746 ] Edoardo Comar commented on KAFKA-4669: -- We've seen this same exception using 10.0.1 clients against

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

2017-03-06 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15897747#comment-15897747 ] Edoardo Comar commented on KAFKA-4669: -- It's easy to discard and recreate the consumer instance to

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

2017-03-02 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15892271#comment-15892271 ] Edoardo Comar commented on KAFKA-1368: -- Yes [~ijuma] we will pick this one up. I work together with

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

2017-01-17 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15826797#comment-15826797 ] Edoardo Comar commented on KAFKA-4617: -- [~dhwanikatagade] thanks for the PR ! > gradle-generated

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

2017-01-16 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15824788#comment-15824788 ] Edoardo Comar commented on KAFKA-4617: -- [~dhwanikatagade] thanks for the patch, The source folders

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

2017-01-12 Thread Edoardo Comar (JIRA)
[ 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

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

2017-01-11 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15818047#comment-15818047 ] Edoardo Comar commented on KAFKA-4617: -- Hi [~dhwanikatagade], thanks I saw that thread and that's

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

2017-01-11 Thread Edoardo Comar (JIRA)
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:

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

2017-01-10 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15814508#comment-15814508 ] Edoardo Comar commented on KAFKA-4611: -- Hi, I am not sure what you are asking is not covered already

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

2017-01-09 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15812411#comment-15812411 ] Edoardo Comar commented on KAFKA-4441: -- Please ignore the previous comment - the

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

2017-01-06 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15804874#comment-15804874 ] Edoardo Comar edited comment on KAFKA-4441 at 1/6/17 4:16 PM: -- For the

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

2017-01-06 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15804874#comment-15804874 ] Edoardo Comar commented on KAFKA-4441: -- For the {{UnderReplicatedPartitions}} metrics, the Gauge

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

2017-01-06 Thread Edoardo Comar (JIRA)
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

2017-01-06 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15804732#comment-15804732 ] Edoardo Comar commented on KAFKA-4441: -- Raising the severity because we've seen this spurious metric

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

2017-01-06 Thread Edoardo Comar (JIRA)
[ 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

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

2017-01-05 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15801283#comment-15801283 ] Edoardo Comar commented on KAFKA-1368: -- Moving to Log4j v2 would allow dynamic reconfiguration of the

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

2016-12-27 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15780212#comment-15780212 ] Edoardo Comar commented on KAFKA-4180: -- Now that https://issues.apache.org/jira/browse/KAFKA-4259 has

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

2016-12-14 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15748758#comment-15748758 ] Edoardo Comar commented on KAFKA-4180: -- I have updated the PR based on the discussion in the mailing

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

2016-12-13 Thread Edoardo Comar (JIRA)
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:

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

2016-12-07 Thread Edoardo Comar (JIRA)
[ 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

[jira] [Commented] (KAFKA-4185) Abstract out password verifier in SaslServer as an injectable dependency

2016-10-13 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15571363#comment-15571363 ] Edoardo Comar commented on KAFKA-4185: -- Hi [~piyushvijay] I see that a KIP has been proposed as a

[jira] [Commented] (KAFKA-3302) Pass kerberos keytab and principal as part of client config

2016-10-06 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15551821#comment-15551821 ] Edoardo Comar commented on KAFKA-3302: -- looks like [~rsivaram]'s

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

2016-09-28 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15529377#comment-15529377 ] Edoardo Comar commented on KAFKA-3396: -- new PR is https://github.com/apache/kafka/pull/1908 >

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

2016-09-27 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar reassigned KAFKA-3899: Assignee: Edoardo Comar > Consumer.poll() stuck in loop if wrong credentials are supplied

[jira] [Commented] (KAFKA-4185) Abstract out password verifier in SaslServer as an injectable dependency

2016-09-27 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526623#comment-15526623 ] Edoardo Comar commented on KAFKA-4185: -- I think this is a duplicate of

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

2016-09-27 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526574#comment-15526574 ] Edoardo Comar commented on KAFKA-4180: -- Hi [~sriharsha] thanks for pointing this out. I'd say this

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

2016-09-27 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar resolved KAFKA-3679. -- Resolution: Won't Fix The Documentation

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

2016-09-22 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar updated KAFKA-4206: - Description: The current handling of invalid credentials (ie wrong user/password) is to let the

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

2016-09-22 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar updated KAFKA-4206: - Description: The current handling of invalid credentials (ie wrong user/password) is to let the

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

2016-09-22 Thread Edoardo Comar (JIRA)
Edoardo Comar created KAFKA-4206: Summary: Improve handling of invalid credentials to mitigate DOS issue (especially on SSL listeners) Key: KAFKA-4206 URL: https://issues.apache.org/jira/browse/KAFKA-4206

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

2016-07-11 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15370562#comment-15370562 ] Edoardo Comar commented on KAFKA-3827: -- Hu [~junrao] [~ijuma] [~ewencp] given that the upgrade docs

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

2016-06-24 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15348181#comment-15348181 ] Edoardo Comar commented on KAFKA-3899: -- Like in the case of issue

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

2016-06-24 Thread Edoardo Comar (JIRA)
[ 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

2016-06-24 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15348172#comment-15348172 ] Edoardo Comar commented on KAFKA-3899: -- The Producer is instead more protected against these issues.

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

2016-06-24 Thread Edoardo Comar (JIRA)
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-3727) Consumer.poll() stuck in loop on non-existent topic manually assigned

2016-06-23 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15347169#comment-15347169 ] Edoardo Comar commented on KAFKA-3727: -- Thanks [~hachikuji], sure I could start a small KIP - an

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

2016-06-20 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15340699#comment-15340699 ] Edoardo Comar commented on KAFKA-3727: -- [~ijuma] and [~hachikuji] referring to your comments in

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

2016-06-14 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15330850#comment-15330850 ] Edoardo Comar commented on KAFKA-3727: -- Another case where poll() hangs forever is when the user

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

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

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

2016-06-14 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15330848#comment-15330848 ] Edoardo Comar commented on KAFKA-1894: -- Another case that leads to the loop ``` public void

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

2016-06-10 Thread Edoardo Comar (JIRA)
[ 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

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

2016-06-10 Thread Edoardo Comar (JIRA)
[ 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

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

2016-06-10 Thread Edoardo Comar (JIRA)
[ 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

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

2016-06-10 Thread Edoardo Comar (JIRA)
[ 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

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

2016-06-10 Thread Edoardo Comar (JIRA)
[ 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

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

2016-05-26 Thread Edoardo Comar (JIRA)
[ 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

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

2016-05-25 Thread Edoardo Comar (JIRA)
[ 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

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

2016-05-25 Thread Edoardo Comar (JIRA)
[ 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

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

2016-05-25 Thread Edoardo Comar (JIRA)
[ 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

  1   2   >