Re: [ANNOUNCE] New Committer: Bill Bejeck

Congratulations Bill! On Thursday, February 14, 2019, Konstantine Karantasis < konstant...@confluent.io> wrote: > Congrats Bill! > > -Konstantine > > On Wed, Feb 13, 2019 at 8:42 PM Srinivas Reddy > wrote: > >> Congratulations Bill  >> >> Well deserved!! >> >> - >> Srinivas >> >> - Typed on

Re: [DISCUSS] KIP-428: Add in-memory window store

Hi Sophie, Thanks for the KIP write-up, I made a pass over the wiki and the PR as well, here's some comments: 1. the proposed API seems to be inconsistent from the PR, should it be: public static WindowBytesStoreSupplier inMemoryWindowStore(final String name, final

Re: [VOTE] 2.1.1 RC2

+1 (Validated signatures, unit tests, quickstart) Thanks, Colin, for managing the bugfix release. On Fri, Feb 8, 2019 at 12:02 PM Colin McCabe wrote: > > Hi all, > > This is the third candidate for release of Apache Kafka 2.1.1. This release > includes many bug fixes for Apache Kafka 2.1. > >

Re: [ANNOUNCE] New Committer: Bill Bejeck

Congrats Bill! -Konstantine On Wed, Feb 13, 2019 at 8:42 PM Srinivas Reddy wrote: > Congratulations Bill  > > Well deserved!! > > - > Srinivas > > - Typed on tiny keys. pls ignore typos.{mobile app} > > On Thu, 14 Feb, 2019, 11:21 Ismael Juma > > Congratulations Bill! > > > > On Wed, Feb

Re: [ANNOUNCE] New Committer: Bill Bejeck

Congratulations Bill  Well deserved!! - Srinivas - Typed on tiny keys. pls ignore typos.{mobile app} On Thu, 14 Feb, 2019, 11:21 Ismael Juma Congratulations Bill! > > On Wed, Feb 13, 2019, 5:03 PM Guozhang Wang > > Hello all, > > > > The PMC of Apache Kafka is happy to announce that we've

Re: [ANNOUNCE] New Committer: Bill Bejeck

Congratulations Bill! On Wed, Feb 13, 2019, 5:03 PM Guozhang Wang Hello all, > > The PMC of Apache Kafka is happy to announce that we've added Bill Bejeck > as our newest project committer. > > Bill has been active in the Kafka community since 2015. He has made > significant contributions to the

Re: [ANNOUNCE] New Committer: Bill Bejeck

Congratulations Bill! On Wed, 13 Feb 2019 at 16:51, Satish Duggana wrote: > Congratulations Bill! > > On Thu, Feb 14, 2019 at 6:41 AM Marcelo Barbosa > wrote: > > > > Wow! Congrats Bill! > > Cheers, > > Barbosa > > Em quarta-feira, 13 de fevereiro de 2019 23:03:54 BRST, Guozhang > Wang

Re: [ANNOUNCE] New Committer: Bill Bejeck

Congratulations Bill! On Thu, Feb 14, 2019 at 6:41 AM Marcelo Barbosa wrote: > > Wow! Congrats Bill! > Cheers, > Barbosa > Em quarta-feira, 13 de fevereiro de 2019 23:03:54 BRST, Guozhang Wang > escreveu: > > Hello all, > > The PMC of Apache Kafka is happy to announce that we've added

Build failed in Jenkins: kafka-2.2-jdk8 #13

See Changes: [wangguoz] KAFKA-7921: log at error level for missing source topic (#6262) -- [...truncated 2.59 MB...] kafka.controller.PartitionStateMachineTest >

[jira] [Created] (KAFKA-7931) Java Client: if all ephemeral brokers fail, client can never reconnect to brokers

Brian created KAFKA-7931: Summary: Java Client: if all ephemeral brokers fail, client can never reconnect to brokers Key: KAFKA-7931 URL: https://issues.apache.org/jira/browse/KAFKA-7931 Project: Kafka

Re: [ANNOUNCE] New Committer: Bill Bejeck

Congrats! Well deserved! -Matthias On 2/13/19 4:56 PM, Guozhang Wang wrote: > Hello all, > > The PMC of Apache Kafka is happy to announce that we've added Bill Bejeck > as our newest project committer. > > Bill has been active in the Kafka community since 2015. He has made > significant

Re: Questions regarding KAFKA-6460

Sure! On Wed, Feb 13, 2019 at 9:52 AM Yishun Guan wrote: > Hi Guozhang, > > I have been looking at KAFKA-6460 > (https://issues.apache.org/jira/browse/KAFKA-6460?filter=-1) and have > a few questions, would you take a look at the comment when you have > time? Thank you so much! > > Best, >

Re: [ANNOUNCE] New Committer: Bill Bejeck

Wow! Congrats Bill!  Cheers, Barbosa Em quarta-feira, 13 de fevereiro de 2019 23:03:54 BRST, Guozhang Wang escreveu: Hello all, The PMC of Apache Kafka is happy to announce that we've added Bill Bejeck as our newest project committer. Bill has been active in the Kafka community since

Re: [ANNOUNCE] New Committer: Bill Bejeck

Congratulations Bill! On Wed, Feb 13, 2019 at 5:09 PM Matthias J. Sax wrote: > Congrats! Well deserved! > > -Matthias > > On 2/13/19 4:56 PM, Guozhang Wang wrote: > > Hello all, > > > > The PMC of Apache Kafka is happy to announce that we've added Bill Bejeck > > as our newest project

[ANNOUNCE] New Committer: Bill Bejeck

Hello all, The PMC of Apache Kafka is happy to announce that we've added Bill Bejeck as our newest project committer. Bill has been active in the Kafka community since 2015. He has made significant contributions to the Kafka Streams project with more than 100 PRs and 4 authored KIPs, including

[jira] [Created] (KAFKA-7930) StreamsResetter makes "changelog" topic naming assumptions

Murad M created KAFKA-7930: -- Summary: StreamsResetter makes "changelog" topic naming assumptions Key: KAFKA-7930 URL: https://issues.apache.org/jira/browse/KAFKA-7930 Project: Kafka Issue Type:

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

See Changes: [wangguoz] KAFKA-7921: log at error level for missing source topic (#6262) -- [...truncated 2.31 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

[jira] [Created] (KAFKA-7929) RocksDB Window Store allows segments to expire out from under iterator

Sophie Blee-Goldman created KAFKA-7929: -- Summary: RocksDB Window Store allows segments to expire out from under iterator Key: KAFKA-7929 URL: https://issues.apache.org/jira/browse/KAFKA-7929

[jira] [Created] (KAFKA-7928) Deprecate WindowStore.put(key, value)

John Roesler created KAFKA-7928: --- Summary: Deprecate WindowStore.put(key, value) Key: KAFKA-7928 URL: https://issues.apache.org/jira/browse/KAFKA-7928 Project: Kafka Issue Type: Improvement

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

See Changes: [jason] KAFKA-7440; Add leader epoch to fetch and list-offset request (#6190) -- [...truncated 4.84 MB...] org.apache.kafka.streams.test.OutputVerifierTest

[jira] [Resolved] (KAFKA-7917) Streams store cleanup: collapse layers

[ https://issues.apache.org/jira/browse/KAFKA-7917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-7917. - Resolution: Won't Fix > Streams store cleanup: collapse layers >

Re: [DISCUSS] Kafka 2.2.0 in February 2018

@Srinivas: Thanks for pointing out. Missed it, because the KIP wiki page was not updated correctly. The KIP was still listed in table "Under discussion" instead of "Adopted". (I updated the KIP and Release Plan wiki pages accordingly). @Ismael: Thanks! We also got one more blocker ticket: -

Re: [DISCUSSION] KIP-422: Add support for user/client configuration in the Kafka Admin Client

Hi, Yaodong, Thanks for the KIP. As Stan mentioned earlier, it seems that this is mostly covered by KIP-248, which was originally proposed by Victor. Hi, Victor, Do you still plan to work on KIP-248? It seems that you already got pretty far on that. If not, would you mind letting Yaodong take

Questions regarding KAFKA-6460

Hi Guozhang, I have been looking at KAFKA-6460 (https://issues.apache.org/jira/browse/KAFKA-6460?filter=-1) and have a few questions, would you take a look at the comment when you have time? Thank you so much! Best, Yishun

Re: [DISCUSS] KIP-430 - Return Authorized Operations in Describe Responses

Hi Rajini, That makes sense, thanks for the clarification. Satish. On Wed, Feb 13, 2019 at 7:30 PM Rajini Sivaram wrote: > > Thanks for the reviews! > > Hi Satish, > > The authorised operations returned will use the same values as the > operations returned by the existing DescribeAclsResponse.

Re: [DISCUSS] KIP-430 - Return Authorized Operations in Describe Responses

Thanks for the reviews! Hi Satish, The authorised operations returned will use the same values as the operations returned by the existing DescribeAclsResponse. AdminClient will return these using the existing enum AclOperation. Hi Magnus, The MetadataResponse contains these two lines: -

[jira] [Created] (KAFKA-7927) Read committed receives aborted events

Gabor Somogyi created KAFKA-7927: Summary: Read committed receives aborted events Key: KAFKA-7927 URL: https://issues.apache.org/jira/browse/KAFKA-7927 Project: Kafka Issue Type: Bug

Build failed in Jenkins: kafka-2.2-jdk8 #12

See Changes: [wangguoz] KAFKA-7652: Part III; Put to underlying before Flush (#6191) -- [...truncated 1.42 MB...] kafka.controller.PartitionLeaderElectionAlgorithmsTest >

Jenkins build is back to normal : kafka-trunk-jdk11 #281

See

Re: [DISCUSS] KIP-430 - Return Authorized Operations in Describe Responses

Hi, Thanks for the KIP. 1. Can't we include IdempotentWrite/ClusterResource Operations for Cluster resource. 2. What will be the API behaviour when the authorizer is not configured?. I assume we return empty list. Thanks, Manikumar On Wed, Feb 13, 2019 at 12:33 AM Rajini Sivaram wrote: > Hi

Re: [DISCUSS] KIP-430 - Return Authorized Operations in Describe Responses

Hey Rajini, good work on the KIP! I'm personally not thrilled with piggy-backing the authorized_operations on existing APIs, it seems like a mix of concerns. Since there is already the notion of generic ResourceType,ResourceName tuples in the Admin API, I believe it would make more sense to add

Re: [DISCUSS] KIP-430 - Return Authorized Operations in Describe Responses

Hi Rajini, Thanks for the KIP. KIP proposes to add a new field called `authorized_operations` which is an array of Byte values. I guess these are APIKeys#id for respective operations. Do you plan to have an array of ids or an array of respective ApiKeys enum values in

[jira] [Created] (KAFKA-7926) Issue with Kafka Broker - UnknownServerException

Santosh S created KAFKA-7926: Summary: Issue with Kafka Broker - UnknownServerException Key: KAFKA-7926 URL: https://issues.apache.org/jira/browse/KAFKA-7926 Project: Kafka Issue Type: Bug

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

See Changes: [manikumar] MINOR: fix docs of common per-broker metrics [github] KAFKA-7652: Part III; Put to underlying before Flush (#6191) -- [...truncated 2.31 MB...]

Build failed in Jenkins: kafka-trunk-jdk11 #280

See Changes: [manikumar] MINOR: fix docs of common per-broker metrics -- [...truncated 2.31 MB...] org.apache.kafka.connect.transforms.CastTest >

[jira] [Created] (KAFKA-7925) Constant 100% cpu usage by all kafka brokers

Abhi created KAFKA-7925: --- Summary: Constant 100% cpu usage by all kafka brokers Key: KAFKA-7925 URL: https://issues.apache.org/jira/browse/KAFKA-7925 Project: Kafka Issue Type: Bug