[GitHub] kafka-site pull request: Add Ismael to committers page

GitHub user ijuma opened a pull request: https://github.com/apache/kafka-site/pull/11 Add Ismael to committers page You can merge this pull request into a Git repository by running: $ git pull https://github.com/ijuma/kafka-site add-ismael-to-committers-page Alternatively you

[jira] [Updated] (KAFKA-3294) Kafka REST API

[ https://issues.apache.org/jira/browse/KAFKA-3294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-3294: -- Assignee: Parth Brahmbhatt (was: Sriharsha Chintalapani) > Kafka REST API > ---

Re: [ANNOUNCE] New committer: Ismael Juma

Congrats Ismael! On 04/26/2016 07:52 AM, Neha Narkhede wrote: > The PMC for Apache Kafka has invited Ismael Juma to join as a committer and > we are pleased to announce that he has accepted! > > Ismael has contributed 121 commits > to a wide r

Re: [ANNOUNCE] New committer: Ismael Juma

Thank you Neha and the PMC for the opportunity. I am both grateful and excited. :) And thanks to everyone else in the Kafka community too. Ismael On Mon, Apr 25, 2016 at 10:52 PM, Neha Narkhede wrote: > The PMC for Apache Kafka has invited Ismael Juma to join as a committer and > we are please

[GitHub] kafka-site pull request: Add Ismael to committers page

Github user Ishiihara commented on the pull request: https://github.com/apache/kafka-site/pull/11#issuecomment-214653285 LGTM --- 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 enab

Re: [ANNOUNCE] New committer: Ismael Juma

Congrats Ismael On Tue, Apr 26, 2016 at 12:58 PM, Ismael Juma wrote: > Thank you Neha and the PMC for the opportunity. I am both grateful and > excited. :) > > And thanks to everyone else in the Kafka community too. > > Ismael > > On Mon, Apr 25, 2016 at 10:52 PM, Neha Narkhede wrote: > > > The

[GroupCoordinatorNotAvailableException] consumer error on poll request

Hello, I am using KafkaProducer and KafkaConsumer, version 0.90, in java, the producer works good (the Console Consumer provided in samples receives the producer data). But in the configured KafkaConsumer I got the /org.apache.kafka.common.errors.GroupCoordinatorNotAvailableException/**error

[jira] [Commented] (KAFKA-493) High CPU usage on inactive server

[ https://issues.apache.org/jira/browse/KAFKA-493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15257799#comment-15257799 ] jaikiran pai commented on KAFKA-493: FWIW - we have been seeing a similar issue in 0.8

[GroupCoordinatorNotAvailableException] consumer error on poll request

Hello, I am using KafkaProducer and KafkaConsumer, version 0.90, in java, the producer works good (the Console Consumer provided in samples receives the producer data). But in the configured KafkaConsumer I got the /org.apache.kafka.common.errors.GroupCoordinatorNotAvailableException/**error T

[jira] [Created] (KAFKA-3622) Kafka throws undescriptive error message if port is missing from url

Peter Ableda created KAFKA-3622: --- Summary: Kafka throws undescriptive error message if port is missing from url Key: KAFKA-3622 URL: https://issues.apache.org/jira/browse/KAFKA-3622 Project: Kafka

[GitHub] kafka pull request: KAFKA-3622: Use descriptive error message if p...

GitHub user peterableda opened a pull request: https://github.com/apache/kafka/pull/1269 KAFKA-3622: Use descriptive error message if port number is missing from url A new exception is thrown in *parseAndValidateAddresses* method when the port number is missing from the url.

[jira] [Commented] (KAFKA-3622) Kafka throws undescriptive error message if port is missing from url

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

GroupCoordinatorNotAvailableException, consumer error on poll request

Hello, I am using KafkaProducer and KafkaConsumer, version 0.90, in java, the producer works good (the Console Consumer provided in samples receives the producer data). But in the configured KafkaConsumer I got the /org.apache.kafka.common.errors.GroupCoordinatorNotAvailableException/**error T

[GitHub] kafka pull request: Kafka 3270 Added some Happy Path Tests for the...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/956 --- 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-3270) Add Basic Integration Tests Around ReassignPartitionsCommand

[ https://issues.apache.org/jira/browse/KAFKA-3270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-3270. Resolution: Fixed Fix Version/s: 0.10.0.0 Issue resolved by pull request 956 [https://github.

[GitHub] kafka pull request: KAFKA-3602: rename RecordAccumulator dequeFor(...

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

[jira] [Commented] (KAFKA-3602) Rename RecordAccumulator dequeFor() and ensure proper usage

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

[jira] [Updated] (KAFKA-3602) Rename RecordAccumulator dequeFor() and ensure proper usage

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

[GitHub] kafka pull request: MINOR: Fix some copy-pasted Javadoc in Streams...

GitHub user jklukas opened a pull request: https://github.com/apache/kafka/pull/1270 MINOR: Fix some copy-pasted Javadoc in StreamsConfig.java This contribution is my original work and I license the work to the Kafka project under the project's open source license. cc @guoz

Re: [ANNOUNCE] New committer: Ismael Juma

Congratulations, very well deserved. On Apr 25, 2016 10:53 PM, "Neha Narkhede" wrote: > The PMC for Apache Kafka has invited Ismael Juma to join as a committer and > we are pleased to announce that he has accepted! > > Ismael has contributed 121 commits >

[GitHub] kafka-site pull request: Add Ismael to committers page

Github user guozhangwang commented on the pull request: https://github.com/apache/kafka-site/pull/11#issuecomment-214754966 LGTM! --- 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

[GitHub] kafka-site pull request: Add Ismael to committers page

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

Re: [ANNOUNCE] New committer: Ismael Juma

Congratulations! On Tue, Apr 26, 2016 at 6:57 AM, Gwen Shapira wrote: > Congratulations, very well deserved. > On Apr 25, 2016 10:53 PM, "Neha Narkhede" wrote: > > > The PMC for Apache Kafka has invited Ismael Juma to join as a committer > and > > we are pleased to announce that he has accepted

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

See Changes: [ismael] KAFKA-3270; Added some Happy Path Tests for the Reassign Partitions [ismael] KAFKA-3602; Rename RecordAccumulator dequeFor() and fix usage -- [...truncated 484 lines...] ka

[jira] [Created] (KAFKA-3623) Make KStreamTestDriver extending from ExternalResource

Guozhang Wang created KAFKA-3623: Summary: Make KStreamTestDriver extending from ExternalResource Key: KAFKA-3623 URL: https://issues.apache.org/jira/browse/KAFKA-3623 Project: Kafka Issue Ty

[GitHub] kafka pull request: KAFKA-3499: prevent array typed keys in KeyVal...

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

[jira] [Resolved] (KAFKA-3499) byte[] should not be used as Map key nor Set member

[ https://issues.apache.org/jira/browse/KAFKA-3499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3499. -- Resolution: Fixed Issue resolved by pull request 1229 [https://github.com/apache/kafka/pull/1229

[jira] [Commented] (KAFKA-3499) byte[] should not be used as Map key nor Set member

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

[jira] [Updated] (KAFKA-3624) NullPointerException Thrown for MetadataRequest when Cluster Not Available

[ https://issues.apache.org/jira/browse/KAFKA-3624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Tylwalk updated KAFKA-3624: Description: Have been seeing consistently a NPE when metadata request is sent against a cluster th

[jira] [Created] (KAFKA-3624) NullPointerException Thrown for MetadataRequest when Cluster Not Available

John Tylwalk created KAFKA-3624: --- Summary: NullPointerException Thrown for MetadataRequest when Cluster Not Available Key: KAFKA-3624 URL: https://issues.apache.org/jira/browse/KAFKA-3624 Project: Kafka

[jira] [Updated] (KAFKA-3624) NullPointerException Thrown for MetadataRequest when Cluster Not Available

[ https://issues.apache.org/jira/browse/KAFKA-3624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Tylwalk updated KAFKA-3624: Description: Have been seeing consistently a NPE when metadata request is sent against a cluster th

Re: [ANNOUNCE] New committer: Ismael Juma

Congrats Ismael, very well deserved!! On Tue, Apr 26, 2016 at 7:16 AM -0700, "Sriram Subramanian" wrote: Congratulations! On Tue, Apr 26, 2016 at 6:57 AM, Gwen Shapira wrote: > Congratulations, very well deserved. > On Apr 25, 2016 10:53 PM, "Neha Narkhede" wrote: > > > The PMC for

Re: [ANNOUNCE] New committer: Ismael Juma

Congratulations, Ismael! Jun On Mon, Apr 25, 2016 at 10:52 PM, Neha Narkhede wrote: > The PMC for Apache Kafka has invited Ismael Juma to join as a committer and > we are pleased to announce that he has accepted! > > Ismael has contributed 121 commits >

Re: No Heartbeat request on commit

Hi Ismael, Treating commitSync as heartbeat will definitely resolve the issue i am facing but the reason behind my issue does not seem to be what mentioned in defect (i.e frequent commitSync requests). I am sending CommitSync periodically only to keep my session alive when my consumer is still pr

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

See

Re: [ANNOUNCE] New committer: Ismael Juma

Congrats, Ismael -Harsha On Tue, Apr 26, 2016, at 08:01 AM, Jun Rao wrote: > Congratulations, Ismael! > > Jun > > On Mon, Apr 25, 2016 at 10:52 PM, Neha Narkhede > wrote: > > > The PMC for Apache Kafka has invited Ismael Juma to join as a committer and > > we are pleased to announce that he h

Re: [ANNOUNCE] New committer: Ismael Juma

Congratulations Ismael! On Apr 26, 2016 8:55 AM, "Harsha" wrote: > Congrats, Ismael > > -Harsha > > On Tue, Apr 26, 2016, at 08:01 AM, Jun Rao wrote: > > Congratulations, Ismael! > > > > Jun > > > > On Mon, Apr 25, 2016 at 10:52 PM, Neha Narkhede > > wrote: > > > > > The PMC for Apache Kafka has

[jira] [Created] (KAFKA-3625) Move kafka-streams test fixtures into a published package

Jeff Klukas created KAFKA-3625: -- Summary: Move kafka-streams test fixtures into a published package Key: KAFKA-3625 URL: https://issues.apache.org/jira/browse/KAFKA-3625 Project: Kafka Issue Typ

[jira] [Commented] (KAFKA-3625) Move kafka-streams test fixtures into a published package

[ https://issues.apache.org/jira/browse/KAFKA-3625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258338#comment-15258338 ] Jeff Klukas commented on KAFKA-3625: I would be willing to submit this patch if folks

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

See Changes: [wangguoz] KAFKA-3499: prevent array typed keys in KeyValueStore -- [...truncated 1602 lines...] kafka.server.LogOffsetTest > testGetOffsetsForUnknownTopic PASSED kafka.server.Log

Re: [DISCUSS] KIP-48 Support for delegation tokens as an authentication mechanism

Parth, Overall current design looks good to me. I am +1 on the KIP. Gwen , Jun can you review this as well. -Harsha On Tue, Apr 19, 2016, at 09:57 AM, parth brahmbhatt wrote: > Thanks for review Jitendra. > > I don't like the idea of infinite lifetime but I see the Streaming use > cas

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

See Changes: [wangguoz] KAFKA-3499: prevent array typed keys in KeyValueStore -- [...truncated 5401 lines...] kafka.log.BrokerCompressionTest > testBrokerSideCompression[3] PASSED kafka.log.Bro

[GitHub] kafka pull request: MINOR: Fix some copy-pasted Javadoc in Streams...

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

[jira] [Commented] (KAFKA-3294) Kafka REST API

[ https://issues.apache.org/jira/browse/KAFKA-3294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258438#comment-15258438 ] Mayuresh Gharat commented on KAFKA-3294: Are you thinking of exposing a rest endpo

[GitHub] kafka pull request: KAFKA-3614: Consolidate duplicate code in KGro...

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

[jira] [Commented] (KAFKA-3614) Consolidate duplicate code in KGroupedTableImpl

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

[jira] [Resolved] (KAFKA-3614) Consolidate duplicate code in KGroupedTableImpl

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

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

See Changes: [wangguoz] KAFKA-3614: Consolidate duplicate code in KGroupedTableImpl -- [...truncated 652 lines...] kafka.log.LogTest > testCompressedMessages PASSED kafka.log.LogTest > testAppen

[jira] [Commented] (KAFKA-3294) Kafka REST API

[ https://issues.apache.org/jira/browse/KAFKA-3294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258503#comment-15258503 ] Sriharsha Chintalapani commented on KAFKA-3294: --- [~mgharat] we are actually

[jira] [Updated] (KAFKA-3599) Move WindowStoreUtils to package "internals"

[ https://issues.apache.org/jira/browse/KAFKA-3599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3599: - Resolution: Fixed Status: Resolved (was: Patch Available) > Move WindowStoreUtils to pack

[jira] [Updated] (KAFKA-3599) Move WindowStoreUtils to package "internals"

[ https://issues.apache.org/jira/browse/KAFKA-3599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3599: - Fix Version/s: 0.10.0.0 > Move WindowStoreUtils to package "internals" > -

[GitHub] kafka pull request: KAKFA-3599: Move WindowStoreUtils to package "...

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

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

See Changes: [wangguoz] MINOR: Fix some copy-pasted Javadoc in StreamsConfig.java -- [...truncated 1600 lines...] kafka.log.OffsetIndexTest > appendTooMany PASSED kafka.log.OffsetIndexTest > r

[GitHub] kafka pull request: MINOR: Typo fixes in ReplicaFetchMaxBytesDoc

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

Re: [ANNOUNCE] New committer: Ismael Juma

Great work, Ismael! On Tue, Apr 26, 2016 at 9:00 AM, Grant Henke wrote: > Congratulations Ismael! > On Apr 26, 2016 8:55 AM, "Harsha" wrote: > > > Congrats, Ismael > > > > -Harsha > > > > On Tue, Apr 26, 2016, at 08:01 AM, Jun Rao wrote: > > > Congratulations, Ismael! > > > > > > Jun > > > > >

Re: No Heartbeat request on commit

Hey Vinay, Are you saying that heartbeats are not sent while a metadata refresh is in progress? Do you have any logs which show us the apparent problem? Thanks, Jason On Tue, Apr 26, 2016 at 8:18 AM, vinay sharma wrote: > Hi Ismael, > > Treating commitSync as heartbeat will definitely resolve

[GitHub] kafka pull request: KAFKA-3607: Close KStreamTestDriver upon compl...

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

[jira] [Resolved] (KAFKA-3607) Close state stores explicitly in unit tests upon completing

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

[jira] [Commented] (KAFKA-3607) Close state stores explicitly in unit tests upon completing

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

[jira] [Created] (KAFKA-3626) Transient failure in testGetAllTopicMetadata

Jason Gustafson created KAFKA-3626: -- Summary: Transient failure in testGetAllTopicMetadata Key: KAFKA-3626 URL: https://issues.apache.org/jira/browse/KAFKA-3626 Project: Kafka Issue Type: Su

[GitHub] kafka pull request: MINOR: Fix zk path in KafkaHealthCheck comment

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

Re: GroupCoordinatorNotAvailableException, consumer error on poll request

Hi Jose, Can you provide the full exception stack trace? Which method is this being throw from? It might help to see the snippet which is producing it as well. Thanks, Jason On Tue, Apr 26, 2016 at 5:19 AM, Jose Raul Perez Rodriguez < joseraul.w...@gmail.com> wrote: > Hello, > > I am using Kafk

[jira] [Assigned] (KAFKA-3626) Transient failure in testGetAllTopicMetadata

[ https://issues.apache.org/jira/browse/KAFKA-3626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3626: - Assignee: Liquan Pei > Transient failure in testGetAllTopicMetadata > ---

[GitHub] kafka pull request: Changed port of bootstrap server to default.

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

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

See

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

See Changes: [wangguoz] KAKFA-3599: Move WindowStoreUtils to package "internals" -- [...truncated 5404 lines...] kafka.log.BrokerCompressionTest > testBrokerSideCompression[3] PASSED kafka.log.

[GitHub] kafka pull request: KAFKA-3006: Make collection default container ...

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

[jira] [Commented] (KAFKA-3006) Make collection default container type for sequences in the consumer API

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

Re: GroupCoordinatorNotAvailableException, consumer error on poll request

That is the problem, I can't see the stack trace, the KafkaConsumer don't throw any Exception, it simply stay in *poll() *method and never return. I realized the internal error was GroupCoordinatorNotAvailableException by using Kafka from source code and tracing the method calls, I saw that

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

See

[jira] [Commented] (KAFKA-3294) Kafka REST API

[ https://issues.apache.org/jira/browse/KAFKA-3294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258849#comment-15258849 ] Chien Le commented on KAFKA-3294: - Might want to look into http://docs.confluent.io/2.0.1/

[jira] [Commented] (KAFKA-3294) Kafka REST API

[ https://issues.apache.org/jira/browse/KAFKA-3294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258891#comment-15258891 ] Mayuresh Gharat commented on KAFKA-3294: [~sriharsha.sm] so this will be integrate

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

See Changes: [ismael] MINOR: Typo fixes in ReplicaFetchMaxBytesDoc [wangguoz] KAFKA-3607: Close KStreamTestDriver upon completing; follow-up fixes to [ismael] MINOR: Fix zk path in KafkaHealthCheck comment [ismael] MINOR: Changed p

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

See

Re: GroupCoordinatorNotAvailableException, consumer error on poll request

Hey Jose, That error could indicate that one of the partitions of the __consumer_offsets topic has no leader. The group coordinators are chosen from the leaders of those partitions, so if one is unavailable, then the consumer won't be able to find the group. Can you show the output of the followin

[jira] [Created] (KAFKA-3627) New consumer doesn't run delayed tasks while under load

Rob Underwood created KAFKA-3627: Summary: New consumer doesn't run delayed tasks while under load Key: KAFKA-3627 URL: https://issues.apache.org/jira/browse/KAFKA-3627 Project: Kafka Issue T

[jira] [Assigned] (KAFKA-3627) New consumer doesn't run delayed tasks while under load

[ https://issues.apache.org/jira/browse/KAFKA-3627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3627: - Assignee: Liquan Pei (was: Neha Narkhede) > New consumer doesn't run delayed tasks while under l

[jira] [Commented] (KAFKA-3624) NullPointerException Thrown for MetadataRequest when Cluster Not Available

[ https://issues.apache.org/jira/browse/KAFKA-3624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258949#comment-15258949 ] Jason Gustafson commented on KAFKA-3624: [~johnt] Unless I'm mistaken, it seems mo

[jira] [Commented] (KAFKA-3624) NullPointerException Thrown for MetadataRequest when Cluster Not Available

[ https://issues.apache.org/jira/browse/KAFKA-3624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258952#comment-15258952 ] John Tylwalk commented on KAFKA-3624: - Yep looks like the same issue, closing this out

[jira] [Resolved] (KAFKA-3624) NullPointerException Thrown for MetadataRequest when Cluster Not Available

[ https://issues.apache.org/jira/browse/KAFKA-3624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Tylwalk resolved KAFKA-3624. - Resolution: Duplicate > NullPointerException Thrown for MetadataRequest when Cluster Not Available

[jira] [Updated] (KAFKA-3627) New consumer doesn't run delayed tasks while under load

[ https://issues.apache.org/jira/browse/KAFKA-3627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rob Underwood updated KAFKA-3627: - Attachment: DelayedTaskBugConsumer.java > New consumer doesn't run delayed tasks while under load

[jira] [Commented] (KAFKA-2561) Optionally support OpenSSL for SSL/TLS

[ https://issues.apache.org/jira/browse/KAFKA-2561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258958#comment-15258958 ] Scott Kruger commented on KAFKA-2561: - Now that Java 9 has been delayed until 2017, ca

[GitHub] kafka pull request: MINOR: Upgrade to Gradle 2.13

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/1271 MINOR: Upgrade to Gradle 2.13 There are a few improvements in 2.12 and 2.13. I am particularly interested in the performance improvements: * 2.12: "This release brings support for compile only dep

[jira] [Updated] (KAFKA-3627) New consumer doesn't run delayed tasks while under load

[ https://issues.apache.org/jira/browse/KAFKA-3627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rob Underwood updated KAFKA-3627: - Attachment: kafka-3627-output.log > New consumer doesn't run delayed tasks while under load >

[jira] [Commented] (KAFKA-3627) New consumer doesn't run delayed tasks while under load

[ https://issues.apache.org/jira/browse/KAFKA-3627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258963#comment-15258963 ] Rob Underwood commented on KAFKA-3627: -- I've attached an example consumer in Java tha

[jira] [Commented] (KAFKA-3627) New consumer doesn't run delayed tasks while under load

[ https://issues.apache.org/jira/browse/KAFKA-3627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258986#comment-15258986 ] Jason Gustafson commented on KAFKA-3627: [~robu] Good catch and thanks for the inv

[jira] [Assigned] (KAFKA-3627) New consumer doesn't run delayed tasks while under load

[ https://issues.apache.org/jira/browse/KAFKA-3627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-3627: -- Assignee: Jason Gustafson (was: Liquan Pei) > New consumer doesn't run delayed tasks w

[GitHub] kafka pull request: MINOR: Upgrade to Gradle 2.13

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

Re: [ANNOUNCE] New committer: Ismael Juma

Congratulations, Ismael! E. Ribeiro Em 26/04/2016 15:33, "Jason Gustafson" escreveu: > Great work, Ismael! > > On Tue, Apr 26, 2016 at 9:00 AM, Grant Henke wrote: > > > Congratulations Ismael! > > On Apr 26, 2016 8:55 AM, "Harsha" wrote: > > > > > Congrats, Ismael > > > > > > -Harsha > > > > >

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

See Changes: [cshapi] MINOR: Upgrade to Gradle 2.13 -- [...truncated 493 lines...] kafka.log.BrokerCompressionTest > testBrokerSideCompression[19] PASSED kafka.log.OffsetIndexTest > lookupExtrem

[jira] [Created] (KAFKA-3628) Native Schema Registry in Kafka

Sriharsha Chintalapani created KAFKA-3628: - Summary: Native Schema Registry in Kafka Key: KAFKA-3628 URL: https://issues.apache.org/jira/browse/KAFKA-3628 Project: Kafka Issue Type: B

[jira] [Assigned] (KAFKA-3628) Native Schema Registry in Kafka

[ https://issues.apache.org/jira/browse/KAFKA-3628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani reassigned KAFKA-3628: - Assignee: Sriharsha Chintalapani > Native Schema Registry in Kafka >

[jira] [Updated] (KAFKA-3628) Native Schema Registry in Kafka

[ https://issues.apache.org/jira/browse/KAFKA-3628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-3628: -- Issue Type: New Feature (was: Bug) > Native Schema Registry in Kafka >

Re: [ANNOUNCE] New committer: Ismael Juma

Congrats Ismael!! Regards, Bharat On Tue, Apr 26, 2016 at 4:17 PM, Edward Ribeiro wrote: > Congratulations, Ismael! > > E. Ribeiro > Em 26/04/2016 15:33, "Jason Gustafson" escreveu: > > > Great work, Ismael! > > > > On Tue, Apr 26, 2016 at 9:00 AM, Grant Henke > wrote: > > > > > Congratulat

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

See

[jira] [Commented] (KAFKA-3149) Extend SASL implementation to support more mechanisms

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

[jira] [Commented] (KAFKA-3294) Kafka REST API

[ https://issues.apache.org/jira/browse/KAFKA-3294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15259216#comment-15259216 ] Sriharsha Chintalapani commented on KAFKA-3294: --- [~chienle] I am familiar wi

[jira] [Updated] (KAFKA-3149) Extend SASL implementation to support more mechanisms

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

[GitHub] kafka pull request: KAFKA-3149: Extend SASL implementation to supp...

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

[GitHub] kafka pull request: KAFKA-3306: Change metadata response to includ...

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

  1   2   >