Rpm spec file for kafka

2020-04-02 Thread Divyansh Bokadia
Hello, I wanted to build a rpm from scratch. Is there a spec file anyone could guide me to ? I can see ones for kafka-rest and schema-registry . it would be of great help if I could get for kafka as well. I know there are rpms available but I would prefer it to build on my own Thanks,

Re: Global state store: Lazy loading

2020-04-02 Thread Boyang Chen
Hey Navneeth, could you clarify a bit on what you mean by `lazy load`, specifically how you make it happen with local KV store? On Thu, Apr 2, 2020 at 12:09 PM Navneeth Krishnan wrote: > Hi All, > > Is there a recommend way for lazy loading the global state store. I'm using > PAPI and I have

Re: acks this category properties in Which *.java Defined???

2020-04-02 Thread James Olsen
org.apache.kafka.clients.producer.ProducerConfig org.apache.kafka.clients.consumer.ConsumerConfig > On 3/04/2020, at 04:30, 一直以来 <279377...@qq.com> wrote: > > Properties props = new Properties(); props.put("bootstrap.servers", > "localhost:9092"); props.put("acks", "all");

Global state store: Lazy loading

2020-04-02 Thread Navneeth Krishnan
Hi All, Is there a recommend way for lazy loading the global state store. I'm using PAPI and I have the local KV state stores in lazy load fashion so that I don't end up loading unnecessary data. Similarly I want to get the global state store to be loaded only when the request has the id for

Arcsight Logs into Vertica through Kafka

2020-04-02 Thread Sebastian Schmitz
Hello! One of my customers wants to get the Logs produced by Arcsight into Vertica to do some analysis. They tried posting the normal logs to Kafka and consume from Vertica, but Vertica doesn't understand the (binary) format and the other options available from Arcsight are also not better for

acks this category properties in Which *.java Defined???

2020-04-02 Thread ????????
Properties props = new Properties(); props.put("bootstrap.servers", "localhost:9092"); props.put("acks", "all"); props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer"); props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

Kafka rebalancing issue

2020-04-02 Thread Mirtunjay Kumar
Hi team, We are using kafka since very long time and haven’t face such issue yet, at sudden before sometime we are facing rebalancing issue of nodes with kafka, I do not understand this behaviour, can you please explain possible causes. Also to note my configuration is all okay, and consumer is