[jira] [Commented] (KAFKA-2869) host used by Authorizer should be IP address not hostname/IP

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

[jira] [Updated] (KAFKA-2869) host used by Authorizer should be IP address not hostname/IP

[ https://issues.apache.org/jira/browse/KAFKA-2869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2869: --- Status: Patch Available (was: In Progress) > host used by Authorizer should be IP address not

[GitHub] kafka pull request: KAFKA-2869; Host used by Authorizer should be ...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/567 KAFKA-2869; Host used by Authorizer should be IP address not hostname/IP You can merge this pull request into a Git repository by running: $ git pull https://github.com/ijuma/kafka

[jira] [Commented] (KAFKA-2687) Add support for ListGroups and DescribeGroup APIs

[ https://issues.apache.org/jira/browse/KAFKA-2687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15018132#comment-15018132 ] Ismael Juma commented on KAFKA-2687: [~sslavic], would you like to submit a PR? If not, that's OK,

[jira] [Created] (KAFKA-2868) retry.backoff.ms ignored by Producer

Nicolas Bordier created KAFKA-2868: -- Summary: retry.backoff.ms ignored by Producer Key: KAFKA-2868 URL: https://issues.apache.org/jira/browse/KAFKA-2868 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-2687) Add support for ListGroups and DescribeGroup APIs

[ https://issues.apache.org/jira/browse/KAFKA-2687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15018125#comment-15018125 ] Stevo Slavic commented on KAFKA-2687: - It seems ConsumerMetadataRequest/ConsumerMetadataResponse got

[jira] [Created] (KAFKA-2869) host used by Authorizer should be IP address not hostname/IP

Ismael Juma created KAFKA-2869: -- Summary: host used by Authorizer should be IP address not hostname/IP Key: KAFKA-2869 URL: https://issues.apache.org/jira/browse/KAFKA-2869 Project: Kafka

[jira] [Work started] (KAFKA-2869) host used by Authorizer should be IP address not hostname/IP

[ https://issues.apache.org/jira/browse/KAFKA-2869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2869 started by Ismael Juma. -- > host used by Authorizer should be IP address not hostname/IP >

[jira] [Commented] (KAFKA-2863) Authorizer should provide lifecycle (shutdown) methods

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

[jira] [Assigned] (KAFKA-2863) Authorizer should provide lifecycle (shutdown) methods

[ https://issues.apache.org/jira/browse/KAFKA-2863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-2863: -- Assignee: Ismael Juma (was: Parth Brahmbhatt) > Authorizer should provide lifecycle

[jira] [Commented] (KAFKA-2687) Add support for ListGroups and DescribeGroup APIs

[ https://issues.apache.org/jira/browse/KAFKA-2687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15018157#comment-15018157 ] Stevo Slavic commented on KAFKA-2687: - So much changed, still trying to grasp it, would delay PR too

[GitHub] kafka pull request: KAFKA-2863; Add a `close()` method to `Authori...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/568 KAFKA-2863; Add a `close()` method to `Authorizer` You can merge this pull request into a Git repository by running: $ git pull https://github.com/ijuma/kafka kafka-2863-authorizer-close

[jira] [Created] (KAFKA-2870) Support configuring operationRetryTimeout of underlying ZkClient through ZkUtils constructor

Stevo Slavic created KAFKA-2870: --- Summary: Support configuring operationRetryTimeout of underlying ZkClient through ZkUtils constructor Key: KAFKA-2870 URL: https://issues.apache.org/jira/browse/KAFKA-2870

[jira] [Commented] (KAFKA-2869) host used by Authorizer should be IP address not hostname/IP

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

[jira] [Updated] (KAFKA-2869) host used by Authorizer should be IP address not hostname/IP

[ https://issues.apache.org/jira/browse/KAFKA-2869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2869: --- Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request 567

[jira] [Updated] (KAFKA-2863) Authorizer should provide lifecycle (shutdown) methods

[ https://issues.apache.org/jira/browse/KAFKA-2863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2863: --- Reviewer: Jun Rao Status: Patch Available (was: Open) [~parth.brahmbhatt], I hope you don't

Potential KafkaStreaming Bug

Hi All, I'm starting to experiment with the lower-level Processor Client API found on the KIP-28 wiki. When starting the KafkaStream I get the following Exception: Exception in thread "main" java.util.NoSuchElementException: id: SINK at

[GitHub] kafka pull request: KAFKA-2869; Host used by Authorizer should be ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/567 --- 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

[jira] [Commented] (KAFKA-2867) Missing synchronization and improperly handled InterruptException in WorkerSourceTask

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

[GitHub] kafka pull request: KAFKA-2867: Fix missing WorkerSourceTask synch...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/566 --- 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

[jira] [Updated] (KAFKA-2867) Missing synchronization and improperly handled InterruptException in WorkerSourceTask

[ https://issues.apache.org/jira/browse/KAFKA-2867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2867: --- Resolution: Fixed Fix Version/s: (was: 0.9.1.0) Status: Resolved (was: Patch Available)

Build failed in Jenkins: kafka_0.9.0_jdk7 #35

See Changes: [junrao] KAFKA-2860: better handling of auto commit errors [junrao] KAFKA-2869; Host used by Authorizer should be IP address not hostname/IP -- [...truncated 773 lines...]

Jenkins build is back to normal : kafka-trunk-jdk7 #842

See

[jira] [Updated] (KAFKA-2863) Authorizer should provide lifecycle (shutdown) methods

[ https://issues.apache.org/jira/browse/KAFKA-2863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2863: --- Fix Version/s: (was: 0.9.0.1) 0.9.0.0 > Authorizer should provide lifecycle

[GitHub] kafka pull request: KAFKA-2863; Add a `close()` method to `Authori...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/568 --- 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

[jira] [Commented] (KAFKA-2863) Authorizer should provide lifecycle (shutdown) methods

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

[jira] [Updated] (KAFKA-2863) Authorizer should provide lifecycle (shutdown) methods

[ https://issues.apache.org/jira/browse/KAFKA-2863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2863: --- Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request 568

[GitHub] kafka pull request: MINOR: Log at INFO level in Benchmark tests

GitHub user granders opened a pull request: https://github.com/apache/kafka/pull/569 MINOR: Log at INFO level in Benchmark tests You can merge this pull request into a Git repository by running: $ git pull https://github.com/confluentinc/kafka minor-reduce-benchmark-logs

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

See Changes: [junrao] KAFKA-2869; Host used by Authorizer should be IP address not hostname/IP [junrao] KAFKA-2867: Fix missing WorkerSourceTask synchronization and handling of --

[jira] [Created] (KAFKA-2871) Newly replicated brokers don't expire log segments properly

Evan Huus created KAFKA-2871: Summary: Newly replicated brokers don't expire log segments properly Key: KAFKA-2871 URL: https://issues.apache.org/jira/browse/KAFKA-2871 Project: Kafka Issue

Jenkins build is back to normal : kafka_0.9.0_jdk7 #36

See

[GitHub] kafka pull request: MINOR: Log at INFO level in Benchmark tests

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/569 --- 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

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

See Changes: [junrao] KAFKA-2863; Add a `close()` method to `Authorizer` [cshapi] MINOR: Log at INFO level in Benchmark tests -- [...truncated 3312 lines...]

[GitHub] kafka pull request: KAFKA-2825, KAFKA-2851: Extended existing duck...

Github user apovzner closed the pull request at: https://github.com/apache/kafka/pull/518 --- 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

[jira] [Commented] (KAFKA-2825) Add controller failover to existing replication tests

[ https://issues.apache.org/jira/browse/KAFKA-2825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15018892#comment-15018892 ] ASF GitHub Bot commented on KAFKA-2825: --- Github user apovzner closed the pull request at:

[jira] [Commented] (KAFKA-2825) Add controller failover to existing replication tests

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

[jira] [Commented] (KAFKA-2687) Add support for ListGroups and DescribeGroup APIs

[ https://issues.apache.org/jira/browse/KAFKA-2687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15018863#comment-15018863 ] Jun Rao commented on KAFKA-2687: [~sslavic], thanks for reporting the typo. I fixed that in the 0.9.0

[GitHub] kafka pull request: KAFKA-2825, KAFKA-2852: Controller failover te...

GitHub user apovzner opened a pull request: https://github.com/apache/kafka/pull/570 KAFKA-2825, KAFKA-2852: Controller failover tests added to ducktape replication tests and fix to temp dir I closed an original pull request that contained previous comments by Geoff (which are

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

See Changes: [junrao] trivial change to 0.9.0 docs to fix outdated ConsumerMetadataRequest [junrao] trivial change to 0.9.0 docs to fix incorrect ssl.key.password -- [...truncated 2796

[jira] [Resolved] (KAFKA-2812) Enhance new consumer integration test coverage

[ https://issues.apache.org/jira/browse/KAFKA-2812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-2812. -- Resolution: Fixed > Enhance new consumer integration test coverage >

Build failed in Jenkins: kafka_0.9.0_jdk7 #39

See Changes: [guozhang] KAFKA-2718: Avoid reusing temporary directories in core unit tests [guozhang] KAFKA-2812: improve consumer integration tests [junrao] trivial change: revert incorrect change to ssl.key.password

Re: [VOTE] 0.9.0.0 Candiate 3

KAFKA-2859 is now fixed. Will roll out RC4. Thanks, Jun On Thu, Nov 19, 2015 at 12:52 PM, Ewen Cheslack-Postava wrote: > FYI, I found a blocker for Kafka Connect > https://issues.apache.org/jira/browse/KAFKA-2859. The fix is already in, > but we'll need to do one more round

Build failed in Jenkins: kafka_0.9.0_jdk7 #38

See Changes: [junrao] trivial change to 0.9.0 docs to fix incorrect ssl.key.password -- [...truncated 231 lines...] :core:jar UP-TO-DATE :examples:compileJava :examples:processResources

[GitHub] kafka pull request: KAFKA-2718: Avoid reusing temporary directorie...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/399 --- 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

[jira] [Commented] (KAFKA-2718) Reuse of temporary directories leading to transient unit test failures

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

[jira] [Resolved] (KAFKA-2853) Reuse of temporary server data.dir could lead to transient failures.

[ https://issues.apache.org/jira/browse/KAFKA-2853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-2853. -- Resolution: Duplicate > Reuse of temporary server data.dir could lead to transient failures. >

[jira] [Updated] (KAFKA-2718) Reuse of temporary directories leading to transient unit test failures

[ https://issues.apache.org/jira/browse/KAFKA-2718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2718: - Resolution: Fixed Fix Version/s: 0.9.0.0 Status: Resolved (was: Patch

[GitHub] kafka pull request: KAFKA-2812: improve consumer integration tests

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/500 --- 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

[jira] [Commented] (KAFKA-2812) Enhance new consumer integration test coverage

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

[GitHub] kafka pull request: KAFKA-2862: Fix MirrorMaker's message.handler....

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/561 --- 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

[jira] [Commented] (KAFKA-2862) Incorrect help description for MirrorMaker's message.handler.args

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

[jira] [Resolved] (KAFKA-2862) Incorrect help description for MirrorMaker's message.handler.args

[ https://issues.apache.org/jira/browse/KAFKA-2862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-2862. -- Resolution: Fixed Fix Version/s: 0.9.1.0 Issue resolved by pull request 561

Re: Potential KafkaStreaming Bug

Bill, Thanks for point it out! I think this is a real bug. Do you want to file PR in github with the fix? You can find the instructions here: https://cwiki.apache.org/confluence/display/KAFKA/Contributing+Code+Changes Guozhang On Fri, Nov 20, 2015 at 8:32 AM, Bill Bejeck

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

See Changes: [guozhang] KAFKA-2718: Avoid reusing temporary directories in core unit tests [guozhang] KAFKA-2812: improve consumer integration tests [guozhang] KAFKA-2862: Fix MirrorMaker's message.handler.args description

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

See Changes: [junrao] trivial change: revert incorrect change to ssl.key.password -- [...truncated 89 lines...] ^

0.9.0.0 RC4

This is the fourth candidate for release of Apache Kafka 0.9.0.0. This a major release that includes (1) authentication (through SSL and SASL) and authorization, (2) a new java consumer, (3) a Kafka connect framework for data ingestion and egression, and (4) quotas. Since this is a major release,

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

See Changes: [guozhang] KAFKA-2718: Avoid reusing temporary directories in core unit tests [guozhang] KAFKA-2812: improve consumer integration tests [guozhang] KAFKA-2862: Fix MirrorMaker's message.handler.args description

Re: Potential KafkaStreaming Bug

Ok great. I'll get it too it this weekend. Thanks, Bill On Fri, Nov 20, 2015 at 8:04 PM, Guozhang Wang wrote: > Bill, > > Thanks for point it out! I think this is a real bug. Do you want to file PR > in github with the fix? You can find the instructions here: > >

[jira] [Created] (KAFKA-2872) Error starting KafkaStream caused by sink not being connected to parent source/processor nodes

Bill Bejeck created KAFKA-2872: -- Summary: Error starting KafkaStream caused by sink not being connected to parent source/processor nodes Key: KAFKA-2872 URL: https://issues.apache.org/jira/browse/KAFKA-2872

Jenkins build is back to normal : kafka-trunk-jdk7 #847

See

[jira] [Work started] (KAFKA-2872) Error starting KafkaStream caused by sink not being connected to parent source/processor nodes

[ https://issues.apache.org/jira/browse/KAFKA-2872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2872 started by Bill Bejeck. -- > Error starting KafkaStream caused by sink not being connected to parent >

[GitHub] kafka pull request: KAFKA-2361: unit test failure in ProducerFailu...

GitHub user ZoneMayor opened a pull request: https://github.com/apache/kafka/pull/571 KAFKA-2361: unit test failure in ProducerFailureHandlingTest.testNotE… same issue with KAFKA-1999, so I want to fix it https://issues.apache.org/jira/browse/KAFKA-1999 You can merge this

[jira] [Commented] (KAFKA-2361) Unit Test BUILD FAILED

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

[GitHub] kafka pull request: KAFKA-2361: unit test failure in ProducerFailu...

Github user ZoneMayor closed the pull request at: https://github.com/apache/kafka/pull/558 --- 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

[jira] [Commented] (KAFKA-2361) Unit Test BUILD FAILED

[ https://issues.apache.org/jira/browse/KAFKA-2361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15020299#comment-15020299 ] ASF GitHub Bot commented on KAFKA-2361: --- Github user ZoneMayor closed the pull request at: