kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Hamza HACHANI <hamza.hach...@supcom.tn>
Subject Re : A specific use case
Date Thu, 04 Aug 2016 03:53:44 GMT
Yes in fact .
And ï found à solution.
It was in editing the method punctuate in kafka stream processor.

----- Message de réponse -----
De : "Guozhang Wang" <wangguoz@gmail.com>
Pour : "users@kafka.apache.org" <users@kafka.apache.org>
Objet : A specific use case
Date : mer., août 3, 2016 23:38

Hello Hamza,

By saying "broker" I think you are actually referring to a Kafka Streams


On Mon, Aug 1, 2016 at 1:01 AM, Hamza HACHANI <hamza.hachani@supcom.tn>

> Good morning,
> I'm working on a specific use case. In fact i'm receiving messages from an
> operator network and trying to do statistics on their number per
> minute,perhour,per day ...
> I would like to create a broker that receives the messages and generates a
> message every minute. These producted messages are consumed by a consumer
> from in one hand and also se,t to an other topic which receives them and
> generates messages every minute.
> I've  been doing that for a while without a success. In fact the first
> broker in any time it receives a messages ,it produces one and send it to
> the other topic.
> My question is ,what i'm trying to do,Is it possible without passing by an
> intermediate java processus which is out of kafka.
> If yes , How ?
> Thanks In advance.

-- Guozhang

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message