[GitHub] kafka pull request: KAFKA-3085: BrokerChangeListener computes inco...

GitHub user dajac opened a pull request: https://github.com/apache/kafka/pull/752 KAFKA-3085: BrokerChangeListener computes inconsistent live/dead broker list You can merge this pull request into a Git repository by running: $ git pull https://github.com/dajac/kafka KAFKA-3085

[jira] [Commented] (KAFKA-3085) BrokerChangeListener computes inconsistent live/dead broker list

[ https://issues.apache.org/jira/browse/KAFKA-3085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15091625#comment-15091625 ] ASF GitHub Bot commented on KAFKA-3085: --- GitHub user dajac opened a pull request:

[jira] [Updated] (KAFKA-3085) BrokerChangeListener computes inconsistent live/dead broker list

[ https://issues.apache.org/jira/browse/KAFKA-3085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot updated KAFKA-3085: --- Status: Patch Available (was: Open) > BrokerChangeListener computes inconsistent live/dead broker lis

[GitHub] kafka pull request: MINOR: Fix a type of variable

GitHub user oyld opened a pull request: https://github.com/apache/kafka/pull/753 MINOR: Fix a type of variable requestTimeoutMs should be int. You can merge this pull request into a Git repository by running: $ git pull https://github.com/oyld/kafka type_improvement Alternativ

[jira] [Created] (KAFKA-3087) Fix documentation for retention.ms property

Raju Bairishetti created KAFKA-3087: --- Summary: Fix documentation for retention.ms property Key: KAFKA-3087 URL: https://issues.apache.org/jira/browse/KAFKA-3087 Project: Kafka Issue Type: B

[jira] [Updated] (KAFKA-3087) Fix documentation for retention.ms property and update documentation for LogConfig.scala class

[ https://issues.apache.org/jira/browse/KAFKA-3087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raju Bairishetti updated KAFKA-3087: Summary: Fix documentation for retention.ms property and update documentation for LogConfig.

[jira] [Commented] (KAFKA-3087) Fix documentation for retention.ms property and update documentation for LogConfig.scala class

[ https://issues.apache.org/jira/browse/KAFKA-3087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15091671#comment-15091671 ] Raju Bairishetti commented on KAFKA-3087: - Could any one please add me as a contri

[jira] [Updated] (KAFKA-3087) Fix documentation for retention.ms property and update documentation for LogConfig.scala class

[ https://issues.apache.org/jira/browse/KAFKA-3087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raju Bairishetti updated KAFKA-3087: Description: Log retention settings can be set it in broker and some properties can be over

[jira] [Commented] (KAFKA-3054) Connect Herder fail forever if sent a wrong connector config or task config

[ https://issues.apache.org/jira/browse/KAFKA-3054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15091994#comment-15091994 ] jin xing commented on KAFKA-3054: - [~ewencp] thanks for comment : ) currently the Distribu

[jira] [Commented] (KAFKA-3019) Add an exceptionName method to Errors

[ https://issues.apache.org/jira/browse/KAFKA-3019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15092037#comment-15092037 ] ASF GitHub Bot commented on KAFKA-3019: --- GitHub user granthenke opened a pull reques

[GitHub] kafka pull request: KAFKA-3019: Add an exceptionName method to Err...

GitHub user granthenke opened a pull request: https://github.com/apache/kafka/pull/754 KAFKA-3019: Add an exceptionName method to Errors You can merge this pull request into a Git repository by running: $ git pull https://github.com/granthenke/kafka exception-name Alternative

[jira] [Updated] (KAFKA-3019) Add an exceptionName method to Errors

[ https://issues.apache.org/jira/browse/KAFKA-3019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-3019: --- Status: Patch Available (was: Open) > Add an exceptionName method to Errors > ---

Automated PR builds

It looks like the automated builds have stopped triggering. Any ideas what could be the cause? Thanks, Grant -- Grant Henke Software Engineer | Cloudera gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke

Re: Automated PR builds

I filed https://issues.apache.org/jira/browse/INFRA-11065 about an hour ago. Ismael On Mon, Jan 11, 2016 at 3:08 PM, Grant Henke wrote: > It looks like the automated builds have stopped triggering. Any ideas what > could be the cause? > > Thanks, > Grant > -- > Grant Henke > Software Engineer |

[jira] [Resolved] (KAFKA-2685) "alter topic" on non-existent topic exits without error

[ https://issues.apache.org/jira/browse/KAFKA-2685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke resolved KAFKA-2685. Resolution: Fixed Assignee: Grant Henke (was: Edward Ribeiro) > "alter topic" on non-existent

ClassLoading in OSGi environment

Hi. I have tried using 0.9.0.0, building an OSGi bundle and exporting the packages. However, when creating a Producer, I get an Ex: Caused by: org.apache.kafka.common.config.ConfigException: Invalid value org.apache.kafka.clients.producer.internals.DefaultPartitioner for configuration partitioner

Re: ClassLoading in OSGi environment

There are multiple places in Kafka where the context class loader or Class.forName() is used to load classes. Perhaps it would be better to use a common utility everywhere for dynamic classloading with an option to use the right classloader.loadClass() that works with OSGi? Regards, Rajini On Mo

[jira] [Updated] (KAFKA-2260) Allow specifying expected offset on produce

[ https://issues.apache.org/jira/browse/KAFKA-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira updated KAFKA-2260: Patch is stale, I'm uploading an updated version. > Allow specifying expected offset on produc

[jira] [Updated] (KAFKA-2260) Allow specifying expected offset on produce

[ https://issues.apache.org/jira/browse/KAFKA-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira updated KAFKA-2260: Attachment: KAFKA-2260.patch I understand we are doing patchers through github push requests

Build failed in Jenkins: kafka-trunk-jdk8 #278

See Changes: [me] MINOR: speed up connect startup when full connector class name is [me] MINOR: Add property to configure showing of standard streams in Gradle [me] MINOR: Security doc fixes [me] KAFKA-3044: Re-word consumer.poll beh

[jira] [Commented] (KAFKA-3054) Connect Herder fail forever if sent a wrong connector config or task config

[ https://issues.apache.org/jira/browse/KAFKA-3054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15092392#comment-15092392 ] Ewen Cheslack-Postava commented on KAFKA-3054: -- [~jinxing6...@126.com] We do

[GitHub] kafka pull request: KAFKA-3084: Topic existence checks in topic co...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/744 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[jira] [Commented] (KAFKA-3084) Topic existence checks in topic commands (create, alter, delete)

[ https://issues.apache.org/jira/browse/KAFKA-3084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15092396#comment-15092396 ] ASF GitHub Bot commented on KAFKA-3084: --- Github user asfgit closed the pull request

[jira] [Updated] (KAFKA-3084) Topic existence checks in topic commands (create, alter, delete)

[ https://issues.apache.org/jira/browse/KAFKA-3084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3084: - Resolution: Fixed Fix Version/s: 0.9.1.0 Status: Resolved (was:

Build failed in Jenkins: kafka-trunk-jdk7 #951

See Changes: [me] KAFKA-3084: Topic existence checks in topic commands (create, alter, -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu3 (

[jira] [Created] (KAFKA-3088) 0.9.0.0 broker crash on receipt of produce request with empty client ID

Dave Peterson created KAFKA-3088: Summary: 0.9.0.0 broker crash on receipt of produce request with empty client ID Key: KAFKA-3088 URL: https://issues.apache.org/jira/browse/KAFKA-3088 Project: Kafka

[GitHub] kafka pull request: KAFKA-3019: Add an exceptionName method to Err...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/754 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[jira] [Updated] (KAFKA-3019) Add an exceptionName method to Errors

[ https://issues.apache.org/jira/browse/KAFKA-3019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3019: - Resolution: Fixed Fix Version/s: 0.9.1.0 Status: Resolved (was:

[jira] [Commented] (KAFKA-3019) Add an exceptionName method to Errors

[ https://issues.apache.org/jira/browse/KAFKA-3019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15092503#comment-15092503 ] ASF GitHub Bot commented on KAFKA-3019: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-3079) org.apache.kafka.common.KafkaException: java.lang.SecurityException: Configuration Error:

[ https://issues.apache.org/jira/browse/KAFKA-3079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15092506#comment-15092506 ] Mohit Anchlia commented on KAFKA-3079: -- I've tried multiple entries and for some reas

[jira] [Commented] (KAFKA-3079) org.apache.kafka.common.KafkaException: java.lang.SecurityException: Configuration Error:

[ https://issues.apache.org/jira/browse/KAFKA-3079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15092524#comment-15092524 ] Ismael Juma commented on KAFKA-3079: [~mohitanchlia], what happens if you remove the "

Jenkins build is back to normal : kafka-trunk-jdk8 #279

See

Build failed in Jenkins: kafka-trunk-jdk8 #280

See Changes: [me] KAFKA-3019: Add an exceptionName method to Errors -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H11 (Ubuntu ubuntu) in works

Re: Consider increasing the default reserved.broker.max.id

Any thoughts on adding a "broker.id.generation.enabled" configuration for auto generating broker ids? If we added this and defaulted it to false, users who upgrade don't need to worry about the reserved.broker.max.id configuration since it will not be used. Users using the standard/old way of manu

Build failed in Jenkins: kafka-trunk-jdk7 #952

See Changes: [me] KAFKA-3019: Add an exceptionName method to Errors -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H11 (Ubuntu ubuntu) in works

What about Audit feature?

Hi Kafka documentation mention Audit feature in section 6.6 but https://issues.apache.org/jira/browse/KAFKA-260 is resolved Won't Fix. Should this section of the documentation be removed? Regards Luciano

Kafka KIP meeting Jan. 12 at 11:00am PST

Hi, Everyone, We will have a Kafka KIP meeting tomorrow at 11:00am PST. If you plan to attend but haven't received an invite, please let me know. The following is the agenda. Agenda: KIP-36: Rack-aware replica assignment KIP-41: KafkaConsumer Max Records Thanks, Jun

[jira] [Commented] (KAFKA-3021) Centralize dependency version managment

[ https://issues.apache.org/jira/browse/KAFKA-3021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15092794#comment-15092794 ] ASF GitHub Bot commented on KAFKA-3021: --- Github user asfgit closed the pull request

[GitHub] kafka pull request: KAFKA-3021: Centralize dependency version mana...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/741 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[jira] [Updated] (KAFKA-3021) Centralize dependency version managment

[ https://issues.apache.org/jira/browse/KAFKA-3021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3021: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved

Build failed in Jenkins: kafka-trunk-jdk7 #953

See Changes: [me] KAFKA-3021: Centralize dependency version management -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H11 (Ubuntu ubuntu) in wo

[jira] [Created] (KAFKA-3089) VerifiableProducer should do a clean shutdown in stop_node()

Dong Lin created KAFKA-3089: --- Summary: VerifiableProducer should do a clean shutdown in stop_node() Key: KAFKA-3089 URL: https://issues.apache.org/jira/browse/KAFKA-3089 Project: Kafka Issue Type:

[GitHub] kafka pull request: KAFKA-3089; VerifiableProducer should do a cle...

GitHub user lindong28 opened a pull request: https://github.com/apache/kafka/pull/755 KAFKA-3089; VerifiableProducer should do a clean shutdown in stop_node() You can merge this pull request into a Git repository by running: $ git pull https://github.com/lindong28/kafka KAFKA-

[jira] [Commented] (KAFKA-3089) VerifiableProducer should do a clean shutdown in stop_node()

[ https://issues.apache.org/jira/browse/KAFKA-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15092874#comment-15092874 ] ASF GitHub Bot commented on KAFKA-3089: --- GitHub user lindong28 opened a pull request

[GitHub] kafka pull request: KAFKA-3085: BrokerChangeListener computes inco...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/752 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[jira] [Commented] (KAFKA-3085) BrokerChangeListener computes inconsistent live/dead broker list

[ https://issues.apache.org/jira/browse/KAFKA-3085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15092892#comment-15092892 ] ASF GitHub Bot commented on KAFKA-3085: --- Github user asfgit closed the pull request

Build failed in Jenkins: kafka-trunk-jdk8 #281

See Changes: [me] KAFKA-3021: Centralize dependency version management [junrao] KAFKA-3085; BrokerChangeListener computes inconsistent live/dead broker -- Started by an SCM change [EnvInject] -

[jira] [Commented] (KAFKA-3085) BrokerChangeListener computes inconsistent live/dead broker list

[ https://issues.apache.org/jira/browse/KAFKA-3085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15092923#comment-15092923 ] Jun Rao commented on KAFKA-3085: [~dajac], sorry, I overlooked this when reviewing the pat

Build failed in Jenkins: kafka-trunk-jdk7 #954

See Changes: [junrao] KAFKA-3085; BrokerChangeListener computes inconsistent live/dead broker -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H1

[jira] [Assigned] (KAFKA-2998) New Consumer should not retry indefinitely if no broker is available

[ https://issues.apache.org/jira/browse/KAFKA-2998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-2998: -- Assignee: Jason Gustafson > New Consumer should not retry indefinitely if no broker is

[jira] [Commented] (KAFKA-2998) New Consumer should not retry indefinitely if no broker is available

[ https://issues.apache.org/jira/browse/KAFKA-2998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15093078#comment-15093078 ] Jason Gustafson commented on KAFKA-2998: [~ijuma] Maybe we can treat this as a sep

Re: ClassLoading in OSGi environment

This makes sense, could you file a JIRA to keep track of this? Guozhang On Mon, Jan 11, 2016 at 8:17 AM, Rajini Sivaram < rajinisiva...@googlemail.com> wrote: > There are multiple places in Kafka where the context class loader or > Class.forName() is used to load classes. Perhaps it would be bet

[jira] [Commented] (KAFKA-2998) New Consumer should not retry indefinitely if no broker is available

[ https://issues.apache.org/jira/browse/KAFKA-2998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15093118#comment-15093118 ] Ismael Juma commented on KAFKA-2998: Sounds like a good plan. > New Consumer should n

[jira] [Updated] (KAFKA-2478) KafkaConsumer javadoc example seems wrong

[ https://issues.apache.org/jira/browse/KAFKA-2478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2478: - Assignee: Dmitry Stratiychuk (was: Neha Narkhede) > KafkaConsumer javadoc example seems wrong > -

[GitHub] kafka pull request: Minor - remove unused TimeUnit from MetricConf...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/600 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

Build failed in Jenkins: kafka-trunk-jdk7 #955

See Changes: [wangguoz] MINOR: remove unused TimeUnit from MetricConfig -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-4 (docker Ubuntu

Build failed in Jenkins: kafka-trunk-jdk8 #282

See Changes: [wangguoz] MINOR: remove unused TimeUnit from MetricConfig -- [...truncated 1452 lines...] kafka.KafkaTest > testGetKafkaConfigFromArgsNonArgsOnly PASSED kafka.KafkaTest > testGetK

[jira] [Commented] (KAFKA-3085) BrokerChangeListener computes inconsistent live/dead broker list

[ https://issues.apache.org/jira/browse/KAFKA-3085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15093334#comment-15093334 ] David Jacot commented on KAFKA-3085: [~junrao] No worries. I'll update it accordingly.

[jira] [Updated] (KAFKA-3085) BrokerChangeListener computes inconsistent live/dead broker list

[ https://issues.apache.org/jira/browse/KAFKA-3085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot updated KAFKA-3085: --- Status: In Progress (was: Patch Available) > BrokerChangeListener computes inconsistent live/dead bro

Re: [VOTE] KIP-32 Add CreateTime and LogAppendTime to Kafka message.

That makes sense to me, too. I will update the KIP to reflect this. Thanks, Anna. > On Jan 9, 2016, at 9:37 AM, Neha Narkhede wrote: > > Anna - Good suggestion. Sounds good to me as well > > On Fri, Jan 8, 2016 at 2:32 PM, Aditya Auradkar < > aaurad...@linkedin.com.invalid> wrote: > >> Anna,

[jira] [Commented] (KAFKA-3085) BrokerChangeListener computes inconsistent live/dead broker list

[ https://issues.apache.org/jira/browse/KAFKA-3085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15093411#comment-15093411 ] ASF GitHub Bot commented on KAFKA-3085: --- GitHub user dajac opened a pull request:

[GitHub] kafka pull request: KAFKA-3085: BrokerChangeListener computes inco...

GitHub user dajac opened a pull request: https://github.com/apache/kafka/pull/756 KAFKA-3085: BrokerChangeListener computes inconsistent live/dead broker list. Follow up PR as per comments in the ticket. @junrao It should be correct now as `curBrokers` included only live br

[jira] [Updated] (KAFKA-3085) BrokerChangeListener computes inconsistent live/dead broker list

[ https://issues.apache.org/jira/browse/KAFKA-3085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot updated KAFKA-3085: --- Status: Patch Available (was: In Progress) > BrokerChangeListener computes inconsistent live/dead bro

[jira] [Resolved] (KAFKA-3077) Enable KafkaLog4jAppender to work with SASL enabled brokers.

[ https://issues.apache.org/jira/browse/KAFKA-3077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-3077. -- Resolution: Fixed Fix Version/s: 0.9.1.0 Issue resolved by pull request 7

[GitHub] kafka pull request: KAFKA-3077: Enable KafkaLog4jAppender to work ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/740 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[jira] [Commented] (KAFKA-3077) Enable KafkaLog4jAppender to work with SASL enabled brokers.

[ https://issues.apache.org/jira/browse/KAFKA-3077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15093453#comment-15093453 ] ASF GitHub Bot commented on KAFKA-3077: --- Github user asfgit closed the pull request

[GitHub] kafka pull request: Kafka 3078

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/747 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[jira] [Resolved] (KAFKA-3078) Add ducktape tests for KafkaLog4jAppender producing to SASL enabled Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-3078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-3078. -- Resolution: Fixed Fix Version/s: 0.9.1.0 Issue resolved by pull request 7

[jira] [Commented] (KAFKA-3077) Enable KafkaLog4jAppender to work with SASL enabled brokers.

[ https://issues.apache.org/jira/browse/KAFKA-3077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15093458#comment-15093458 ] ASF GitHub Bot commented on KAFKA-3077: --- Github user asfgit closed the pull request

Build failed in Jenkins: kafka-trunk-jdk7 #956

See Changes: [me] KAFKA-3077: Enable KafkaLog4jAppender to work with SASL enabled brokers [me] KAFKA-3078: Add ducktape tests for KafkaLog4jAppender producing to SASL -- Started by an SCM change