Jenkins build is back to normal : kafka-trunk-jdk10 #51

See

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

See Changes: [jason] MINOR: Refactor AdminClient ListConsumerGroups API (#4884) -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remo

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

See Changes: [jason] MINOR: Refactor AdminClient ListConsumerGroups API (#4884) -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remo

Re: [VOTE] KIP-277 - Fine Grained ACL for CreateTopics API

+1 On Thu., 26 Apr. 2018, 4:19 am Ted Yu, wrote: > +1 > > On Wed, Apr 25, 2018 at 3:24 PM, Guozhang Wang wrote: > > > Thanks Edo, +1 from me. > > > > > > Guozhang > > > > On Wed, Apr 25, 2018 at 2:45 AM, Edoardo Comar > wrote: > > > > > Hi, > > > > > > The discuss thread on KIP-277 ( > > > htt

Build failed in Jenkins: kafka-trunk-jdk10 #49

See Changes: [dolin] KAFKA-6795; Added unit tests for ReplicaAlterLogDirsThread -- [...truncated 1.48 MB...] kafka.server.epoch.LeaderEpochFileCacheTest > shouldNotResetEp

Write access required to Confluence wiki

I want to open a JIRA and a KIP. Can someone please grant me the necessary permissions? My username is *piyushvijay*. Thank you Piyush Vijay

Re: [VOTE] KIP-277 - Fine Grained ACL for CreateTopics API

+1 On Wed, Apr 25, 2018 at 3:24 PM, Guozhang Wang wrote: > Thanks Edo, +1 from me. > > > Guozhang > > On Wed, Apr 25, 2018 at 2:45 AM, Edoardo Comar wrote: > > > Hi, > > > > The discuss thread on KIP-277 ( > > https://www.mail-archive.com/dev@kafka.apache.org/msg86540.html ) > > seems to have b

Re: [DISCUSS] KIP-280: Enhanced log compaction

Luis, Just sharing my two cents here: we can extend the OffsetMap trait, making its "offset" type a generic template, and have a integer typed OffsetMap (for offset), and a long typed OffsetMap (for timestamp), and a byte array typed OffsetMap (record header fields). For the byte array typed offs

Re: [VOTE] KIP-277 - Fine Grained ACL for CreateTopics API

Thanks Edo, +1 from me. Guozhang On Wed, Apr 25, 2018 at 2:45 AM, Edoardo Comar wrote: > Hi, > > The discuss thread on KIP-277 ( > https://www.mail-archive.com/dev@kafka.apache.org/msg86540.html ) > seems to have been fruitful and concerns have been addressed, please allow > me start a vote on

Re: [VOTE] KIP-219 - Improve Quota Communication

Hello, Per Ismael's suggestion, I'd like to get comments from the original voters for KIP-219 (Becket, Jun, Rajini) and others about the new interface change proposed in the discussion thread ( https://markmail.org/search/?q=kafka+KIP-219#query:kafka%20KIP-219+page:1+mid:5rwju2gwpicojr3f+state:res

Re: [VOTE] KIP-219 - Improve Quota Communication

+Jon On Mon, 22 Jan 2018 at 10:38 AM Becket Qin wrote: > Thanks for the discussion and voting. > > KIP-219 has passed with +3 binding votes (Becket, Jun, Rajini). > > On Thu, Jan 18, 2018 at 1:32 AM, Rajini Sivaram > wrote: > > > Hi Becket, > > > > Thanks for the update. Yes, it does address my

Re: [DISCUSS] KIP-219 - Improve Quota Communication

Hi Ismael, I'll start a vote thread. Jon On Wed, Apr 25, 2018 at 2:28 PM, Dong Lin wrote: > + Jon > > On Tue, Apr 24, 2018 at 10:04 PM, Ismael Juma wrote: > >> Hi Jon, >> >> Not sure about this approach. It's worth mentioning this in the vote >> thread >> as well so that the people who voted

Re: [DISCUSS] KIP-219 - Improve Quota Communication

+ Jon On Tue, Apr 24, 2018 at 10:04 PM, Ismael Juma wrote: > Hi Jon, > > Not sure about this approach. It's worth mentioning this in the vote thread > as well so that the people who voted originally have a chance to comment. > Also, we should really get input from developers of Kafka clients > (

Re: [DISCUSSION] KIP-266: Add TimeoutException to KafkaConsumer#position()

Previously there are some debates on whether we should add this nonblocking behavior via a config v.s. via overloaded functions. To make progress on this discussion we need to first figure that part out. I'm in favor of the current approach of overloaded functions over the config since if we are go

Re: [DISCUSSION] KIP-266: Add TimeoutException to KafkaConsumer#position()

Hi Richard, I've updated the KIP with my proposed replacement methods for the poll use cases. Since I'm no longer proposing to alter poll(long) in place, I don't think it's necessary to ever through a ClientTimeoutException from poll(Duration). The new method, awaitAssignmentMetadata, however wou

Re: [DISCUSSION] KIP-266: Add TimeoutException to KafkaConsumer#position()

Re Ted's last comment, that style of async API requires some thread to actually drive the request/response cycle and invoke the callback when it's complete. Right now, this happens in the caller's thread as a side-effect of calling poll(). But that clearly won't work for poll() itself! In the futu

Re: [DISCUSS] KIP-285: Connect Rest Extension Plugin

Thanks Randall for your thoughts. I have created a replica of the required entities in the draft implementation. If you can take a look at the PR and let me know your thoughts, I will update the KIP to reflect the same https://github.com/apache/kafka/pull/4931 On Tue, Apr 24, 2018 at 11:44 AM, Ra

Re: [VOTE] KIP-282: Add the listener name to the authentication context

I've updated the KIP to simply expose the String value instead of the full ListenerName object. On Wed, Apr 25, 2018 at 8:10 PM, Mickael Maison wrote: > Thanks for the heads up Ismael. In that case, I also think it makes > sense to just use the String representation. > > I'll update the KIP to re

Re: [VOTE] KIP-282: Add the listener name to the authentication context

Thanks for the heads up Ismael. In that case, I also think it makes sense to just use the String representation. I'll update the KIP to reflect that change On Wed, Apr 25, 2018 at 7:25 PM, Rajini Sivaram wrote: > Sorry, I hadn't noticed that it was using `ListenerName`. I think we should > retur

Re: [VOTE] KIP-282: Add the listener name to the authentication context

Sorry, I hadn't noticed that it was using `ListenerName`. I think we should return just a String. On Wed, Apr 25, 2018 at 7:02 PM, Ismael Juma wrote: > ListenerName is in an internal package, so we would have to move it before > exposing it in a public API. > > Ismael > > On Wed, 25 Apr 2018, 01

Re: [VOTE] KIP-282: Add the listener name to the authentication context

ListenerName is in an internal package, so we would have to move it before exposing it in a public API. Ismael On Wed, 25 Apr 2018, 01:52 Mickael Maison, wrote: > Hi, > > There has been no objections in the DISCUSS thread so I'd like to > start a vote on KIP-282: > https://cwiki.apache.org/conf

Re: [VOTE] KIP-275 - Indicate "isClosing" in the SinkTaskContext

Bump! We're currently at 1 non-binding +1. Still soliciting votes here. =) On Wed, Apr 18, 2018 at 3:41 PM, Ted Yu wrote: > +1 > > On Wed, Apr 18, 2018 at 12:40 PM, Matt Farmer wrote: > > > Good afternoon/evening/morning all: > > > > I'd like to start voting on KIP-275: Indicate "isClosing" i

Re: Can I get permission to create KIP?

I have already added you to the permission granted list. Guozhang On Wed, Apr 25, 2018 at 9:16 AM, qingjun wu wrote: > Hi Dear, > > Can I get any update for the permission request? > > Thank you very much! > > Wade Wu > > On Mon, Apr 23, 2018 at 4:21 PM, qingjun wu wrote: > > > Hi Dear, > > >

Re: [VOTE] KIP-282: Add the listener name to the authentication context

+1 (non-binding) On Wed, Apr 25, 2018 at 9:05 PM, Ted Yu wrote: > +1 > > On Wed, Apr 25, 2018 at 8:33 AM, Rajini Sivaram > wrote: > > > Hi Mickael, > > > > Thanks for the KIP. > > > > +1 (binding) > > > > On Wed, Apr 25, 2018 at 9:51 AM, Mickael Maison < > mickael.mai...@gmail.com> > > wrote: >

Re: Can I get permission to create KIP?

Hi Dear, Can I get any update for the permission request? Thank you very much! Wade Wu On Mon, Apr 23, 2018 at 4:21 PM, qingjun wu wrote: > Hi Dear, > > I found something that Kafka should improve. Can I get permission for > this? I am working for Microsoft actually. If you need me to login a

Re: [VOTE] KIP-276 Add StreamsConfig prefix for different consumers

Thanks everyone! Looks like we got 3 binding +1 here. I will address the final reviews on the pull request and close it shortly. Best, Boyang From: John Roesler Sent: Wednesday, April 25, 2018 11:35 PM To: dev@kafka.apache.org; Damian Guy Subject: Re: [VOTE] K

[jira] [Created] (KAFKA-6827) Messages stuck after broker's multiple restart in a row

Yohan Sanchez created KAFKA-6827: Summary: Messages stuck after broker's multiple restart in a row Key: KAFKA-6827 URL: https://issues.apache.org/jira/browse/KAFKA-6827 Project: Kafka Issue T

Re: [VOTE] KIP-282: Add the listener name to the authentication context

+1 On Wed, Apr 25, 2018 at 8:33 AM, Rajini Sivaram wrote: > Hi Mickael, > > Thanks for the KIP. > > +1 (binding) > > On Wed, Apr 25, 2018 at 9:51 AM, Mickael Maison > wrote: > > > Hi, > > > > There has been no objections in the DISCUSS thread so I'd like to > > start a vote on KIP-282: > > http

Re: [VOTE] KIP-276 Add StreamsConfig prefix for different consumers

I'm +1 (non-binding). Thanks! On Wed, Apr 25, 2018 at 6:08 AM, Damian Guy wrote: > Thanks +1 > > On Fri, 20 Apr 2018 at 23:41 Bill Bejeck wrote: > > > +1 > > > > Thanks, > > Bill > > > > On Thu, Apr 19, 2018 at 9:50 AM, Boyang Chen > wrote: > > > > > Thanks guys！ > > > > > > Sent from my iPhon

Re: [VOTE] KIP-282: Add the listener name to the authentication context

Hi Mickael, Thanks for the KIP. +1 (binding) On Wed, Apr 25, 2018 at 9:51 AM, Mickael Maison wrote: > Hi, > > There has been no objections in the DISCUSS thread so I'd like to > start a vote on KIP-282: > https://cwiki.apache.org/confluence/display/KAFKA/KIP- > 282%3A+Add+the+listener+name+to+

Re: [VOTE] KIP-276 Add StreamsConfig prefix for different consumers

Thanks +1 On Fri, 20 Apr 2018 at 23:41 Bill Bejeck wrote: > +1 > > Thanks, > Bill > > On Thu, Apr 19, 2018 at 9:50 AM, Boyang Chen wrote: > > > Thanks guys！ > > > > Sent from my iPhone > > > > > On Apr 19, 2018, at 8:28 PM, Matthias J. Sax > > wrote: > > > > > > +1 (binding) > > > > > > -Matth

[DISCUSS] Apache Kafka 2.0.0 Release Plan

I would like to volunteer to be the release manager for our next time-based feature release (v2.0.0). See https://cwiki.apache.org/ confluence/display/KAFKA/Time+Based+Release+Plan if you missed previous communication on ti

[jira] [Created] (KAFKA-6826) Avoid range scans when forwarding values in window store aggregations

Xavier Léauté created KAFKA-6826: Summary: Avoid range scans when forwarding values in window store aggregations Key: KAFKA-6826 URL: https://issues.apache.org/jira/browse/KAFKA-6826 Project: Kafka

[VOTE] KIP-277 - Fine Grained ACL for CreateTopics API

Hi, The discuss thread on KIP-277 ( https://www.mail-archive.com/dev@kafka.apache.org/msg86540.html ) seems to have been fruitful and concerns have been addressed, please allow me start a vote on it: https://cwiki.apache.org/confluence/display/KAFKA/KIP-277+-+Fine+Grained+ACL+for+CreateTopics+

[jira] [Created] (KAFKA-6825) DEFAULT_PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG is private

Anna O created KAFKA-6825: - Summary: DEFAULT_PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG is private Key: KAFKA-6825 URL: https://issues.apache.org/jira/browse/KAFKA-6825 Project: Kafka Issue Type: Bug

[VOTE] KIP-282: Add the listener name to the authentication context

Hi, There has been no objections in the DISCUSS thread so I'd like to start a vote on KIP-282: https://cwiki.apache.org/confluence/display/KAFKA/KIP-282%3A+Add+the+listener+name+to+the+authentication+context Thanks

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

See