Consumer Assignment documentation - StreamPartitionAssignment.java

Hi all, I am going through the partition assignment logic in the Kafka new consumer. Is there any documentation for the logic implemented? It would be great if some one can write the algorithm for consumer partition assignment (within a group and across groups). -- Regards Vamsi Subhash

[jira] [Comment Edited] (KAFKA-3189) Kafka server always return UnknownServerException.

[ https://issues.apache.org/jira/browse/KAFKA-3189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15127813#comment-15127813 ] Ismael Juma edited comment on KAFKA-3189 at 2/2/16 9:43 AM: Ch

[jira] [Commented] (KAFKA-3174) Re-evaluate the CRC32 class performance.

[ https://issues.apache.org/jira/browse/KAFKA-3174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128038#comment-15128038 ] Ismael Juma commented on KAFKA-3174: Becket, I think the best way to validate the reas

[jira] [Commented] (KAFKA-3186) Kafka authorizer should be aware of principal types it supports.

[ https://issues.apache.org/jira/browse/KAFKA-3186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128067#comment-15128067 ] Ismael Juma commented on KAFKA-3186: The CLI is actually meant to work with pluggable

Re: [DISCUSS] KIP-43: Kafka SASL enhancements

As Ismael has said, we do not have a requirement to support multiple protocols in a broker. But I agree with Jun's observation that some companies might want to support a different authentication mechanism for internal users or partners. For instance, we do use two different authentication mechanis

[jira] [Assigned] (KAFKA-3189) Kafka server always return UnknownServerException.

[ https://issues.apache.org/jira/browse/KAFKA-3189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke reassigned KAFKA-3189: -- Assignee: Grant Henke > Kafka server always return UnknownServerException. > --

[jira] [Commented] (KAFKA-3189) Kafka server always return UnknownServerException.

[ https://issues.apache.org/jira/browse/KAFKA-3189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128284#comment-15128284 ] Grant Henke commented on KAFKA-3189: [~becket_qin] Could you be more specific how/when

[jira] [Updated] (KAFKA-3169) Kafka broker throws OutOfMemory error with invalid SASL packet

[ https://issues.apache.org/jira/browse/KAFKA-3169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3169: --- Resolution: Fixed Status: Resolved (was: Patch Available) This was merged to both trunk and 0

[jira] [Updated] (KAFKA-3169) Kafka broker throws OutOfMemory error with invalid SASL packet

[ https://issues.apache.org/jira/browse/KAFKA-3169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3169: --- Reviewer: sriharsha chintalapani > Kafka broker throws OutOfMemory error with invalid SASL packet > --

Re: [VOTE] KIP-42 -- Add Producer and Consumer Interceptors.

+1 On Monday, February 1, 2016, Anna Povzner wrote: > Hi All, > > I am opening the voting thread for KIP-42: Add Producer and Consumer > Interceptors. > > For reference, here's the KIP wiki: > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-42%3A+Add+Producer+and+Consumer+Interceptors >

[jira] [Commented] (KAFKA-2936) Socket server selector can stuck on one send in tight loop.

[ https://issues.apache.org/jira/browse/KAFKA-2936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128448#comment-15128448 ] Jun Rao commented on KAFKA-2936: [~becket_qin], is this still an issue? We fixed a similar

Re: Consumer Assignment documentation - StreamPartitionAssignment.java

Hi Vamsi, Consumer partition assignment is always within a single group. You can find the java docs for the PartitionAssignor interface here: https://kafka.apache.org/090/javadoc/index.html?org/apache/kafka/clients/consumer/RangeAssignor.html StreamPartitionAssignor is one implementation of the

[GitHub] kafka pull request: KAFKA-3068: Remove retry with nodesEverSeen

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/823 --- 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-3068) NetworkClient may connect to a different Kafka cluster than originally configured

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

[jira] [Commented] (KAFKA-3068) NetworkClient may connect to a different Kafka cluster than originally configured

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

[GitHub] kafka pull request: KAFKA-3170: Set default fetch_min_bytes in new...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/832 --- 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-3170) Default value of fetch_min_bytes in new consumer is 1024 while doc says it is 1

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

[jira] [Commented] (KAFKA-3186) Kafka authorizer should be aware of principal types it supports.

[ https://issues.apache.org/jira/browse/KAFKA-3186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128661#comment-15128661 ] Ashish K Singh commented on KAFKA-3186: --- {quote} I assume you are referring to the f

[GitHub] kafka pull request: MINOR: fix the logic of RocksDBWindowStore usi...

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/849 MINOR: fix the logic of RocksDBWindowStore using RocksDBStore Segments You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka KR

[GitHub] kafka pull request: MINOR: fix the logic of RocksDBWindowStore usi...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/849 --- 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-3189) Kafka server always return UnknownServerException.

[ https://issues.apache.org/jira/browse/KAFKA-3189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128739#comment-15128739 ] Jiangjie Qin commented on KAFKA-3189: - [~granthenke] The exception I saw was InvalidMe

[jira] [Updated] (KAFKA-3191) Improve offset committing JavaDoc in KafkaConsumer

[ https://issues.apache.org/jira/browse/KAFKA-3191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3191: Assignee: Adam Kunicki (was: Neha Narkhede) > Improve offset committing JavaDoc in KafkaConsumer >

Re: [VOTE] KIP-42 -- Add Producer and Consumer Interceptors.

+1. On Tue, Feb 2, 2016 at 7:46 AM, Joel Koshy wrote: > +1 > > On Monday, February 1, 2016, Anna Povzner wrote: > > > Hi All, > > > > I am opening the voting thread for KIP-42: Add Producer and Consumer > > Interceptors. > > > > For reference, here's the KIP wiki: > > > > > https://cwiki.apache

[jira] [Commented] (KAFKA-3186) Kafka authorizer should be aware of principal types it supports.

[ https://issues.apache.org/jira/browse/KAFKA-3186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128743#comment-15128743 ] Gwen Shapira commented on KAFKA-3186: - Got it. In this case, the suggestion makes sens

Re: [VOTE] KIP-42 -- Add Producer and Consumer Interceptors.

Hi All, KIP-42 passes with 6 binding and 2 non-binding +1s. I will update the wiki and post an initial patch in the next couple of days. Thanks everyone for the feedback! Anna On Tue, Feb 2, 2016 at 10:31 AM, Guozhang Wang wrote: > +1. > > On Tue, Feb 2, 2016 at 7:46 AM, Joel Koshy wrote: >

[jira] [Created] (KAFKA-3192) Add implicit unlimited windowed aggregation for KStream

Guozhang Wang created KAFKA-3192: Summary: Add implicit unlimited windowed aggregation for KStream Key: KAFKA-3192 URL: https://issues.apache.org/jira/browse/KAFKA-3192 Project: Kafka Issue T

[jira] [Commented] (KAFKA-2936) Socket server selector can stuck on one send in tight loop.

[ https://issues.apache.org/jira/browse/KAFKA-2936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128770#comment-15128770 ] Jiangjie Qin commented on KAFKA-2936: - [~junrao] It seems KAFKA-2813 should have fixed

[jira] [Resolved] (KAFKA-2936) Socket server selector can stuck on one send in tight loop.

[ https://issues.apache.org/jira/browse/KAFKA-2936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved KAFKA-2936. - Resolution: Duplicate This issue has been fixed in KAFKA-2813. Close as duplicate. > Socket serve

[GitHub] kafka pull request: MINOR: some javadocs for kstream public api

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

See Changes: [me] KAFKA-3068: Remove retry with nodesEverSeen [wangguoz] KAFKA-3170; Set default fetch_min_bytes in new consumer to 1 [wangguoz] MINOR: fix the logic of RocksDBWindowStore using RocksDBStore Segments

[jira] [Created] (KAFKA-3193) Wait for producer message acks in StreamTask.commit()

Guozhang Wang created KAFKA-3193: Summary: Wait for producer message acks in StreamTask.commit() Key: KAFKA-3193 URL: https://issues.apache.org/jira/browse/KAFKA-3193 Project: Kafka Issue Typ

[jira] [Resolved] (KAFKA-3193) Wait for producer message acks in StreamTask.commit()

[ https://issues.apache.org/jira/browse/KAFKA-3193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3193. -- Resolution: Not A Problem > Wait for producer message acks in StreamTask.commit() >

[jira] [Updated] (KAFKA-3162) KIP-42: Add Producer and Consumer Interceptors

[ https://issues.apache.org/jira/browse/KAFKA-3162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anna Povzner updated KAFKA-3162: Description: This JIRA is for KIP-42 implementation, which includes: 1. Add ProducerInterceptor int

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

See Changes: [wangguoz] KAFKA-3170; Set default fetch_min_bytes in new consumer to 1 [wangguoz] MINOR: fix the logic of RocksDBWindowStore using RocksDBStore Segments [wangguoz] MINOR: some javadocs for kstream public api -

Re: [DISCUSS] KIP-33 - Add a time based log index to Kafka

Bump up. Because most of the changes in KIP-33 have been discussed in KIP-31 and KIP-32 earlier, if there is no further concerns or comments, I will initiate the voting shortly. Thanks, Jiangjie (Becket) Qin On Wed, Jan 27, 2016 at 7:17 PM, Becket Qin wrote: > Hi, > > Since KIP-31 and KIP-32 h

[GitHub] kafka pull request: KAFKA-3191: Improve offset committing JavaDoc ...

GitHub user kunickiaj opened a pull request: https://github.com/apache/kafka/pull/850 KAFKA-3191: Improve offset committing JavaDoc in KafkaConsumer Added an example clarifying the correct way to use explicit offsets with commitSync(). You can merge this pull request into a Git rep

[jira] [Updated] (KAFKA-3191) Improve offset committing JavaDoc in KafkaConsumer

[ https://issues.apache.org/jira/browse/KAFKA-3191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Adam Kunicki updated KAFKA-3191: Status: Patch Available (was: In Progress) > Improve offset committing JavaDoc in KafkaConsumer > -

[jira] [Updated] (KAFKA-3191) Improve offset committing JavaDoc in KafkaConsumer

[ https://issues.apache.org/jira/browse/KAFKA-3191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Adam Kunicki updated KAFKA-3191: Reviewer: Gwen Shapira > Improve offset committing JavaDoc in KafkaConsumer > --

[jira] [Work started] (KAFKA-3191) Improve offset committing JavaDoc in KafkaConsumer

[ https://issues.apache.org/jira/browse/KAFKA-3191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3191 started by Adam Kunicki. --- > Improve offset committing JavaDoc in KafkaConsumer >

[jira] [Commented] (KAFKA-3191) Improve offset committing JavaDoc in KafkaConsumer

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

[jira] [Commented] (KAFKA-3055) JsonConverter mangles schema during serialization (fromConnectData)

[ https://issues.apache.org/jira/browse/KAFKA-3055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128891#comment-15128891 ] Saravanan Tirugnanum commented on KAFKA-3055: - Hi Kishore I am facing this sa

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

See

[GitHub] kafka pull request: KAFKA-3121: Refactor KStream Aggregate to be L...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/839 --- 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-3121) KStream DSL API Improvement

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

[jira] [Commented] (KAFKA-3121) KStream DSL API Improvement

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

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

See Changes: [wangguoz] MINOR: some javadocs for kstream public api -- [...truncated 6689 lines...] org.apache.kafka.connect.runtime.rest.resources.ConnectorsResourceTest > testGetConnectorTaskC

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

See Changes: [me] KAFKA-3121: Refactor KStream Aggregate to be Lambda-able. -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H11 (docker Ubuntu u

[jira] [Commented] (KAFKA-3129) Potential Console Producer/Consumer Issue

[ https://issues.apache.org/jira/browse/KAFKA-3129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129021#comment-15129021 ] Vahid Hashemian commented on KAFKA-3129: Further evidence that this is a producer

[jira] [Comment Edited] (KAFKA-3129) Potential Console Producer/Consumer Issue

[ https://issues.apache.org/jira/browse/KAFKA-3129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129021#comment-15129021 ] Vahid Hashemian edited comment on KAFKA-3129 at 2/2/16 9:00 PM:

[jira] [Updated] (KAFKA-3129) Console Producer/Consumer Issue

[ https://issues.apache.org/jira/browse/KAFKA-3129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-3129: --- Summary: Console Producer/Consumer Issue (was: Potential Console Producer/Consumer Issue) >

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

See

[jira] [Commented] (KAFKA-3188) Add integration test for KIP-31 and KIP-32

[ https://issues.apache.org/jira/browse/KAFKA-3188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129105#comment-15129105 ] Anna Povzner commented on KAFKA-3188: - [~becket_qin] Do you mind making separate JIRAs

[jira] [Created] (KAFKA-3194) Validate security.inter.broker.protocol against the advertised.listeners protocols

Grant Henke created KAFKA-3194: -- Summary: Validate security.inter.broker.protocol against the advertised.listeners protocols Key: KAFKA-3194 URL: https://issues.apache.org/jira/browse/KAFKA-3194 Project:

[jira] [Updated] (KAFKA-3121) KStream DSL API Improvement

[ https://issues.apache.org/jira/browse/KAFKA-3121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3121: - Description: >From some collected feedbacks, here is a list of potential improvements that >we wa

[GitHub] kafka pull request: KAFKA-3194: Validate security.inter.broker.pro...

GitHub user granthenke opened a pull request: https://github.com/apache/kafka/pull/851 KAFKA-3194: Validate security.inter.broker.protocol against the adver… …tised.listeners protocols You can merge this pull request into a Git repository by running: $ git pull https://gith

[jira] [Commented] (KAFKA-3194) Validate security.inter.broker.protocol against the advertised.listeners protocols

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

[jira] [Updated] (KAFKA-3194) Validate security.inter.broker.protocol against the advertised.listeners protocols

[ https://issues.apache.org/jira/browse/KAFKA-3194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-3194: --- Status: Patch Available (was: Open) > Validate security.inter.broker.protocol against the advertised.

[jira] [Commented] (KAFKA-3159) Kafka consumer 0.9.0.0 client poll is very CPU intensive under certain conditions

[ https://issues.apache.org/jira/browse/KAFKA-3159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129287#comment-15129287 ] Jason Gustafson commented on KAFKA-3159: [~ra...@signalfx.com] I think we'll proba

[GitHub] kafka pull request: zkclient and scalatest library updates

Github user stumped2 closed the pull request at: https://github.com/apache/kafka/pull/3 --- 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: Switch to using scala 2.9.2

Github user stumped2 closed the pull request at: https://github.com/apache/kafka/pull/1 --- 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-826) Make Kafka 0.8 depend on metrics 2.2.0 instead of 3.x

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

[GitHub] kafka pull request: [KAFKA-1344] - Added compression codec option ...

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

[GitHub] kafka pull request: KAFKA-1834: No Response when handle LeaderAndI...

Github user stumped2 closed the pull request at: https://github.com/apache/kafka/pull/40 --- 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-1834) No Response when handle LeaderAndIsrRequest some case

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

[GitHub] kafka pull request: KAFKA-1369 snappy-1.1.x update (RHEL4,5,6)

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

[GitHub] kafka pull request: KAFKA-2356 Added support for retrieving partit...

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

[GitHub] kafka pull request: KAFKA-1695: Adding zookeeper authentication. Z...

Github user stumped2 closed the pull request at: https://github.com/apache/kafka/pull/93 --- 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-1344) Kafka-console-producer.sh support snappy compression

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

[GitHub] kafka pull request: MINOR: MockClient's disconnect() method has tw...

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

[jira] [Commented] (KAFKA-1369) snappy version update 1.1.x

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

[jira] [Commented] (KAFKA-2356) Support retrieving partitions of ConsumerRecords

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

[jira] [Commented] (KAFKA-1695) Authenticate connection to Zookeeper

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

[GitHub] kafka pull request: 0.8.2

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

[GitHub] kafka pull request: KAFKA-1545: KafkaHealthcheck.register failure

Github user stumped2 closed the pull request at: https://github.com/apache/kafka/pull/48 --- 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-1545) java.net.InetAddress.getLocalHost in KafkaHealthcheck.register may fail on some irregular hostnames

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

[GitHub] kafka pull request: 0.9.0

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

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

[ https://issues.apache.org/jira/browse/KAFKA-3177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129355#comment-15129355 ] Jason Gustafson commented on KAFKA-3177: [~guozhang] I think it's useful to separa

[jira] [Created] (KAFKA-3195) Transient test failure in OffsetCheckpointTest.testReadWrite

Ewen Cheslack-Postava created KAFKA-3195: Summary: Transient test failure in OffsetCheckpointTest.testReadWrite Key: KAFKA-3195 URL: https://issues.apache.org/jira/browse/KAFKA-3195 Project: K

[jira] [Updated] (KAFKA-3174) Re-evaluate the CRC32 class performance.

[ https://issues.apache.org/jira/browse/KAFKA-3174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3174: --- Fix Version/s: (was: 0.9.0.1) 0.9.1.0 > Re-evaluate the CRC32 class performance

[jira] [Commented] (KAFKA-3129) Console Producer/Consumer Issue

[ https://issues.apache.org/jira/browse/KAFKA-3129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129382#comment-15129382 ] Jason Gustafson commented on KAFKA-3129: [~vahid] Are you using sync or async mode

[jira] [Commented] (KAFKA-3129) Console Producer/Consumer Issue

[ https://issues.apache.org/jira/browse/KAFKA-3129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129385#comment-15129385 ] Jason Gustafson commented on KAFKA-3129: Ah, my mistake. It actually is being clos

[jira] [Commented] (KAFKA-3195) Transient test failure in OffsetCheckpointTest.testReadWrite

[ https://issues.apache.org/jira/browse/KAFKA-3195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129387#comment-15129387 ] Ismael Juma commented on KAFKA-3195: There is: File f = new File("/tmp/kafka-streams/

[GitHub] kafka pull request: MINOR: Increment ducktape dependency

GitHub user granders opened a pull request: https://github.com/apache/kafka/pull/852 MINOR: Increment ducktape dependency Pin kafka system tests to a newer version of ducktape. Ran in branch builder; only one preexisting (transient) failure: http://confluent-kafka-branc

[jira] [Assigned] (KAFKA-3178) Expose a method in AdminUtils to manually truncate a specific partition to a particular offset

[ https://issues.apache.org/jira/browse/KAFKA-3178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian reassigned KAFKA-3178: -- Assignee: Vahid Hashemian > Expose a method in AdminUtils to manually truncate a specif

[jira] [Commented] (KAFKA-3129) Console Producer/Consumer Issue

[ https://issues.apache.org/jira/browse/KAFKA-3129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129419#comment-15129419 ] Vahid Hashemian commented on KAFKA-3129: Thanks [~hachikuji] for the suggestion. I

[jira] [Commented] (KAFKA-3195) Transient test failure in OffsetCheckpointTest.testReadWrite

[ https://issues.apache.org/jira/browse/KAFKA-3195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129426#comment-15129426 ] Guozhang Wang commented on KAFKA-3195: -- Thanks [~ewencp]. [~ijuma] Do you want to pro

[jira] [Commented] (KAFKA-3129) Console Producer/Consumer Issue

[ https://issues.apache.org/jira/browse/KAFKA-3129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129427#comment-15129427 ] Jason Gustafson commented on KAFKA-3129: Are the missing messages always the last

[jira] [Commented] (KAFKA-3195) Transient test failure in OffsetCheckpointTest.testReadWrite

[ https://issues.apache.org/jira/browse/KAFKA-3195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129438#comment-15129438 ] Ismael Juma commented on KAFKA-3195: Sure. > Transient test failure in OffsetCheckpoi

[jira] [Assigned] (KAFKA-3195) Transient test failure in OffsetCheckpointTest.testReadWrite

[ https://issues.apache.org/jira/browse/KAFKA-3195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-3195: -- Assignee: Ismael Juma (was: Guozhang Wang) > Transient test failure in OffsetCheckpointTest.te

[jira] [Commented] (KAFKA-3129) Console Producer/Consumer Issue

[ https://issues.apache.org/jira/browse/KAFKA-3129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129449#comment-15129449 ] Vahid Hashemian commented on KAFKA-3129: As I mentioned, in the input file I have

[GitHub] kafka pull request: MINOR: some more Javadocs

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/853 MINOR: some more Javadocs You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka KJavaDoc Alternatively you can review and appl

[jira] [Created] (KAFKA-3196) KIP-42 (part 2): add record size and CRC to RecordMetadata and ConsumerRecords

Anna Povzner created KAFKA-3196: --- Summary: KIP-42 (part 2): add record size and CRC to RecordMetadata and ConsumerRecords Key: KAFKA-3196 URL: https://issues.apache.org/jira/browse/KAFKA-3196 Project: K

[jira] [Updated] (KAFKA-3162) KIP-42: Add Producer and Consumer Interceptors

[ https://issues.apache.org/jira/browse/KAFKA-3162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anna Povzner updated KAFKA-3162: Description: This JIRA is for main part of KIP-42 implementation, which includes: 1. Add ProducerIn

[jira] [Updated] (KAFKA-3162) KIP-42: Add Producer and Consumer Interceptors

[ https://issues.apache.org/jira/browse/KAFKA-3162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anna Povzner updated KAFKA-3162: Issue Type: Improvement (was: Bug) > KIP-42: Add Producer and Consumer Interceptors > -

[GitHub] kafka pull request: KAFKA-3162: Added producer and consumer interc...

GitHub user apovzner opened a pull request: https://github.com/apache/kafka/pull/854 KAFKA-3162: Added producer and consumer interceptors This is the most of the KIP-42: Producer and consumer interceptor. (Except exposing CRC and record sizes to the interceptor, which is coming as a

[jira] [Commented] (KAFKA-3162) KIP-42: Add Producer and Consumer Interceptors

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

[jira] [Commented] (KAFKA-3129) Console Producer/Consumer Issue

[ https://issues.apache.org/jira/browse/KAFKA-3129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129499#comment-15129499 ] Jason Gustafson commented on KAFKA-3129: I haven't been able to reproduce this. It

[jira] [Updated] (KAFKA-3162) KIP-42: Add Producer and Consumer Interceptors

[ https://issues.apache.org/jira/browse/KAFKA-3162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anna Povzner updated KAFKA-3162: Status: Patch Available (was: In Progress) > KIP-42: Add Producer and Consumer Interceptors > -

[jira] [Commented] (KAFKA-3178) Expose a method in AdminUtils to manually truncate a specific partition to a particular offset

[ https://issues.apache.org/jira/browse/KAFKA-3178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129513#comment-15129513 ] Bill Warshaw commented on KAFKA-3178: - [~vahid] fyi this ticket may end up closing; we

[jira] [Commented] (KAFKA-3178) Expose a method in AdminUtils to manually truncate a specific partition to a particular offset

[ https://issues.apache.org/jira/browse/KAFKA-3178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129547#comment-15129547 ] Vahid Hashemian commented on KAFKA-3178: [~wwarshaw] Thanks for letting me know. I

  1   2   >