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,
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
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
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
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
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
: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
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
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
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
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
11 matches
Mail list logo