Re: [DISCUSS] KIP-377: TopicCommand to use AdminClient

Hi Viktor, Sounds good. If you want to propose a way of improving the metadata protocol so that "[deleted]" could be supported, you could probably create that KIP in parallel. The last KIP in that area that I can remember is KIP-142, which didn't get adopted (yet?) https://cwiki.apache.org/c

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

See Changes: [ismael] MINOR: Less restrictive assertion in flaky BufferPool test (#5799) -- [...truncated 2.83 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

Build failed in Jenkins: kafka-2.0-jdk8 #169

See Changes: [ismael] MINOR: Less restrictive assertion in flaky BufferPool test (#5799) -- [...truncated 885.74 KB...] kafka.controller.PartitionStateMachineTest > testInv

Re: [VOTE] KIP-369 Alternative Partitioner to Support "Always Round-Robin" Selection

Thanks for the KIP. Can you please elaborate on the need for the key in this case? The KIP simply states that the key is needed for metadata, but doesn't give any more details. Ismael On Tue, Sep 4, 2018 at 3:39 AM M. Manna wrote: > Hello, > > I have made necessary changes as per the original d

Re: [VOTE] KIP-369 Alternative Partitioner to Support "Always Round-Robin" Selection

Having Round-robin partitioner as default makes sense. +1 (binding). Thanks, Harsha On Oct 19, 2018, 9:54 AM -0700, Matthias J. Sax , wrote: > People a currently quite busy with 2.1.0 and 2.0.1 releases. That's why > the vote might go slow. > > Just keep bumping the vote thread on a weekly bases..

Re: [VOTE] KIP-380: Detect outdated control requests and bounced brokers using broker generation

+1(binding). LGTM. -Harsha On Oct 20, 2018, 4:49 PM -0700, Dong Lin , wrote: > Thanks much for the KIP Patrick. Looks pretty good. > > +1 (binding) > > On Fri, Oct 19, 2018 at 10:17 AM Patrick Huang wrote: > > > Hi All, > > > > I would like to call for a vote on KIP-380: > > > > https://cwiki.apac

[jira] [Created] (KAFKA-7524) Recommend Scala 2.12 and use it for development

Ismael Juma created KAFKA-7524: -- Summary: Recommend Scala 2.12 and use it for development Key: KAFKA-7524 URL: https://issues.apache.org/jira/browse/KAFKA-7524 Project: Kafka Issue Type: Improve

Jenkins build is back to normal : kafka-2.0-jdk8 #168

See

Re: [VOTE] KIP-380: Detect outdated control requests and bounced brokers using broker generation

Thanks much for the KIP Patrick. Looks pretty good. +1 (binding) On Fri, Oct 19, 2018 at 10:17 AM Patrick Huang wrote: > Hi All, > > I would like to call for a vote on KIP-380: > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-380%3A+Detect+outdated+control+requests+and+bounced+brokers+

[jira] [Resolved] (KAFKA-6490) JSON SerializationException Stops Connect

[ https://issues.apache.org/jira/browse/KAFKA-6490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-6490. -- Resolution: Fixed Fix Version/s: 2.0.0 Closing as this is effectively fi

Re: Java cluster vs Scala cluster

Thank you very much. And all classes arround cluster.scala are deprecated ? __ Od: "Mickael Maison" Komu: "dev" Dátum: 20.10.2018 21:18 Predmet: Re: Java cluster vs Scala cluster Hi, These 2 classes have the same name but are servin

Re: Design patterns in kafka

Please, I need just some examples and will be fine, if you can help me please.   Thanks __ > Od: "Adam Bellemare" > Komu: dev@kafka.apache.org > Dátum: 20.10.2018 19:14 > Predmet: Re: Design patterns in kafka > I think this question is mu

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

See

[jira] [Resolved] (KAFKA-7521) [kafka-streams-scala_2.11] Foreach results in StackOverflowError

[ https://issues.apache.org/jira/browse/KAFKA-7521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7521. Resolution: Fixed Assignee: Joan Goyeau Fix Version/s: 2.1.0 > [kafka-strea

Re: Java cluster vs Scala cluster

Hi, These 2 classes have the same name but are serving different purposes - Cluster.java is part of the public Java API [0] and allows to build a representation of a Kafka Cluster including brokers, topics and partitions. - Cluster.scala is an internal class only used by the old and now deprecate

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

See Changes: [ismael] MINOR: Remove redundant try block in LogCleaner (#5776) -- [...truncated 2.51 MB...] org.apache.kafka.streams.test.OutputVerifierTest > shouldNotAl

Re: Design patterns in kafka

I think this question is much too broad to be answered in this way. This will require you to do your own work on understanding the code. Alternately, start by looking through the Kafka documentation and Confluent blogs to get an understanding of Kafka usage patterns in Event driven microservice

Re: [DISCUSS] KIP-379: Multiple Consumer Group Management

Is there a reason for using multiple --group flags over having it accept a regex? The topics command currently accepts a regex for most operations and doesn't support using multiple topics flags. It seems like it would be better to take a more standardized approach to providing this type of inf

Design patterns in kafka

Hi can you help me identify design patterns in the code apache/kafka ?   Thanks

Re: Java cluster vs Scala cluster

I want to know what is cluster in scala doing and what is doing cluster in java. I mean file Cluster.scala which is at github apache kafka in directory kafka/core/src/main/scala/kafka/cluster and file Cluster.java which is at github apache kafka in directory kafka/clients/src/main/java/org/apac

Not able to start Kafka-Connect as a service on CentOS 7

Hi, I have a Kafka environment (Zookeeper + Kafka Server + Kafka-Connect) which runs perfectly when I use command line to start each individual components on CentOS 7. Now I am setting up these Kafka components to run as a service. For this I have created .service files and placed it in /etc/sy