Kafka user mailing list

Subscribing Kafka user mailing list -- *Thanks And Regard* Ganesh S Vidharthi contact: 9600114171

Re: delete topic causing spikes in fetch/metadata requests

Hi Can you guys help me with this issue On Oct 12, 2016 10:35 PM, "sunil kalva" wrote: > > We are using kafka 0.8.2.2 (client and server), when ever we delete a > topic we see lot of errors in broker logs like below, and there is also a > spike in fetch/metadata requests. Can i correlate these e

Re: Kafka user mailing list

If you want to subscribe, you need to email to users-subscr...@kafka.apache.org. See https://kafka.apache.org/contact -Matthias On 10/16/2016 06:10 AM, ganesh shankar vidharthi wrote: > Subscribing Kafka user mailing list > signature.asc Description: OpenPGP digital signature

Kafka as A Metrics Collector

Hi, I am so new to Kafka and really liked it further to its name. I have a distributed search application. Search requests come to one of my search service (each of them is a Spring Boot application). I want to report query per second and document per second rates. So, I think that Kafka can be

Kafka consumer cluster setup

Hi, We are planning to run Kafka servers along with Zookeeper in 3 remote machines for our cluster setup. We have our application with Kafka Consumer and Publisher running in another/separate 2 machines. We will be configuring 1 or 2 out of 3 Kafka servers as bootstrap servers in Kafka Consumer

Re: Problem in Deleting Kafka Logs

Please help me :( *Thanks, Kunal* *+91-9958189589* *Data Analyst* *First Paper Publication : **http://dl.acm.org/citation.cfm?id=2790798 * *Blog:- **http://learnhardwithkunalgupta.blogspot.in * On Sun, Oc

RE: A question about kafka

Hi, Anybody could help to answer this question? Thanks! Best Regards Johnny -Original Message- From: ZHU Hua B Sent: 2016年10月14日 16:41 To: users@kafka.apache.org Subject: [COMMERCIAL] A question about kafka Hi, I have a question about kafka, could you please help to have a loo

RE: A question about kafka

Hi, I believe the answer is in the code. This is where the --compression-codec is processed: https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/tools/ConsoleProducer.scala#L143 and this is —producer-property: https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/to

Re: A question about kafka

This is known issue in some of the command line tools. JIRA is here : https://issues.apache.org/jira/browse/KAFKA-2619 On Mon, Oct 17, 2016 at 11:16 AM, ZHU Hua B wrote: > Hi, > > > Anybody could help to answer this question? Thanks! > > > > > > > Best Regards > > Johnny > > -Original Messa

RE: A question about kafka

Hi, Thanks for your reply! If console producer only allows for compression codec argument, why we could found option —producer-property defined in ConsoleProducer.scala? And we could find the usage also if we running console producer? The version we used is Kafka 0.10.0.0. Thanks! # ./kafka

RE: A question about kafka

Hi, Thanks for your reply! I saw the last update for this issue was on 14/Nov/2015, do you know if the has been fixed now? The version we used is 0.10.0.0. Thanks! Best Regards Johnny -Original Message- From: Manikumar [mailto:manikumar.re...@gmail.com] Sent: 2016年10月17日 14:03

RE: A question about kafka

Because the producer-property option is used to set other properties that are not compression type. //h...@confluent.io Original message From: ZHU Hua B Date: 10/16/16 11:20 PM (GMT-08:00) To: Radoslaw Gruchalski , users@kafka.apache.org Subject: RE: A question about kafka

RE: A question about kafka

Hi, Thanks for your reply! OK, I got it. And, there is a parameter named compression.type in config/producer.properties, which is same usage as "--compression-codec " I think. I modify compression.type in config/producer.properties firstly, then run console producer with option "--producer.co