[GitHub] kafka pull request #2904: kafka-5901: ReassignPartitionsCommand should prote...

GitHub user amethystic opened a pull request: https://github.com/apache/kafka/pull/2904 kafka-5901: ReassignPartitionsCommand should protect against empty re… ReassignPartitionsCommand should protect against empty replica list assignment. You can merge this pull request into a Gi

[GitHub] kafka pull request #2898: kafka-5104: DumpLogSegments should not open index ...

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

[GitHub] kafka pull request #2905: kafka-5104: DumpLogSegments should not open index ...

GitHub user amethystic opened a pull request: https://github.com/apache/kafka/pull/2905 kafka-5104: DumpLogSegments should not open index files with `rw` Add a parameter 'writable' for AbstractIndex and set its default value to true for its children classes. You can merge this pull

Re: [GitHub] kafka pull request #2759: MINOR: Move `Os` class to utils package and rename...

How can I unsubscribe to these mails? Sent from my iPhone > On 23-Apr-2017, at 2:16 AM, asfgit wrote: > > Github user asfgit closed the pull request at: > >https://github.com/apache/kafka/pull/2759 > > > --- > If your project is set up for it, you can reply to this email and have your >

[jira] [Commented] (KAFKA-4592) Kafka Producer Metrics Invalid Value

[ https://issues.apache.org/jira/browse/KAFKA-4592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980818#comment-15980818 ] huxi commented on KAFKA-4592: - [~ijuma] What's the status for this jira after you said you nee

Re: [DISCUSS] KIP-138: Change punctuate semantics

Hi, I do like Damian's API proposal about the punctuation callback function. I also did reread the KIP and thought about the semantics we want to provide. > Given the above, I don't see a reason any more for a separate system-time > based punctuation. I disagree here. There are real-time appli

[jira] [Commented] (KAFKA-4295) kafka-console-consumer.sh does not delete the temporary group in zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-4295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980835#comment-15980835 ] huxi commented on KAFKA-4295: - [~ijuma] Are we going to continue to fix this issue since KIP

Re: [DISCUSS] KIP 141 - ProducerRecordBuilder Interface

Hey guys, I definitely think that the constructors could have been better designed, but I think given that they're in heavy use I don't think this proposal will improve things. Deprecating constructors just leaves everyone with lots of warnings and crossed out things. We can't actually delete the

Re: [jira] [Commented] (KAFKA-4295) kafka-console-consumer.sh does not delete the temporary group in zookeeper

How can I unsubscribe? Sent from my iPhone > On 24-Apr-2017, at 1:07 PM, huxi (JIRA) wrote: > > >[ > https://issues.apache.org/jira/browse/KAFKA-4295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980835#comment-15980835 > ] > > huxi commented

Re: Recording - Storm & Kafka Meetup on April 20th 2017

How about publishing this to Storm site? - Xin 2017-04-22 19:27 GMT+08:00 steve tueno : > great > > Thanks > > > > Cordialement, > > TUENO FOTSO Steve Jeffrey > Ingénieur de conception > Génie Informatique > +237 676 57 17 28 <+237%206%2076%2057%2017%2028> > +237 697 86 36 38 <+237%206%2097%208

Re: [DISCUSS] KIP-140: Add administrative RPCs for adding, deleting, and listing ACLs

Thanks Colin. A few quick comments: 1. Is there a reason why AddAclsRequest must be sent to the controller broker? When this was discussed previously, Jun suggested that such a restriction may not be necessary for this request. 2. Other protocol APIs use the Delete prefix instead of Remove. Is th

[jira] [Commented] (KAFKA-5110) ConsumerGroupCommand error handling improvement

[ https://issues.apache.org/jira/browse/KAFKA-5110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15981086#comment-15981086 ] Dustin Cote commented on KAFKA-5110: [~vahid] I'd love to provide reproduction steps,

the problems of parititons assigned to consumers

Hi, all. There are two problems when we use kafka about partitions assigned to consumers. Problem 1: Partitions will be reassigned to consumers when consumer online or offline, then the messages latency become higher. Problem 2: If we have two partitions, only two consumers can consume messages。H

how to assign JIRA issue to myself ?

Hi, I am added to JIRA contributor list, and how can I assign JIRA issue to myself ? Thank you :D Sincerely, James.C

Re: Recording - Storm & Kafka Meetup on April 20th 2017

Hello Everyone Can you please let us know when is the next meet up? It would be great if we can have in May. Regards Aditya Desai On Mon, Apr 24, 2017 at 2:16 AM, Xin Wang wrote: > How about publishing this to Storm site? > > - Xin > > 2017-04-22 19:27 GMT+08:00 steve tueno : > >> great >> >>

[jira] [Assigned] (KAFKA-4879) KafkaConsumer.position may hang forever when deleting a topic

[ https://issues.apache.org/jira/browse/KAFKA-4879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Armin Braun reassigned KAFKA-4879: -- Assignee: Armin Braun > KafkaConsumer.position may hang forever when deleting a topic > ---

[jira] [Created] (KAFKA-5116) Controller updates to ISR holds the controller lock for a very long time

Justin Downing created KAFKA-5116: - Summary: Controller updates to ISR holds the controller lock for a very long time Key: KAFKA-5116 URL: https://issues.apache.org/jira/browse/KAFKA-5116 Project: Kaf

[jira] [Commented] (KAFKA-5116) Controller updates to ISR holds the controller lock for a very long time

[ https://issues.apache.org/jira/browse/KAFKA-5116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15981382#comment-15981382 ] Ismael Juma commented on KAFKA-5116: cc [~onurkaraman] [~junrao] > Controller updates

Re: Recording - Storm & Kafka Meetup on April 20th 2017

Hi Aditya, Thanks for your interest. We entatively planning one in June 1st week. If you haven't already please register here https://www.meetup.com/Apache-Storm-Apache-Kafka/ . I'll keep the Storm lists updated once we finalize the date & location. Thanks, Harsha On Mon, Apr 24, 201

[jira] [Work started] (KAFKA-4994) Fix findbugs warning about OffsetStorageWriter#currentFlushId

[ https://issues.apache.org/jira/browse/KAFKA-4994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4994 started by Mariam John. -- > Fix findbugs warning about OffsetStorageWriter#currentFlushId > ---

[jira] [Work stopped] (KAFKA-4994) Fix findbugs warning about OffsetStorageWriter#currentFlushId

[ https://issues.apache.org/jira/browse/KAFKA-4994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4994 stopped by Mariam John. -- > Fix findbugs warning about OffsetStorageWriter#currentFlushId > ---

Re: [DISCUSS] KIP 141 - ProducerRecordBuilder Interface

Hey Jay, I understand your concern, and for sure, we will need to keep the current constructors deprecated for a long time (ie, many years). But if we don't make the move, we will not be able to improve. And I think warnings about using deprecated APIs is an acceptable price to pay. And the API i

Re: [GitHub] kafka pull request #2759: MINOR: Move `Os` class to utils package and rename...

You can't... :( But you can filter them: https://mail.google.com/mail/u/0/?tab=wm#settings/filters Just specify from "g...@git.apache.org" and to "dev@kafka.apache.org" and apply actions you want to take. -Matthias On 4/24/17 12:29 AM, Arisha C wrote: > How can I unsubscribe to these mails? >

Re: [jira] [Commented] (KAFKA-4295) kafka-console-consumer.sh does not delete the temporary group in zookeeper

You can't... But you can filter them: https://mail.google.com/mail/u/0/?tab=wm#settings/filters Just specify from "j...@apache.org" and to "dev@kafka.apache.org" and apply actions you want to take. -Matthias On 4/24/17 1:52 AM, Arisha C wrote: > How can I unsubscribe? > > Sent from my iPhone

[jira] [Assigned] (KAFKA-3940) Log should check the return value of dir.mkdirs()

[ https://issues.apache.org/jira/browse/KAFKA-3940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison reassigned KAFKA-3940: - Assignee: Mickael Maison > Log should check the return value of dir.mkdirs() > --

[GitHub] kafka pull request #2745: MINOR: Replication system tests should cover compr...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2745 --- 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] [Assigned] (KAFKA-3940) Log should check the return value of dir.mkdirs()

[ https://issues.apache.org/jira/browse/KAFKA-3940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-3940: -- Assignee: Colin P. McCabe (was: Mickael Maison) > Log should check the return value of dir.mkd

[jira] [Resolved] (KAFKA-3940) Log should check the return value of dir.mkdirs()

[ https://issues.apache.org/jira/browse/KAFKA-3940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-3940. Resolution: Fixed Fix Version/s: 0.11.0.0 This was fixed as part of the findBugs fixes. > Lo

Re: [DISCUSS] KIP-138: Change punctuate semantics

I agree with this. We would need to allow processor level configuration. And I also agree, that the global caching config is not optimal... -Matthias On 4/24/17 3:55 AM, Michal Borowiecki wrote: > Further to this, on your point about configuration: > >> Thus, I also believe that one might need

Re: [VOTE] KIP 130: Expose states of active tasks to KafkaStreams public API

Florian, could you also add the part of deprecating `KafkaStreams.toString` in your KIP as well? Guozhang On Fri, Apr 21, 2017 at 8:32 AM, Damian Guy wrote: > +1 > > On Fri, 21 Apr 2017 at 09:06 Eno Thereska wrote: > > > +1 (non-binding) > > > > Thanks > > Eno > > > > > On 21 Apr 2017, at 05:

Re: [DISCUSS] KIP-138: Change punctuate semantics

A simple example would be some dashboard app, that needs to get "current" status in regular time intervals (ie, and real-time app). Or something like a "scheduler" -- think "cron job" application. -Matthias On 4/24/17 2:23 AM, Michal Borowiecki wrote: > Hi Matthias, > > I agree it's difficult

Re: [DISCUSS] KIP 141 - ProducerRecordBuilder Interface

Why not simply make a cleaner client fluent API wrapper? The internals use and send via current api, but provide a cleaner more fluent api. A good example here is HTTP compontents where they did this. https://hc.apache.org/httpcomponents-client-ga/tutorial/html/fluent.html On 24/04/2017, 17:4

[GitHub] kafka pull request #2867: KAFKA-4755: Cherrypick streams tests from trunk

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

[jira] [Commented] (KAFKA-4755) SimpleBenchmark test fails for streams

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

Re: Recording - Storm & Kafka Meetup on April 20th 2017

Hi Harsha and others Really thanks a lot for this meetup. I have signed up and will surely attend it from June. I am really new to Apache Storm and Apache Kafka. I am still learning them and these meetups will definitely help people like me. If you have any of you have some good resources/tutorial

Re: [DISCUSS] KIP-138: Change punctuate semantics

>> Would a dashboard need perfect regularity? Wouldn't an upper bound suffice? If you go with stream-time and don't have any input records for all partitions, punctuate would not be called at all, and thus your dashboard would "freeze". >> I thought about cron-type things, but aren't they better

[jira] [Created] (KAFKA-5117) Kafka Connect REST endpoints reveal Password typed values

Thomas Holmes created KAFKA-5117: Summary: Kafka Connect REST endpoints reveal Password typed values Key: KAFKA-5117 URL: https://issues.apache.org/jira/browse/KAFKA-5117 Project: Kafka Issue

[jira] [Updated] (KAFKA-5117) Kafka Connect REST endpoints reveal Password typed values

[ https://issues.apache.org/jira/browse/KAFKA-5117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Holmes updated KAFKA-5117: - Description: A Kafka Connect connector can specify ConfigDef keys as type of Password. This type

Re: [DISCUSS] KIP-140: Add administrative RPCs for adding, deleting, and listing ACLs

Thanks for taking a look, Ismael. On Mon, Apr 24, 2017, at 04:36, Ismael Juma wrote: > Thanks Colin. A few quick comments: > > 1. Is there a reason why AddAclsRequest must be sent to the controller > broker? When this was discussed previously, Jun suggested that such a > restriction may not be ne

[jira] [Commented] (KAFKA-5110) ConsumerGroupCommand error handling improvement

[ https://issues.apache.org/jira/browse/KAFKA-5110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15981652#comment-15981652 ] Vahid Hashemian commented on KAFKA-5110: [~cotedm] Thanks for your response. Yes,

[jira] [Assigned] (KAFKA-5055) Kafka Streams skipped-records-rate sensor producing nonzero values even when FailOnInvalidTimestamp is used as extractor

[ https://issues.apache.org/jira/browse/KAFKA-5055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5055: Assignee: Guozhang Wang > Kafka Streams skipped-records-rate sensor producing nonzero value

[jira] [Commented] (KAFKA-5055) Kafka Streams skipped-records-rate sensor producing nonzero values even when FailOnInvalidTimestamp is used as extractor

[ https://issues.apache.org/jira/browse/KAFKA-5055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15981662#comment-15981662 ] Guozhang Wang commented on KAFKA-5055: -- Thanks [~nthean], looking into it now. > Kaf

Re: [VOTE] KIP-123: Allow per stream/table timestamp extractor

+1. Thanks for the KIP! On Tue, Feb 28, 2017 at 12:59 AM, Jeyhun Karimov wrote: > Dear community, > > I'd like to start the vote for KIP-123: > https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=68714788 > > > Cheers, > Jeyhun > -- > -Cheers > > Jeyhun > -- *Gwen Shapira* Produ

Re: [VOTE] KIP-123: Allow per stream/table timestamp extractor

+1 (non-binding) On Tue, 2017-02-28 at 08:59 +, Jeyhun Karimov wrote: > Dear community, > > I'd like to start the vote for KIP-123: > https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=6871 > 4788 > > > Cheers, > Jeyhun -- Tommy Becker Senior Software Engineer O +

[jira] [Created] (KAFKA-5118) Improve message for Kafka failed startup with non-Kafka data in data.dirs

Dustin Cote created KAFKA-5118: -- Summary: Improve message for Kafka failed startup with non-Kafka data in data.dirs Key: KAFKA-5118 URL: https://issues.apache.org/jira/browse/KAFKA-5118 Project: Kafka

[GitHub] kafka pull request #2906: Kafka-4994 Fix findbug warnings about OffsetStorag...

GitHub user johnma14 opened a pull request: https://github.com/apache/kafka/pull/2906 Kafka-4994 Fix findbug warnings about OffsetStorageWriter#currentFlushId Based on the description of the class OffsetStorageWriter, it is not a thread-safe class and should be accessed only from a

[jira] [Work started] (KAFKA-4994) Fix findbugs warning about OffsetStorageWriter#currentFlushId

[ https://issues.apache.org/jira/browse/KAFKA-4994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4994 started by Mariam John. -- > Fix findbugs warning about OffsetStorageWriter#currentFlushId > ---

[jira] [Updated] (KAFKA-4994) Fix findbugs warning about OffsetStorageWriter#currentFlushId

[ https://issues.apache.org/jira/browse/KAFKA-4994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John updated KAFKA-4994: --- Reviewer: Colin P. McCabe Status: Patch Available (was: In Progress) > Fix findbugs warning abo

[jira] [Created] (KAFKA-5119) Transient test failure SocketServerTest.testMetricCollectionAfterShutdown

Jason Gustafson created KAFKA-5119: -- Summary: Transient test failure SocketServerTest.testMetricCollectionAfterShutdown Key: KAFKA-5119 URL: https://issues.apache.org/jira/browse/KAFKA-5119 Project:

[ANNOUNCE] New committer: Rajini Sivaram

The PMC for Apache Kafka has invited Rajini Sivaram as a committer and we are pleased to announce that she has accepted! Rajini contributed 83 patches, 8 KIPs (all security and quota improvements) and a significant number of reviews. She is also on the conference committee for Kafka Summit, where

Re: [ANNOUNCE] New committer: Rajini Sivaram

Great news. Congrats Rajini! --Vahid From: Gwen Shapira To: dev@kafka.apache.org, Users , priv...@kafka.apache.org Date: 04/24/2017 02:06 PM Subject:[ANNOUNCE] New committer: Rajini Sivaram The PMC for Apache Kafka has invited Rajini Sivaram as a committer and we are plea

Re: [ANNOUNCE] New committer: Rajini Sivaram

Congrats Rajini! On Mon, Apr 24, 2017 at 2:06 PM, Gwen Shapira wrote: > The PMC for Apache Kafka has invited Rajini Sivaram as a committer and we > are pleased to announce that she has accepted! > > Rajini contributed 83 patches, 8 KIPs (all security and quota > improvements) and a significant n

[jira] [Assigned] (KAFKA-3266) List/Alter Acls - protocol and server side implementation

[ https://issues.apache.org/jira/browse/KAFKA-3266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe reassigned KAFKA-3266: -- Assignee: Colin P. McCabe (was: Grant Henke) > List/Alter Acls - protocol and server s

[jira] [Updated] (KAFKA-3266) Implement KIP-4 RPCs and APIs for creating, altering, and listing ACLs

[ https://issues.apache.org/jira/browse/KAFKA-3266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-3266: --- Summary: Implement KIP-4 RPCs and APIs for creating, altering, and listing ACLs (was: List/Al

[jira] [Commented] (KAFKA-4593) Task migration during rebalance callback process could lead the obsoleted task's IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-4593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15981970#comment-15981970 ] Matthias J. Sax commented on KAFKA-4593: This JIRA seems to relate to this one: h

Re: [ANNOUNCE] New committer: Rajini Sivaram

Congrats Rajini! Well-deserved. :) Ismael On Mon, Apr 24, 2017 at 10:06 PM, Gwen Shapira wrote: > The PMC for Apache Kafka has invited Rajini Sivaram as a committer and we > are pleased to announce that she has accepted! > > Rajini contributed 83 patches, 8 KIPs (all security and quota > improv

Jenkins build is back to normal : kafka-0.10.2-jdk7 #150

See

Re: [ANNOUNCE] New committer: Rajini Sivaram

Congratulations, Rajini! On Mon, Apr 24, 2017 at 11:50 PM, Ismael Juma wrote: > Congrats Rajini! Well-deserved. :) > > Ismael > > On Mon, Apr 24, 2017 at 10:06 PM, Gwen Shapira wrote: > > > The PMC for Apache Kafka has invited Rajini Sivaram as a committer and we > > are pleased to announce tha

Re: [ANNOUNCE] New committer: Rajini Sivaram

Congratulations, Rajini ! Thanks for all your contributions. Jun On Mon, Apr 24, 2017 at 2:06 PM, Gwen Shapira wrote: > The PMC for Apache Kafka has invited Rajini Sivaram as a committer and we > are pleased to announce that she has accepted! > > Rajini contributed 83 patches, 8 KIPs (all secur

Re: [ANNOUNCE] New committer: Rajini Sivaram

Woohoo! Great work, Rajini! On Mon, Apr 24, 2017 at 3:27 PM, Jun Rao wrote: > Congratulations, Rajini ! Thanks for all your contributions. > > Jun > > On Mon, Apr 24, 2017 at 2:06 PM, Gwen Shapira wrote: > > > The PMC for Apache Kafka has invited Rajini Sivaram as a committer and we > > are ple

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

See

[jira] [Commented] (KAFKA-5118) Improve message for Kafka failed startup with non-Kafka data in data.dirs

[ https://issues.apache.org/jira/browse/KAFKA-5118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15982092#comment-15982092 ] huxi commented on KAFKA-5118: - I remember 0.10.2.0 checks whether the directory name contains

[jira] [Created] (KAFKA-5120) Several controller metrics block if controller lock is held by another thread

Tim Carey-Smith created KAFKA-5120: -- Summary: Several controller metrics block if controller lock is held by another thread Key: KAFKA-5120 URL: https://issues.apache.org/jira/browse/KAFKA-5120 Proje

[jira] [Commented] (KAFKA-5120) Several controller metrics block if controller lock is held by another thread

[ https://issues.apache.org/jira/browse/KAFKA-5120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15982118#comment-15982118 ] Onur Karaman commented on KAFKA-5120: - This will be fixed in KAFKA-5028. It chooses th

Re: [ANNOUNCE] New committer: Rajini Sivaram

Congratulations! Rajini! Great work! On Mon, Apr 24, 2017 at 3:33 PM, Jason Gustafson wrote: > Woohoo! Great work, Rajini! > > On Mon, Apr 24, 2017 at 3:27 PM, Jun Rao wrote: > > > Congratulations, Rajini ! Thanks for all your contributions. > > > > Jun > > > > On Mon, Apr 24, 2017 at 2:06 PM,

Re: [ANNOUNCE] New committer: Rajini Sivaram

Congratulations Rajini! On Mon, Apr 24, 2017 at 4:52 PM, Becket Qin wrote: > Congratulations! Rajini! Great work! > > On Mon, Apr 24, 2017 at 3:33 PM, Jason Gustafson > wrote: > > > Woohoo! Great work, Rajini! > > > > On Mon, Apr 24, 2017 at 3:27 PM, Jun Rao wrote: > > > > > Congratulations, R

Re: [ANNOUNCE] New committer: Rajini Sivaram

Congratulations Rajini! On Mon, Apr 24, 2017 at 2:06 PM, Gwen Shapira wrote: > The PMC for Apache Kafka has invited Rajini Sivaram as a committer and we > are pleased to announce that she has accepted! > > Rajini contributed 83 patches, 8 KIPs (all security and quota > improvements) and a signif

[jira] [Commented] (KAFKA-5118) Improve message for Kafka failed startup with non-Kafka data in data.dirs

[ https://issues.apache.org/jira/browse/KAFKA-5118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15982148#comment-15982148 ] Dustin Cote commented on KAFKA-5118: @huxi yes this is where this one came from. Direc

[jira] [Commented] (KAFKA-5118) Improve message for Kafka failed startup with non-Kafka data in data.dirs

[ https://issues.apache.org/jira/browse/KAFKA-5118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15982151#comment-15982151 ] Dustin Cote commented on KAFKA-5118: [~huxi] ^ > Improve message for Kafka failed sta

[jira] [Comment Edited] (KAFKA-5118) Improve message for Kafka failed startup with non-Kafka data in data.dirs

[ https://issues.apache.org/jira/browse/KAFKA-5118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15982092#comment-15982092 ] huxi edited comment on KAFKA-5118 at 4/25/17 1:12 AM: -- I remember 0.1

Re: Recording - Storm & Kafka Meetup on April 20th 2017

Hi, In the comments section of the Meetup page you can find links for all the slides. https://www.meetup.com/Apache-Storm-Apache-Kafka/events/238975416/ Thank you for your interest. Hugo On Apr 24, 2017, at 10:19 AM, Aditya Desai mailto:adity...@usc.edu>> wrote: Hi Harsha and others Really

[jira] [Created] (KAFKA-5121) Implement transaction index for KIP-98

Jason Gustafson created KAFKA-5121: -- Summary: Implement transaction index for KIP-98 Key: KAFKA-5121 URL: https://issues.apache.org/jira/browse/KAFKA-5121 Project: Kafka Issue Type: Sub-task

[jira] [Assigned] (KAFKA-5065) AbstractCoordinator.ensureCoordinatorReady() stuck in loop if absent any bootstrap servers

[ https://issues.apache.org/jira/browse/KAFKA-5065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] james chien reassigned KAFKA-5065: -- Assignee: james chien we should not replace Long.MAX_VALUE for custom setting, but should make

[jira] [Comment Edited] (KAFKA-5065) AbstractCoordinator.ensureCoordinatorReady() stuck in loop if absent any bootstrap servers

[ https://issues.apache.org/jira/browse/KAFKA-5065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15982296#comment-15982296 ] james chien edited comment on KAFKA-5065 at 4/25/17 2:39 AM: -

[jira] [Comment Edited] (KAFKA-5065) AbstractCoordinator.ensureCoordinatorReady() stuck in loop if absent any bootstrap servers

[ https://issues.apache.org/jira/browse/KAFKA-5065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980629#comment-15980629 ] james chien edited comment on KAFKA-5065 at 4/25/17 2:40 AM: -

[GitHub] kafka pull request #2907: kafka-5118: Improve message for Kafka failed start...

GitHub user amethystic opened a pull request: https://github.com/apache/kafka/pull/2907 kafka-5118: Improve message for Kafka failed startup with non-Kafka data in data.dirs Explicitly throwing clear exceptions when starting up a Kafka with some non-Kafka data in data.dirs. You ca

[jira] [Assigned] (KAFKA-5118) Improve message for Kafka failed startup with non-Kafka data in data.dirs

[ https://issues.apache.org/jira/browse/KAFKA-5118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxi reassigned KAFKA-5118: --- Assignee: huxi > Improve message for Kafka failed startup with non-Kafka data in data.dirs >

[jira] [Commented] (KAFKA-5070) org.apache.kafka.streams.errors.LockException: task [0_18] Failed to lock the state directory: /opt/rocksdb/pulse10/0_18

[ https://issues.apache.org/jira/browse/KAFKA-5070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15982356#comment-15982356 ] Shoyeb Pathan commented on KAFKA-5070: -- Thanks for responding [~mjsax], we will test

[GitHub] kafka pull request #2908: KAFKA-4379 Followup: Remove eviction listener from...

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/2908 KAFKA-4379 Followup: Remove eviction listener from InMemoryLRUCache You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka K437

[jira] [Commented] (KAFKA-4379) Remove caching of dirty and removed keys from StoreChangeLogger

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

[jira] [Commented] (KAFKA-4879) KafkaConsumer.position may hang forever when deleting a topic

[ https://issues.apache.org/jira/browse/KAFKA-4879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15982386#comment-15982386 ] Guozhang Wang commented on KAFKA-4879: -- [~huxi_2b] adding the timeout in these intern

[GitHub] kafka pull request #2909: MINOR: adding global store must ensure unique name...

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/2909 MINOR: adding global store must ensure unique names You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/kafka minor-fix-add-global-store Altern

[GitHub] kafka pull request #2910: KAFKA-5121 [WIP]: Implement transaction index for ...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2910 KAFKA-5121 [WIP]: Implement transaction index for KIP-98 You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka eos-txn-index Altern

[jira] [Commented] (KAFKA-5121) Implement transaction index for KIP-98

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