[jira] [Updated] (KAFKA-2470) kafka-producer-perf-test.sh can't configure all to request-num-acks

[ https://issues.apache.org/jira/browse/KAFKA-2470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2470: --- Fix Version/s: 0.8.3 > kafka-producer-perf-test.sh can't configure all to request-num-acks > -

[jira] [Created] (KAFKA-2477) Replicas spuriously deleting all segments in partition

Håkon Hitland created KAFKA-2477: Summary: Replicas spuriously deleting all segments in partition Key: KAFKA-2477 URL: https://issues.apache.org/jira/browse/KAFKA-2477 Project: Kafka Issue Ty

[jira] [Updated] (KAFKA-2477) Replicas spuriously deleting all segments in partition

[ https://issues.apache.org/jira/browse/KAFKA-2477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Håkon Hitland updated KAFKA-2477: - Attachment: kafka_log.txt Attached example log from a broker > Replicas spuriously deleting all s

[jira] [Commented] (KAFKA-1451) Broker stuck due to leader election race

[ https://issues.apache.org/jira/browse/KAFKA-1451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14713405#comment-14713405 ] Jason Kania commented on KAFKA-1451: I too am seeing this issue in 0.8.2.1. > Broker

Re: Issue when enabling SSL on broker

Hi, Harsha, I appreciate you very much for your response and the bash script you provided to generate the keystores works for me and solve the problem. I was wondering it was caused by the cipher suite differences between openjdk and oracle-jdk, anyway it is not that case. Finally I got it worked

Issue when enabling SSL on broker

Hi, folks, I am just following up to see if anybody has clue on the following issue when I was following the guidelines provided in the step of running openssl to verify the SSL setup: [2015-08-25 22:29:15,385] WARN Error in I/O with connection to X (org.apache.kafka.common.network.Selector)

[jira] [Commented] (KAFKA-1690) Add SSL support to Kafka Broker, Producer and Consumer

[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14713445#comment-14713445 ] Navjot commented on KAFKA-1690: --- [~harsha_ch] Finally I got some luck with Testing SSL Enabl

[jira] [Commented] (KAFKA-1690) Add SSL support to Kafka Broker, Producer and Consumer

[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14713464#comment-14713464 ] Sriharsha Chintalapani commented on KAFKA-1690: --- [~NavjotBhardwaj] are you u

[jira] [Commented] (KAFKA-1690) Add SSL support to Kafka Broker, Producer and Consumer

[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14713473#comment-14713473 ] Navjot commented on KAFKA-1690: --- Great [~harsha_ch] seems that it's time to recompile everyt

Re: KAFKA-2364 migrate docs from SVN to git

Hi Guozhang, Our plan is to follow Gwen's suggested approach and migrate the existing svn site repo to new git repo. (1) Gwen's suggestion will help to us maintain latest docs in Kafka repo itself. We periodically need to copy these latest docs to site repo. I will submit patch for this.

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

Dmitry Stratiychuk created KAFKA-2478: - Summary: KafkaConsumer javadoc example seems wrong Key: KAFKA-2478 URL: https://issues.apache.org/jira/browse/KAFKA-2478 Project: Kafka Issue Type:

Re: KAFKA-2364 migrate docs from SVN to git

Hi Kumar, One note: we need to update the documentation on how to submit changes to the website here: http://kafka.apache.org/contributing.html Ismael On Wed, Aug 26, 2015 at 3:13 PM, Manikumar Reddy wrote: > Hi Guozhang, > > Our plan is to follow Gwen's suggested approach and migrate the e

[jira] [Commented] (KAFKA-1690) Add SSL support to Kafka Broker, Producer and Consumer

[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14713667#comment-14713667 ] Navjot commented on KAFKA-1690: --- And it started working. I'll now try to do it via API. Than

Re: Can I get permission to create proposal

Done. Guozhang On Tue, Aug 25, 2015 at 11:33 AM, Abhishek Nigam < ani...@linkedin.com.invalid> wrote: > For pinning the controller to a broker KAFKA-1778 I want to create a > proposal detailing the design. > > My user id is:anigam > > -Abhishek > -- -- Guozhang

[GitHub] kafka pull request: KAFKA-2072: Add StopReplica request/response t...

GitHub user dajac opened a pull request: https://github.com/apache/kafka/pull/170 KAFKA-2072: Add StopReplica request/response to o.a.k.common.requests This PR adds StopReplica request and response as it is required by @ijuma for KAFKA-2411. Migration of core module is addressed a s

[jira] [Commented] (KAFKA-2072) Add StopReplica request/response to o.a.k.common.requests and replace the usage in core module

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

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

[ https://issues.apache.org/jira/browse/KAFKA-2478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14714505#comment-14714505 ] Jason Gustafson commented on KAFKA-2478: [~devstr] I agree that the example seems

Copying latest version docs to kafka repo

Hi Kafka Devs, Current svn website has the following directory structure. 082/ 083/ code.html coding-guide.html committers.html contact.html contributing.html diagrams/ documentation.html downloads.html images includes/ index.html I will be coping

[jira] [Commented] (KAFKA-2477) Replicas spuriously deleting all segments in partition

[ https://issues.apache.org/jira/browse/KAFKA-2477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14715280#comment-14715280 ] Jiangjie Qin commented on KAFKA-2477: - Maybe related to KAFKA-2143. > Replicas spurio

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

[ https://issues.apache.org/jira/browse/KAFKA-2478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14715362#comment-14715362 ] Dmitry Stratiychuk commented on KAFKA-2478: --- Or flush the buffer and commit at t

[jira] [Commented] (KAFKA-1977) Make logEndOffset available in the Zookeeper consumer

[ https://issues.apache.org/jira/browse/KAFKA-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14715394#comment-14715394 ] James Cheng commented on KAFKA-1977: Ping [~gwenshap]. Do you think logEndOffset can/s

[jira] [Commented] (KAFKA-1977) Make logEndOffset available in the Zookeeper consumer

[ https://issues.apache.org/jira/browse/KAFKA-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14715409#comment-14715409 ] Gwen Shapira commented on KAFKA-1977: - I lost track of the new consumer APIs, so I'm o

[jira] [Commented] (KAFKA-1977) Make logEndOffset available in the Zookeeper consumer

[ https://issues.apache.org/jira/browse/KAFKA-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14715430#comment-14715430 ] Will Funnell commented on KAFKA-1977: - I would still definitely like to see this in th

[jira] [Comment Edited] (KAFKA-1977) Make logEndOffset available in the Zookeeper consumer

[ https://issues.apache.org/jira/browse/KAFKA-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14715430#comment-14715430 ] Will Funnell edited comment on KAFKA-1977 at 8/26/15 8:12 PM: --

Re: Review Request 36858: Patch for KAFKA-2120

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/36858/#review96095 --- Can you rebase? clients/src/main/java/org/apache/kafka/clients/InF

[jira] [Updated] (KAFKA-2120) Add a request timeout to NetworkClient

[ https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joel Koshy updated KAFKA-2120: -- Status: In Progress (was: Patch Available) > Add a request timeout to NetworkClient > -

Re: Review Request 36858: Patch for KAFKA-2120

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/36858/#review96586 --- clients/src/main/java/org/apache/kafka/clients/producer/internals/R

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

[ https://issues.apache.org/jira/browse/KAFKA-2478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14715459#comment-14715459 ] Jason Gustafson commented on KAFKA-2478: [~devstr] Not that I'm aware of. You can

[jira] [Commented] (KAFKA-1977) Make logEndOffset available in the Zookeeper consumer

[ https://issues.apache.org/jira/browse/KAFKA-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14715470#comment-14715470 ] Jason Gustafson commented on KAFKA-1977: Seems like there should be some options f

[GitHub] kafka pull request: KAFKA-1683: persisting session information in ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/155 --- 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-1683) Implement a "session" concept in the socket server

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

[jira] [Resolved] (KAFKA-1683) Implement a "session" concept in the socket server

[ https://issues.apache.org/jira/browse/KAFKA-1683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-1683. - Resolution: Fixed Issue resolved by pull request 155 [https://github.com/apache/kafka/pull/155] >

[jira] [Commented] (KAFKA-2477) Replicas spuriously deleting all segments in partition

[ https://issues.apache.org/jira/browse/KAFKA-2477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14715518#comment-14715518 ] Håkon Hitland commented on KAFKA-2477: -- Thanks for the reply. Checking the logs, we d

Re: Review Request 34492: Patch for KAFKA-2210

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34492/ --- (Updated Aug. 26, 2015, 9:29 p.m.) Review request for kafka. Bugs: KAFKA-2210

[jira] [Commented] (KAFKA-2210) KafkaAuthorizer: Add all public entities, config changes and changes to KafkaAPI and kafkaServer to allow pluggable authorizer implementation.

[ https://issues.apache.org/jira/browse/KAFKA-2210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14715553#comment-14715553 ] Parth Brahmbhatt commented on KAFKA-2210: - Updated reviewboard https://reviews.apa

[jira] [Updated] (KAFKA-2210) KafkaAuthorizer: Add all public entities, config changes and changes to KafkaAPI and kafkaServer to allow pluggable authorizer implementation.

[ https://issues.apache.org/jira/browse/KAFKA-2210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Parth Brahmbhatt updated KAFKA-2210: Attachment: KAFKA-2210_2015-08-26_14:29:02.patch > KafkaAuthorizer: Add all public entities,

[jira] [Commented] (KAFKA-2389) CommitType seems not necessary in commit().

[ https://issues.apache.org/jira/browse/KAFKA-2389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14715565#comment-14715565 ] Guozhang Wang commented on KAFKA-2389: -- I'm late on this discussion, but here are my

[jira] [Comment Edited] (KAFKA-2389) CommitType seems not necessary in commit().

[ https://issues.apache.org/jira/browse/KAFKA-2389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14715565#comment-14715565 ] Guozhang Wang edited comment on KAFKA-2389 at 8/26/15 9:39 PM: -

[jira] [Commented] (KAFKA-2477) Replicas spuriously deleting all segments in partition

[ https://issues.apache.org/jira/browse/KAFKA-2477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14715604#comment-14715604 ] Jiangjie Qin commented on KAFKA-2477: - What is the partition replication factor? > Re

[jira] [Comment Edited] (KAFKA-2477) Replicas spuriously deleting all segments in partition

[ https://issues.apache.org/jira/browse/KAFKA-2477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14715604#comment-14715604 ] Jiangjie Qin edited comment on KAFKA-2477 at 8/26/15 10:13 PM: -

[GitHub] kafka pull request: KAFKA-2072: Add StopReplica request/response t...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/170 --- 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-2072) Add StopReplica request/response to o.a.k.common.requests and replace the usage in core module

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

[jira] [Resolved] (KAFKA-2072) Add StopReplica request/response to o.a.k.common.requests and replace the usage in core module

[ https://issues.apache.org/jira/browse/KAFKA-2072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-2072. Resolution: Fixed Issue resolved by pull request 170 [https://github.com/apache/kafka/pull/170] > Add StopR

[jira] [Commented] (KAFKA-2389) CommitType seems not necessary in commit().

[ https://issues.apache.org/jira/browse/KAFKA-2389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14715660#comment-14715660 ] Jiangjie Qin commented on KAFKA-2389: - [~guozhang] As you said, distinguishing sync/as

[jira] [Commented] (KAFKA-2390) Seek() should take a callback.

[ https://issues.apache.org/jira/browse/KAFKA-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14715682#comment-14715682 ] Jiangjie Qin commented on KAFKA-2390: - Makes sense, so if user needs the offsets, they

[jira] [Updated] (KAFKA-2390) OffsetOutOfRangeException should contain the Offset and Partition info.

[ https://issues.apache.org/jira/browse/KAFKA-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2390: Summary: OffsetOutOfRangeException should contain the Offset and Partition info. (was: Seek() shoul

Build failed in Jenkins: Kafka-trunk #601

See Changes: [junrao] KAFKA-2072: Add StopReplica request/response to o.a.k.common.requests -- [...truncated 2936 lines...] kafka.api.ProducerSendTest > testCloseWithZeroTimeoutFromCallerThread PASSED

[jira] [Updated] (KAFKA-2390) OffsetOutOfRangeException should contain the Offset and Partition info.

[ https://issues.apache.org/jira/browse/KAFKA-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2390: Description: Currently when seek() finishes, the offset seek to is not verified and OffsetOutOfRange

[jira] [Updated] (KAFKA-2390) OffsetOutOfRangeException should contain the Offset and Partition info.

[ https://issues.apache.org/jira/browse/KAFKA-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2390: Description: Currently when seek() finishes, the offset seek to is not verified and OffsetOutOfRange

[jira] [Commented] (KAFKA-2477) Replicas spuriously deleting all segments in partition

[ https://issues.apache.org/jira/browse/KAFKA-2477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14715742#comment-14715742 ] Håkon Hitland commented on KAFKA-2477: -- We use a replication factor of 3. The only li

[jira] [Comment Edited] (KAFKA-2477) Replicas spuriously deleting all segments in partition

[ https://issues.apache.org/jira/browse/KAFKA-2477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14715742#comment-14715742 ] Håkon Hitland edited comment on KAFKA-2477 at 8/26/15 11:38 PM:

Re: [DISCUSS] Client-side Assignment for New Consumer

Hi folks, After further discussion in LinkedIn, we found that while having a more general group management protocol is very useful, the vast majority of the clients will not use customized partition assignment strategy. In that case, the broker side partition assignment would be ideal because it a

[jira] [Assigned] (KAFKA-2065) Add ControlledShutdown to org.apache.kafka.common.requests and replace current use in core module

[ https://issues.apache.org/jira/browse/KAFKA-2065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-2065: -- Assignee: Ismael Juma (was: Ashish K Singh) > Add ControlledShutdown to org.apache.kafka.comm

[jira] [Commented] (KAFKA-2065) Add ControlledShutdown to org.apache.kafka.common.requests and replace current use in core module

[ https://issues.apache.org/jira/browse/KAFKA-2065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14715780#comment-14715780 ] Ismael Juma commented on KAFKA-2065: I've done this as part of KAFKA-2417, I hope you

[jira] [Comment Edited] (KAFKA-2065) Add ControlledShutdown to org.apache.kafka.common.requests and replace current use in core module

[ https://issues.apache.org/jira/browse/KAFKA-2065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14715780#comment-14715780 ] Ismael Juma edited comment on KAFKA-2065 at 8/27/15 12:04 AM: --

[jira] [Assigned] (KAFKA-2067) Add LeaderAndISR request/response to org.apache.kafka.common.requests and replace usage in core module

[ https://issues.apache.org/jira/browse/KAFKA-2067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-2067: -- Assignee: Ismael Juma > Add LeaderAndISR request/response to org.apache.kafka.common.requests a

[jira] [Commented] (KAFKA-2067) Add LeaderAndISR request/response to org.apache.kafka.common.requests and replace usage in core module

[ https://issues.apache.org/jira/browse/KAFKA-2067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14715785#comment-14715785 ] Ismael Juma commented on KAFKA-2067: Needed for KAFKA-2411 > Add LeaderAndISR request

[GitHub] kafka pull request: KAFKA-2388 [WIP]; refactor KafkaConsumer subsc...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/139 --- 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-2388) subscribe(topic)/unsubscribe(topic) should either take a callback to allow user to handle exceptions or it should be synchronous.

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

[jira] [Commented] (KAFKA-2388) subscribe(topic)/unsubscribe(topic) should either take a callback to allow user to handle exceptions or it should be synchronous.

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

[jira] [Commented] (KAFKA-2389) CommitType seems not necessary in commit().

[ https://issues.apache.org/jira/browse/KAFKA-2389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14715805#comment-14715805 ] Ewen Cheslack-Postava commented on KAFKA-2389: -- I'd also say that just becaus

[jira] [Commented] (KAFKA-2389) CommitType seems not necessary in commit().

[ https://issues.apache.org/jira/browse/KAFKA-2389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14715846#comment-14715846 ] Guozhang Wang commented on KAFKA-2389: -- Yeah, I did not think that Zookeeper API is t

[jira] [Updated] (KAFKA-2467) ConsoleConsumer regressions

[ https://issues.apache.org/jira/browse/KAFKA-2467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2467: - Status: Patch Available (was: Open) [~gwenshap] or [~guozhang] Can one of you rev

Build failed in Jenkins: Kafka-trunk #602

See Changes: [wangguoz] KAFKA-2388: refactor KafkaConsumer subscribe API -- [...truncated 1633 lines...] kafka.coordinator.ConsumerCoordinatorResponseTest > testHeartbeatIllegalGeneration PASSED kaf

[jira] [Commented] (KAFKA-2467) ConsoleConsumer regressions

[ https://issues.apache.org/jira/browse/KAFKA-2467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14715879#comment-14715879 ] Guozhang Wang commented on KAFKA-2467: -- I should be the guy apologizing here.. My ori

[GitHub] kafka pull request: KAFKA-2467: Fix changes to behavior in Console...

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

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

[jira] [Commented] (KAFKA-2467) ConsoleConsumer regressions

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

[jira] [Commented] (KAFKA-2466) ConsoleConsumer throws ConcurrentModificationException on termination

[ https://issues.apache.org/jira/browse/KAFKA-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14715889#comment-14715889 ] Guozhang Wang commented on KAFKA-2466: -- This is fixed as part of KAFKA-2466. > Conso

[jira] [Resolved] (KAFKA-2466) ConsoleConsumer throws ConcurrentModificationException on termination

[ https://issues.apache.org/jira/browse/KAFKA-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-2466. -- Resolution: Fixed Fix Version/s: 0.8.3 > ConsoleConsumer throws ConcurrentModificationExc

Build failed in Jenkins: Kafka-trunk #603

See Changes: [wangguoz] KAFKA-2467: Fix changes to behavior in ConsoleConsumer: properly parse consumer.config option, handle exceptions during message processing, and print number of processed messages to stderr.

Re: [DISCUSS] Client-side Assignment for New Consumer

Hey Becket, In that case, the broker side partition assignment would be ideal because > it avoids > issues like metadata inconsistency / split brain / exploding subscription > set propagation. As per our previous discussions regarding each of those concerns (referring to this email thread, KIP c

[jira] [Work started] (KAFKA-2072) Add StopReplica request/response to o.a.k.common.requests and replace the usage in core module

[ https://issues.apache.org/jira/browse/KAFKA-2072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2072 started by David Jacot. -- > Add StopReplica request/response to o.a.k.common.requests and replace the > usage

[jira] [Reopened] (KAFKA-2072) Add StopReplica request/response to o.a.k.common.requests and replace the usage in core module

[ https://issues.apache.org/jira/browse/KAFKA-2072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot reopened KAFKA-2072: Reopen this JIRA as https://github.com/apache/kafka/pull/170 adds StopReplica request/response to o.a.k