FYI, my goal was to get it to compile, since that is where
implicit resolution takes place. Obviously, you would need to plug in the
properties, start the stream, add a shutdown hook, etc.
On Fri, Nov 20, 2020 at 12:56 AM Daniel Hinojosa <
dhinoj...@evolutionnext.com> wrote:
> Done. I am using
Done. I am using SBT for the build tool. I created an application and put
it here
https://github.com/dhinojosa/kafka-streams-scala
The implicits for SessionWindowedSerde from this line below. The reason is
I am turning off the timeWindowSerde, and that just leaves the
SessionWindowSerde, the
Daniel,
I copied your code from here:
https://gist.github.com/dhinojosa/390f3a98d271272bbea90765cb58e735
Still getting the same error message. Actually, I am not sure why it would
work since you don't have implicits for SessionWindowedSerde. By the way,
which versions of Scala & Kafka did you
That said John, nothing wrong with being explicit in code. :)
On Fri, 20 Nov. 2020, 1:46 pm John Roesler, wrote:
> Oh, nice. Thanks, Daniel!
>
> That’s much nicer than my ham-handed approach.
>
> Thanks,
> John
>
> On Thu, Nov 19, 2020, at 17:44, Daniel Hinojosa wrote:
> > Hope this helps, I
Oh, nice. Thanks, Daniel!
That’s much nicer than my ham-handed approach.
Thanks,
John
On Thu, Nov 19, 2020, at 17:44, Daniel Hinojosa wrote:
> Hope this helps, I tried copying your code into a sample application. I got
> it to compile with the implicits all resolving. I think the trick was
Hope this helps, I tried copying your code into a sample application. I got
it to compile with the implicits all resolving. I think the trick was there
were two implementations for Windowing Serdes. You just need to block one
from the imports. See if that fits with what you are doing. Oh also,
Hello Kafka users, developers, and client-developers,
This is the third candidate for the release of Apache Kafka 2.7.0.
This is a major release that includes many new features, including:
* Configurable TCP connection timeout and improve the initial metadata fetch
* Enforce broker-wide and
./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list
192.168.10.145:9092 --topic IIoT
Error: partition 0 does not have a leader. Skip getting offsets
[2020-11-19 09:28:47,688] WARN [Consumer clientId=GetOffsetShell, groupId=null]
1 partitions have leader brokers without a matching
Hi Eric,
Sure thing. Assuming the definition of ‘produced’ you had tried in your code,
it’s just:
...
.toStream.to("streams-pipe-output")(produced)
As far as the json serde goes, I think that I wrote an example of using Jackson
to implement a serde in Confluent’s kafka-streams-examples repo.
