[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

[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

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

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.

[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

[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] [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] [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)

[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] [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

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] [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

[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] [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-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] [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

[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] [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

[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] [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] [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] [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

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] [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:

[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] [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

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: Summary: OffsetOutOfRangeException should contain the Offset and Partition info. (was: Seek() shoul

[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] [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] [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-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

[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] [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: -

[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-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-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] [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-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

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-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

[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-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

[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-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

[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

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] [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/#review96095 --- Can you rebase? clients/src/main/java/org/apache/kafka/clients/InF

[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: --

[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] [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=14715394#comment-14715394 ] James Cheng commented on KAFKA-1977: Ping [~gwenshap]. Do you think logEndOffset can/s

[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-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

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-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

[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:

[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

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

[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: 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] [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 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] [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

[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=14713445#comment-14713445 ] Navjot commented on KAFKA-1690: --- [~harsha_ch] Finally I got some luck with Testing SSL Enabl

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)

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

[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

[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] [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-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 > -