-BEGIN PGP SIGNED MESSAGE-
Hash: SHA512
Thx! :)
On 10/25/16 2:03 PM, saiprasad mishra wrote:
> Just created the JIRA
>
> https://issues.apache.org/jira/browse/KAFKA-4344
>
> Regards Sai
>
> On Tue, Oct 25, 2016 at 11:59 AM, saiprasad mishra <
> saiprasadmis...@gmail.com> wrote:
>
>>
Just created the JIRA
https://issues.apache.org/jira/browse/KAFKA-4344
Regards
Sai
On Tue, Oct 25, 2016 at 11:59 AM, saiprasad mishra <
saiprasadmis...@gmail.com> wrote:
> My JIRA id is saimishra
>
> Regards
> Sai
>
> On Tue, Oct 25, 2016 at 10:55 AM, Matthias J. Sax
> wrote:
>
>> -BEGIN P
My JIRA id is saimishra
Regards
Sai
On Tue, Oct 25, 2016 at 10:55 AM, Matthias J. Sax
wrote:
> -BEGIN PGP SIGNED MESSAGE-
> Hash: SHA512
>
> What is your JIRA ID? We can add you to the contributor list to give
> you permission.
>
> - -Matthias
>
>
> On 10/25/16 10:48 AM, saiprasad mishr
-BEGIN PGP SIGNED MESSAGE-
Hash: SHA512
What is your JIRA ID? We can add you to the contributor list to give
you permission.
- -Matthias
On 10/25/16 10:48 AM, saiprasad mishra wrote:
> Hi Matthias Thanks for the reply. I think I don't have permission
> for this. If you can grant me perm
Hi Matthias
Thanks for the reply.
I think I don't have permission for this.
If you can grant me permission I can create one (my handle is saimishra).
Or you can go ahead and create one
I may need permission to create JIRA as I might report more issues after
discussing with you over here.
Regards
-BEGIN PGP SIGNED MESSAGE-
Hash: SHA512
Hi,
sorry for late reply. Seems like a bug to me; within
Processor#process() accessing the context should work. Can you open a
JIRA for it?
- -Matthias
On 10/23/16 10:28 PM, saiprasad mishra wrote:
> Sorry for the email again
>
> I was expecting
Sorry for the email again
I was expecting it to work always when accessed from process() method as
this corresponds to each kafka message/record processing.
I understand illegalstate by the time punctuate() is called as its already
batched by time interval
Regards
Sai
On Sun, Oct 23, 2016 at 9:1
Hi
his is with my streaming app kafka 10.1.0.
My flow looks something like below
source topic stream -> filter for null value ->map to make it keyed by id
->custom processor to mystore -> to another topic -> ktable
I am hitting the below type of exception in a custom processor class if I
try to
