Jose,
You're all set. I look forward to your PR.
Thanks,
Bill
On Mon, Apr 8, 2019 at 4:59 PM Jose Lopez wrote:
> Bill,
>
> Thank you again for your help.
>
> I am happy to give it a try. My Jira username is JoseLopez, could you
> please get me added as a contributor?
>
> Regards,
> Jose
>
>
Bill,
Thank you again for your help.
I am happy to give it a try. My Jira username is JoseLopez, could you
please get me added as a contributor?
Regards,
Jose
On Mon, 8 Apr 2019 at 18:28, Bill Bejeck wrote:
> Jose,
>
> If you'd like to take a swing at fixing this, by all means, assign the
Hmm, not sure I understand what you are suggesting. Let me address
each step in turn:
> 1) materialize the topic-1 into a state store
Ok, I think that's basically what we have with the global k-table I
showed in the topology, or did you mean something else, like using the
Processor API to
Jose,
If you'd like to take a swing at fixing this, by all means, assign the Jira
ticket to yourself and submit a PR.
If you don't have an Apache Jira account, sign up for one and list your
jira userid here and I'll get you added as a contributor.
Thanks,
Bill
On Mon, Apr 8, 2019 at 11:52 AM
Thank you for the prompt response, Bill.
Do you have an estimated date as to when this could be fixed? Are you open
to new developers / collaborators?
Regards,
Jose
On Mon, 8 Apr 2019 at 17:06, Bill Bejeck wrote:
> Jose,
>
> Thanks for reporting this we have created this Jira
>
Jose,
Thanks for reporting this we have created this Jira
https://issues.apache.org/jira/browse/KAFKA-8199 for tracking the issue.
-Bill
On Mon, Apr 8, 2019 at 5:49 AM Jose Lopez wrote:
> Hi all,
>
> My topology is:
>
> stream -> groupByKey -> windowedBy -> count -> suppress -> groupBy ->
>
Hi all,
My topology is:
stream -> groupByKey -> windowedBy -> count -> suppress -> groupBy ->
aggregate -> toStream
When I *groupBy* after *suppress*, the following exception is thrown:
java.lang.ClassCastException:
org.apache.kafka.streams.kstream.internals.KTableImpl$$Lambda$15/1208825205
Hi,
I wanted to compute partition number using rd_kafka_msg_partitioner_murmur2()
API.
Can someone tell me how to get partition count on a specific topic inside my c
application on the fly?
I need to pass this count as one of the parameter to above api.
One more query:
Is murmur3 supported in
On 2019/04/03 13:08:45, Shantanu Deshmukh wrote:
> Hello everyone,
>
> I am trying to setup Kafka SASL authentication on my single node Kafka on
> my local machine. version 2.
>
> Here's my Kafka broker JAAS file:
>
> KafkaServer {
>
