the print is in line 40 of the class Base...
De : Hamza HACHANI <hamza.hach...@supcom.tn>
Envoyé : lundi 28 novembre 2016 01:25:08
À : users@kafka.apache.org
Objet : RE: Abnormal working in the method punctuate and error linked to
seesion.timeout.ms
of your code so we can have a look?
Thanks
Eno
> On 28 Nov 2016, at 12:58, Hamza HACHANI <hamza.hach...@supcom.tn> wrote:
>
> Hi Eno.
>
> The problem is that there is no infinite while loop that i write.
>
> So I can't understand w
t : Re: Abnormal working in the method punctuate and error linked to
seesion.timeout.ms
Hi Hamza,
If you have an infinite while loop, that would mean the app would spend all the
time in that loop and poll() would never be called.
Eno
> On 28 Nov 2016, at 10:49, Hamza HACHANI <hamza.hach.
Hi,
I've some troubles with the method puctuate.In fact when i would like to print
a string in the method punctuate.
this string would be printed in an indefinitly way as if I printed (while
(true){print(string)}.
I can't understand what happened.Does any body has an explenation ?.
Besides
at
https://cwiki.apache.org/confluence/display/KAFKA/KIP-63%3A+Unify+store+and+downstream+caching+in+streams
Thanks,
Damian
On Fri, 4 Nov 2016 at 09:44 Hamza HACHANI <hamza.hach...@supcom.tn> wrote:
> Hi Damian,
>
>
> If i would pass tp the 0.10.1. Is this possible without i
ut you should still
expect multiple results for a window.
Thanks,
Damian
On Fri, 4 Nov 2016 at 08:42 Hamza HACHANI <hamza.hach...@supcom.tn> wrote:
> Hi,
>
>
> I implemented window using Stream DSL.But results does get out from the
> window anytime a new data come. Is there any
Hi,
I implemented window using Stream DSL.But results does get out from the window
anytime a new data come. Is there anyway to make result get out from the
window just at the end of the size of the window not like this way.
In other words, I do need to control the flow of data getting out of
> API. All you can do with plain processor API you can also do within
> DSL via .process(...)
>
>
> - -Matthias
>
> On 11/2/16 3:49 AM, Hamza HACHANI wrote:
>> Hi Eno,
>>
>>
>> What I want to say is that i don't find a place where to define the
>>
.persistent()
.windowed(10, 10, 2, false).build(), "the-processor")
Thanks
Eno
> On 2 Nov 2016, at 08:19, Hamza HACHANI <hamza.hach...@supcom.tn> wrote:
>
> Hi,
>
> I would like to know if somebody has an idea how to define the size of the
> window in t
Hi,
I would like to know if somebody has an idea how to define the size of the
window in the processor api.
I've been blocked for 6 days looking for a solution.
using :
Stores.create(...).withStringKeys().withStringValues().persistent().windowed(...).build()
I was able to define the
:23 AM, Hamza HACHANI <hamza.hach...@supcom.tn>
wrote:
> And the start time and end time of the window.
>
> In other words i need the notion of windows in the proecessor API.
>
> Is this possible ?
>
> ________
> De : Hamza HACHANI <hamza.ha
To be more specific.
What id do really need is the property of the retention time dor the window in
the processor API.
Because for the window i think that i can manage to do this.
Hamza
De : Hamza HACHANI <hamza.hach...@supcom.tn>
Envoyé : diman
Hi,
I would like to process data based on a customised event time.(a timestamp that
I implement as part of the message).
The data is processed in periodic windows of x time that are parametered via
the method punctuate.
What I need is a retention time for the window to be able to treat the
d name? Sounds like there might be a missing validation
> > somewhere.
> >
> > Regards,
> >
> > Rajini
> >
> > On Thu, Oct 6, 2016 at 10:12 AM, Hamza HACHANI <hamza.hach...@supcom.tn>
> > wrote:
> >
> >> Thanks Todd,
> >>
>
: Hamza HACHANI <hamza.hach...@supcom.tn>
Envoyé : mercredi 5 octobre 2016 19:23:00
À : users@kafka.apache.org
Objet : RE: difficulty to delete a topic because of its syntax
Hi,
Attached the files showing what i'm talking about.
Hamza
De : Todd S <t...@
w you got white space in topic name.
>
> On Wed, Oct 5, 2016 at 8:19 PM, Hamza HACHANI <hamza.hach...@supcom.tn
> <javascript:;>>
> wrote:
>
> > Well ackwardly when i list the topics i find it but when i do delete it
> it
> > says that this topic does n
delete a topic because of its syntax
Try putting "" or '' around the string when running the command.
On Wed, Oct 5, 2016 at 3:29 PM, Hamza HACHANI <hamza.hach...@supcom.tn>
wrote:
> It's between "the" and "metric"
>
> ___
name
On Wed, Oct 5, 2016 at 6:42 PM, Hamza HACHANI <hamza.hach...@supcom.tn>
wrote:
> Hi,
>
> I created a topic called device-connection-invert-key-value-the
> metric-changelog.
>
> I insit that there is a space in it.
>
>
>
> Now that i want to delete it
Hi,
I created a topic called device-connection-invert-key-value-the
metric-changelog.
I insit that there is a space in it.
Now that i want to delete it because my cluster can no longer work correctly i
can't do it as it only reads the first part of it : (
Hi,
i would like to know how in kafka streams the context is initilised.
Because I 've a problem with one kafka-stream apllication. every time i call it
i notice that the context is initilaised more than once or is created more
than once which is abnormal and this cause a bug in the system.
I'm using the version 10.0
De : Hamza HACHANI
Envoyé : lundi 19 septembre 2016 19:20:23
À : users@kafka.apache.org
Objet : RE: Error kafka-stream method punctuate in context.forward()
Hi Guozhang,
Here is the code for the two concerned classes
If this can
"{'operatorId':'fake','networkPartnerId':'fake','baseStationId':'fake','count':-1,'timestamp':5}";
}
}
}
De : Guozhang Wang <wangg...@gmail.com>
Envoyé : lundi 19 septembre 2016 12:19:36
À : users@kafka.apache.org
Objet : Re: Error ka
Good morning,
I have a problem with a kafka-stream application.
In fact I 've created already two kafka stream applications :
StatsByMinute : entry topic : uplinks, out topic : statsM.
StatsByHour : entrey topic : statsM, out topic : statsH.
StatsByDay : entry topic : statsH, out topic :
Date : mer., août 3, 2016 23:38
Hello Hamza,
By saying "broker" I think you are actually referring to a Kafka Streams
instance?
Guozhang
On Mon, Aug 1, 2016 at 1:01 AM, Hamza HACHANI <hamza.hach...@supcom.tn>
wrote:
> Good morning,
>
> I'm working on a specific us
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
e Engineer | Surescripts
O: 651.855.3042 | www.surescripts.com<http://www.surescripts.com> |
dave.tauz...@surescripts.com
Connect with us: Twitter I LinkedIn I Facebook I YouTube
-----Original Message-
From: Hamza HACHANI [mailto:hamza.hach...@supcom.tn]
Sent: Friday, J
> Good morning,
>
> I'm an ICT student in TELECOM BRRETAGNE (a french school).
> I did follow your presentation in Youtube and i found them really
> intresting.
> I'm trying to do some stuffs with Kafka. And now it has been about 3 days
> that I'm blocked.
> I'm trying to control the time in
27 matches
Mail list logo
