[jira] [Updated] (KAFKA-3172) Consumer threads stay in 'Watiting' status and are blocked at consumer poll method

[ https://issues.apache.org/jira/browse/KAFKA-3172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dany Benjamin updated KAFKA-3172: - Priority: Critical (was: Blocker) > Consumer threads stay in 'Watiting' status and are blocked at

[jira] [Updated] (KAFKA-3172) Consumer threads stay in 'Watiting' status and are blocked at consumer poll method

[ https://issues.apache.org/jira/browse/KAFKA-3172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dany Benjamin updated KAFKA-3172: - Priority: Blocker (was: Major) > Consumer threads stay in 'Watiting' status and are blocked at co

[jira] [Updated] (KAFKA-3029) Make class org.apache.kafka.common.TopicPartition Serializable

[ https://issues.apache.org/jira/browse/KAFKA-3029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3029: - Assignee: Praveen Devarao > Make class org.apache.kafka.common.TopicPartition Seri

[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 ] Jiangjie Qin updated KAFKA-3174: Status: Patch Available (was: Open) > Re-evaluate the CRC32 class performance. > --

[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=15124778#comment-15124778 ] ASF GitHub Bot commented on KAFKA-3174: --- GitHub user becketqin opened a pull request

[GitHub] kafka pull request: KAFKA-3174: Change Crc32 to use java.util.zip....

GitHub user becketqin opened a pull request: https://github.com/apache/kafka/pull/841 KAFKA-3174: Change Crc32 to use java.util.zip.CRC32 You can merge this pull request into a Git repository by running: $ git pull https://github.com/becketqin/kafka KAFKA-3174 Alternatively y

[jira] [Commented] (KAFKA-2522) ConsumerGroupCommand sends all output to STDOUT

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

[GitHub] kafka pull request: KAFKA-2522: ConsumerGroupCommand writes error ...

GitHub user melan opened a pull request: https://github.com/apache/kafka/pull/840 KAFKA-2522: ConsumerGroupCommand writes error messages to STDERR instead of STDOUT ConsumerGroupCommand sends errors and valuable output to different streams. It simplifies results parsing. @

[jira] [Commented] (KAFKA-2522) ConsumerGroupCommand sends all output to STDOUT

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

[GitHub] kafka pull request: KAFKA-2522: ConsumerGroupCommand writes error ...

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

[jira] [Commented] (KAFKA-3175) topic not accessible after deletion even when delete.topic.enable is disabled

[ https://issues.apache.org/jira/browse/KAFKA-3175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15124722#comment-15124722 ] Jun Rao commented on KAFKA-3175: It's already doing that. The problem is that initialTopic

[jira] [Comment Edited] (KAFKA-3175) topic not accessible after deletion even when delete.topic.enable is disabled

[ https://issues.apache.org/jira/browse/KAFKA-3175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15124681#comment-15124681 ] Mayuresh Gharat edited comment on KAFKA-3175 at 1/30/16 3:05 AM: ---

[jira] [Commented] (KAFKA-3175) topic not accessible after deletion even when delete.topic.enable is disabled

[ https://issues.apache.org/jira/browse/KAFKA-3175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15124681#comment-15124681 ] Mayuresh Gharat commented on KAFKA-3175: I am just thinking we have that check in

[jira] [Commented] (KAFKA-3175) topic not accessible after deletion even when delete.topic.enable is disabled

[ https://issues.apache.org/jira/browse/KAFKA-3175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15124643#comment-15124643 ] Jun Rao commented on KAFKA-3175: The issue is that during the controller failover, we call

[jira] [Assigned] (KAFKA-3175) topic not accessible after deletion even when delete.topic.enable is disabled

[ https://issues.apache.org/jira/browse/KAFKA-3175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mayuresh Gharat reassigned KAFKA-3175: -- Assignee: Mayuresh Gharat > topic not accessible after deletion even when delete.topic.

[jira] [Assigned] (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 ] Jiangjie Qin reassigned KAFKA-3174: --- Assignee: Jiangjie Qin > Re-evaluate the CRC32 class performance. > -

[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 ] Jiangjie Qin updated KAFKA-3174: Description: We used org.apache.kafka.common.utils.CRC32 in clients because it has better performan

[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=15124630#comment-15124630 ] Jiangjie Qin commented on KAFKA-3174: - [~ijuma] I just started writing the patch. Shou

[jira] [Created] (KAFKA-3175) topic not accessible after deletion even when delete.topic.enable is disabled

Jun Rao created KAFKA-3175: -- Summary: topic not accessible after deletion even when delete.topic.enable is disabled Key: KAFKA-3175 URL: https://issues.apache.org/jira/browse/KAFKA-3175 Project: Kafka

[jira] [Updated] (KAFKA-3173) Error while moving some partitions to OnlinePartition state

[ https://issues.apache.org/jira/browse/KAFKA-3173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira updated KAFKA-3173: Description: We observed another instance of the problem reported in KAFKA-2300, but this t

[jira] [Updated] (KAFKA-3173) Error while moving some partitions to OnlinePartition state

[ https://issues.apache.org/jira/browse/KAFKA-3173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira updated KAFKA-3173: Description: We observed another instance of the problem reported in KAFKA-2300, but this 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=15124563#comment-15124563 ] Onur Karaman commented on KAFKA-2936: - Hi [~ijuma]. I actually forgot about this and h

[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=15124558#comment-15124558 ] Ismael Juma commented on KAFKA-3174: Becket, are you planning to do this one? I'll tak

[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=15124555#comment-15124555 ] Ismael Juma commented on KAFKA-3174: Jay, I think you meant https://bugs.openjdk.java.

[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=15124537#comment-15124537 ] Jay Kreps commented on KAFKA-3174: -- This is a great find. It looks like it did become an

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

The rationale for the CRC covering the whole record was to check corruption in the full record contents as corruption there will equally prevent someone trying to consume the data. I think you could argue either way but let's definitely not end up with two different CRC calculations, that would jus

[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 ] Jiangjie Qin updated KAFKA-3174: Affects Version/s: 0.9.0.0 Fix Version/s: 0.9.0.1 > Re-evaluate the CRC32 class performance.

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

Jiangjie Qin created KAFKA-3174: --- Summary: Re-evaluate the CRC32 class performance. Key: KAFKA-3174 URL: https://issues.apache.org/jira/browse/KAFKA-3174 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-3173) Error while moving some partitions to OnlinePartition state

Flavio Junqueira created KAFKA-3173: --- Summary: Error while moving some partitions to OnlinePartition state Key: KAFKA-3173 URL: https://issues.apache.org/jira/browse/KAFKA-3173 Project: Kafka

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

Hi Anna, I think there is value if CRC for only user bytes can be used. This will help when we have future protocol updates. Otherwise any protocol migration might break auditing if it largely relies on CRC including system bytes. I did some test to understand the performance overhead of having a

[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=15124460#comment-15124460 ] ASF GitHub Bot commented on KAFKA-3121: --- GitHub user guozhangwang opened a pull requ

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

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/839 KAFKA-3121: Refactor KStream Aggregate to be Lambda-able. You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka K3121s2 Altern

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

See Changes: [wangguoz] MINOR: Remove unused imports from tests whose packages were fixed -- [...truncated 2793 lines...] kafka.log.LogTest > testTimeBasedLogRoll PASSED kafka.log.LogTest > te

[jira] [Resolved] (KAFKA-3171) min.insync.replicas not respected

[ https://issues.apache.org/jira/browse/KAFKA-3171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Serbu resolved KAFKA-3171. - Resolution: Invalid You are right, after I changed ack with "acks" producer raise error when ISR

[jira] [Updated] (KAFKA-3164) Document client and mirrormaker upgrade procedure/requirements

[ https://issues.apache.org/jira/browse/KAFKA-3164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-3164: --- Status: Patch Available (was: Open) > Document client and mirrormaker upgrade procedure/requirements

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

See Changes: [wangguoz] MINOR: Remove unused imports from tests whose packages were fixed -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu

Contributor List

Would it be possible to add me to the contributor list? My apache jira username is: abrahamfine Thanks, Abe

[jira] [Commented] (KAFKA-3164) Document client and mirrormaker upgrade procedure/requirements

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

[GitHub] kafka pull request: KAFKA-3164: Document client and mirrormaker up...

GitHub user granthenke opened a pull request: https://github.com/apache/kafka/pull/838 KAFKA-3164: Document client and mirrormaker upgrade procedure/require… …ments You can merge this pull request into a Git repository by running: $ git pull https://github.com/granthenke/ka

[jira] [Commented] (KAFKA-2607) Review `Time` interface and its usage

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

[GitHub] kafka pull request: KAFKA-2607: Review `Time` interface and its us...

GitHub user afine opened a pull request: https://github.com/apache/kafka/pull/837 KAFKA-2607: Review `Time` interface and its usage You can merge this pull request into a Git repository by running: $ git pull https://github.com/afine/kafka KAFKA-2607 Alternatively you can rev

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

Joel, thanks for your feedback. I updated the wiki based on your comments about the wiki writeup. On Fri, Jan 29, 2016 at 11:50 AM, Anna Povzner wrote: > Becket, > > In your scenario with one message from producer A and one message from > producer B, those are two different messages, and they s

[GitHub] kafka pull request: MINOR: Remove unused imports from tests whose ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/836 --- 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] [Assigned] (KAFKA-3171) min.insync.replicas not respected

[ https://issues.apache.org/jira/browse/KAFKA-3171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke reassigned KAFKA-3171: -- Assignee: Grant Henke > min.insync.replicas not respected > - >

[jira] [Commented] (KAFKA-3171) min.insync.replicas not respected

[ https://issues.apache.org/jira/browse/KAFKA-3171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15124197#comment-15124197 ] Grant Henke commented on KAFKA-3171: Can you try changing `props.put("ack", "all");` t

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

Becket, In your scenario with one message from producer A and one message from producer B, those are two different messages, and they should be tracked as two different messages. So I would argue for using record CRC -- CRC that is actually used by the system + it will not require computing a diff

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

Neha, CRC is definitely an important type of metadata of a record. I am not arguing about that. But I think we should distinguish between two types of checksum here, 1) the checksum of user data. and 2) the checksum including system appended bytes. I completely agree that (1) is good to add. But

[GitHub] kafka pull request: MINOR: Remove unused imports from tests whose ...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/836 MINOR: Remove unused imports from tests whose packages were fixed I missed this when reviewing: https://github.com/apache/kafka/commit/a58b459bddd5b1dcab224b53cda0196e947a5b09 You can merge t

[jira] [Assigned] (KAFKA-3124) Update protocol wiki page to reflect latest request/response formats

[ https://issues.apache.org/jira/browse/KAFKA-3124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3124: - Assignee: Liquan Pei > Update protocol wiki page to reflect latest request/response formats > ---

[jira] [Updated] (KAFKA-3124) Update protocol wiki page to reflect latest request/response formats

[ https://issues.apache.org/jira/browse/KAFKA-3124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3124: Labels: newbie (was: ) > Update protocol wiki page to reflect latest request/response formats > ---

[jira] [Updated] (KAFKA-3172) Consumer threads stay in 'Watiting' status and are blocked at consumer poll method

[ https://issues.apache.org/jira/browse/KAFKA-3172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dany Benjamin updated KAFKA-3172: - Attachment: jmx_info.png > Consumer threads stay in 'Watiting' status and are blocked at consumer

[jira] [Updated] (KAFKA-3172) Consumer threads stay in 'Watiting' status and are blocked at consumer poll method

[ https://issues.apache.org/jira/browse/KAFKA-3172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dany Benjamin updated KAFKA-3172: - Attachment: lagSample.png > Consumer threads stay in 'Watiting' status and are blocked at consumer

[jira] [Updated] (KAFKA-3172) Consumer threads stay in 'Watiting' status and are blocked at consumer poll method

[ https://issues.apache.org/jira/browse/KAFKA-3172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dany Benjamin updated KAFKA-3172: - Attachment: jstack.png > Consumer threads stay in 'Watiting' status and are blocked at consumer po

[jira] [Commented] (KAFKA-3172) Consumer threads stay in 'Watiting' status and are blocked at consumer poll method

[ https://issues.apache.org/jira/browse/KAFKA-3172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15123994#comment-15123994 ] Dany Benjamin commented on KAFKA-3172: -- Even after the consumers are stopped (400) an

[jira] [Created] (KAFKA-3172) Consumer threads stay in 'Watiting' status and are blocked at consumer poll method

Dany Benjamin created KAFKA-3172: Summary: Consumer threads stay in 'Watiting' status and are blocked at consumer poll method Key: KAFKA-3172 URL: https://issues.apache.org/jira/browse/KAFKA-3172 Proj

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

See

[jira] [Commented] (KAFKA-1464) Add a throttling option to the Kafka replication tool

[ https://issues.apache.org/jira/browse/KAFKA-1464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15123956#comment-15123956 ] Jiangjie Qin commented on KAFKA-1464: - It looks our purpose is to minimize user impact

[jira] [Commented] (KAFKA-3093) Keep track of connector and task status info, expose it via the REST API

[ https://issues.apache.org/jira/browse/KAFKA-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15123938#comment-15123938 ] Jason Gustafson commented on KAFKA-3093: [~jinxing6...@126.com] I've started looki

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

See

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

See Changes: [me] KAFKA-3029: Mark TopicPartition and OffsetAndMetadata as Serializable [wangguoz] KAFKA-2676: Fix incorrect package name in tests [wangguoz] MINOR: remove the init method from Serdes -

[jira] [Updated] (KAFKA-3029) Make class org.apache.kafka.common.TopicPartition Serializable

[ https://issues.apache.org/jira/browse/KAFKA-3029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3029: - Fix Version/s: 0.9.0.1 > Make class org.apache.kafka.common.TopicPartition Seriali

Confluence Access

Hello, I'm planning to create a new KIP, but I don't think I have the proper permissions to actually create a child page on the Confluence wiki. Could an administrator give me access to create pages, or am I missing something obvious? Thanks, Bill Warshaw -- This mess

[jira] [Commented] (KAFKA-2143) Replicas get ahead of leader and fail

[ https://issues.apache.org/jira/browse/KAFKA-2143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15123866#comment-15123866 ] Jiangjie Qin commented on KAFKA-2143: - Thanks, [~guozhang]. I almost forgot I had this

[jira] [Commented] (KAFKA-3110) can't set cluster acl for a user to CREATE topics without first creating a topic

[ https://issues.apache.org/jira/browse/KAFKA-3110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15123851#comment-15123851 ] Ismael Juma commented on KAFKA-3110: Thanks for checking. > can't set cluster acl for

[jira] [Resolved] (KAFKA-3110) can't set cluster acl for a user to CREATE topics without first creating a topic

[ https://issues.apache.org/jira/browse/KAFKA-3110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Graves resolved KAFKA-3110. -- Resolution: Invalid > can't set cluster acl for a user to CREATE topics without first creating a

[jira] [Commented] (KAFKA-3110) can't set cluster acl for a user to CREATE topics without first creating a topic

[ https://issues.apache.org/jira/browse/KAFKA-3110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15123845#comment-15123845 ] Thomas Graves commented on KAFKA-3110: -- Tried to reproduce this again but couldn't.

[jira] [Updated] (KAFKA-3165) Fix ignored parameters in the gradle "All" tasks

[ https://issues.apache.org/jira/browse/KAFKA-3165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-3165: --- Status: Patch Available (was: Open) > Fix ignored parameters in the gradle "All" tasks >

[GitHub] kafka pull request: MINOR: remove the init method from Serdes

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/834 --- 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-2676) Incorrect package name in tests (unit and integration prefix)

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

[jira] [Commented] (KAFKA-2676) Incorrect package name in tests (unit and integration prefix)

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

[GitHub] kafka pull request: KAFKA-2676: Fix incorrect package name in test...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/828 --- 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-3165) Fix ignored parameters in the gradle "All" tasks

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

[GitHub] kafka pull request: KAFKA-3165: Fix ignored parameters in the grad...

GitHub user granthenke opened a pull request: https://github.com/apache/kafka/pull/835 KAFKA-3165: Fix ignored parameters in the gradle "All" tasks You can merge this pull request into a Git repository by running: $ git pull https://github.com/granthenke/kafka all-parameters

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

See Changes: [wangguoz] KAFKA-3086: Remove unused method in MirrorMaker. [wangguoz] MINOR: Fix spelling and grammar issues in ReplicaFetcherThread detailed [wangguoz] KAFKA-3075; Fix ClassCastException in ---

[jira] [Commented] (KAFKA-3029) Make class org.apache.kafka.common.TopicPartition Serializable

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

[GitHub] kafka pull request: KAFKA-3029:Marking class org.apache.kafka.comm...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/711 --- 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-3029) Make class org.apache.kafka.common.TopicPartition Serializable

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

[GitHub] kafka pull request: MINOR: remove the init method from Serdes

GitHub user ymatsuda opened a pull request: https://github.com/apache/kafka/pull/834 MINOR: remove the init method from Serdes @guozhangwang You can merge this pull request into a Git repository by running: $ git pull https://github.com/ymatsuda/kafka remove_init_from_Serdes

[jira] [Updated] (KAFKA-3075) java.util.HashMap cannot be cast to scala.collection.immutable.Map When using ZookeeperConsumerConnector.commitOffsets

[ https://issues.apache.org/jira/browse/KAFKA-3075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3075: - Resolution: Fixed Status: Resolved (was: Patch Available) > java.util.HashMap cannot be c

Re: kafka-consumer-groups.sh doesn't work when consumers are off

Thanks for the added info. For the mean time we'll rely on the older ConsumerOffsetChecker for our monitoring tools. Thanks, Cliff On Fri, Jan 29, 2016 at 10:56 AM, Guozhang Wang wrote: > Tao, > > You are right, ConsumerOffsetChecker can still get offsets from the offset > manager in Kafka. >

[jira] [Commented] (KAFKA-3161) Refactor Java client's use of the Properties class

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

[jira] [Commented] (KAFKA-3161) Refactor Java client's use of the Properties class

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

[GitHub] kafka pull request: KAFKA-3161: Fixed ProducerConfig/ConsumerConfi...

GitHub user crhyne reopened a pull request: https://github.com/apache/kafka/pull/824 KAFKA-3161: Fixed ProducerConfig/ConsumerConfig so that defaults are used in java.util.Properties This impacts the ProducerConfig and ConsumerConfig. I added a unit test to reflect the new case.

[GitHub] kafka pull request: KAFKA-3161: Fixed ProducerConfig/ConsumerConfi...

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

Re: kafka-consumer-groups.sh doesn't work when consumers are off

Tao, You are right, ConsumerOffsetChecker can still get offsets from the offset manager in Kafka. Guozhang On Thu, Jan 28, 2016 at 9:36 PM, tao xiao wrote: > it first issues an offsetrequest to broker and check if offset is stored in > broker if not it will queries zk > > > https://github.com/

[GitHub] kafka pull request: KAFKA-3075; Fix ClassCastException in `Zookeep...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/833 --- 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-3075) java.util.HashMap cannot be cast to scala.collection.immutable.Map When using ZookeeperConsumerConnector.commitOffsets

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

[GitHub] kafka pull request: MINOR: Fix spelling and grammar issues in Repl...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/829 --- 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-3086) unused handle method in MirrorMakerMessageHandler

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

[jira] [Updated] (KAFKA-3086) unused handle method in MirrorMakerMessageHandler

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

[GitHub] kafka pull request: KAFKA-3086: Remove unused method.

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/758 --- 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-3075) java.util.HashMap cannot be cast to scala.collection.immutable.Map When using ZookeeperConsumerConnector.commitOffsets

[ https://issues.apache.org/jira/browse/KAFKA-3075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15123723#comment-15123723 ] Ismael Juma commented on KAFKA-3075: Not related to the bug report, but you may consid

[jira] [Updated] (KAFKA-3075) java.util.HashMap cannot be cast to scala.collection.immutable.Map When using ZookeeperConsumerConnector.commitOffsets

[ https://issues.apache.org/jira/browse/KAFKA-3075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3075: --- Affects Version/s: 0.9.0.0 Status: Patch Available (was: Open) Thanks for the report.

[jira] [Commented] (KAFKA-3075) java.util.HashMap cannot be cast to scala.collection.immutable.Map When using ZookeeperConsumerConnector.commitOffsets

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

[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 ] Ismael Juma updated KAFKA-3068: --- Fix Version/s: 0.9.0.1 > NetworkClient may connect to a different Kafka cluster than originally > con

[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 ] Ismael Juma updated KAFKA-3068: --- Reviewer: Ewen Cheslack-Postava Status: Patch Available (was: Open) > NetworkClient may connect

[GitHub] kafka pull request: KAFKA-3075; Fix ClassCastException in `Zookeep...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/833 KAFKA-3075; Fix ClassCastException in `ZookeeperConsumerConnector.commitOffsets` You can merge this pull request into a Git repository by running: $ git pull https://github.com/ijuma/kafka kafk

[jira] [Assigned] (KAFKA-3075) java.util.HashMap cannot be cast to scala.collection.immutable.Map When using ZookeeperConsumerConnector.commitOffsets

[ https://issues.apache.org/jira/browse/KAFKA-3075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-3075: -- Assignee: Ismael Juma (was: Neha Narkhede) > java.util.HashMap cannot be cast to scala.collect

[jira] [Updated] (KAFKA-3171) min.insync.replicas not respected

[ https://issues.apache.org/jira/browse/KAFKA-3171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Serbu updated KAFKA-3171: Environment: Kafka downloaded from http://apache.javapipe.com/kafka/0.9.0.0/kafka_2.11-0.9.0.0.tgz

[jira] [Created] (KAFKA-3171) min.insync.replicas not respected

Victor Serbu created KAFKA-3171: --- Summary: min.insync.replicas not respected Key: KAFKA-3171 URL: https://issues.apache.org/jira/browse/KAFKA-3171 Project: Kafka Issue Type: Bug Rep

  1   2   >