Hi Michael Eugene,
You're correct - you only need to upgrade your Kafka Streams dependencies
in your build file. Looking at MVN Repository, the streams lib will
implicitly bring in its dependency on kafka-clients, but you can always
include your own explicit dependency on it.
https://mvnrepository
Well to bring up that kafka to 2.0, do I just need for sbt kafka clients and
kafka streams 2.0 for sbt? And it doesn't matter if the system is not Kafka
2.0? Upgrading Kafka itself is probably not an option or me right now.
From: John Roesler
Sent: Monday,
This was resolved internally - I realised that we had a second consumer running
against the topic which was committing offsets without setting a group.id or
auto.commit to false.
Henry
> On 5 Sep 2018, at 08:28, Henry Thacker wrote:
>
> Hi,
>
> In testing - i’ve got a 5 node Kafka cluster wi
Hi Ashok,
Did you tried to configure krb5.conf and krb5JAASLogin.conf files?
Thanks,
Subash
On Mon, Sep 10, 2018 at 7:19 PM AshokKumar J
wrote:
> When the Kafka stream app is started, the following jaas file is being
> used. However, the tickets are not being renewed automatically by the
> str
In addition to the other suggestions, if you're having too much trouble
with the interface, you can always fall back to creating anonymous
Initializer/Aggregator instances the way you would if programming in Java.
This way, you wouldn't need SAM conversion at all (all it's doing is
turning your fun
When the Kafka stream app is started, the following jaas file is being
used. However, the tickets are not being renewed automatically by the
stream application. It fails with the exception below after the ticket
expires. What should we do to keep the Kerberos ticket automatically
renewed?
KafkaCli
Hi,
SAM conversions can be enabled in 2.11 with the -Xexperimental to scalac.
However, this version of SAM conversions isn't recommended for production
and was significantly refactored for 2.12. When we contributed this API to
Kafka we explicitly removed the SAM conversions because we didn't want
