Re: A question about Kafka Stream API

2018-08-01 Thread Damian Guy
The count is stored in RocksDB which is persisted to disk. It is not in-memory unless you specifically use an InMemoryStore. On Wed, 1 Aug 2018 at 12:53 Kyle.Hu wrote: > Hi, bosses: > I have read the word count demo of Kafka Stream API, it is cool that > the Kafka Stream keeps the status,

RE: A question about kafka

2016-10-24 Thread ZHU Hua B
apache.org; Radoslaw Gruchalski Subject: 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/produce

RE: A question about kafka

2016-10-23 Thread ZHU Hua B
apache.org; Radoslaw Gruchalski Subject: 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/produce

RE: A question about kafka

2016-10-18 Thread ZHU Hua B
apache.org; Radoslaw Gruchalski Subject: 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/produce

RE: A question about kafka

2016-10-16 Thread ZHU Hua B
oducer.config config/producer.properties --broker-list localhost:9092 --topic test Best Regards Johnny -Original Message- From: Hans Jespersen [mailto:h...@confluent.io] Sent: 2016年10月17日 14:29 To: users@kafka.apache.org; Radoslaw Gruchalski Subject: RE: A question about kafka Because t

RE: A question about kafka

2016-10-16 Thread Hans Jespersen
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

2016-10-16 Thread ZHU Hua B
:03 To: users@kafka.apache.org Subject: 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 t

RE: A question about kafka

2016-10-16 Thread ZHU Hua B
custom configuration for a user- defined message reader. Best Regards Johnny From: Radoslaw Gruchalski [mailto:ra...@gruchalski.com] Sent: 2016年10月17日 14:02 To: ZHU Hua B; users@kafka.apache.org Subject: RE: A question about kafka Hi, I believe the answ

Re: A question about kafka

2016-10-16 Thread Manikumar
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

2016-10-16 Thread Radoslaw Gruchalski
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

2016-10-16 Thread ZHU Hua B
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