Re: High CPU Usage on Brokers

Hi All, Any suggestions, we are running into this issue in production and any help would be greatly appreciated. Thanks On Mon, Jan 6, 2020 at 9:26 PM Navneeth Krishnan wrote: > Hi, > > Thanks for the response. We were using version 0.11 previously and all our > producers/consumers have been u

Re: about default value of struct of connect api

hello guys, update my question, i made a test, code as below, i want to set a default value of address to person SchemaBuilder schemaBuilder = SchemaBuilder.struct().name("address") .field("province", SchemaBuilder.STRING_SCHEMA) .field("city", SchemaBuild

callback function

Hi, Is there a method in which a function can wake when something is new in the queue? This has to be non-blocking to the main thread. Thanks, -Tavares

Re: Question On KIP-500

Hey Ryanne, Amazing! Thanks for pointing this out. I’ll take a look soon. Regards, On Tue, 7 Jan 2020 at 17:15, Ryanne Dolan wrote: > Hello. The dev list might be a better place to ask this question. FWIW I > believe your interpretation is correct -- the proposal essentially uses two > separa

Re: Question On KIP-500

Hello. The dev list might be a better place to ask this question. FWIW I believe your interpretation is correct -- the proposal essentially uses two separate clusters, comprising "controllers" and "brokers". N.B. that the brokers cannot become controllers or vice versa. You can find the discussion

Re: Kafka 2.4.0 & Mirror Maker 2.0 Error

Hi, I just tested with 2.4.0 release, I still get the same error. Filed the jira ticket: https://issues.apache.org/jira/browse/KAFKA-9376 Thanks, Peter On Mon, 6 Jan 2020 at 21:26, Ryanne Dolan wrote: > I just downloaded the 2.4.0 release tarball and didn't run into any issues. > Peter, Jamie,