Hi Sachin,
I do not completely understand what you mean with one single
operation. Do you mean one call of a method in the DSL or the join is
processed on one processor node?
If you mean the latter, the joins in the DSL are also not processed on
one single processor node.
If you mean the former,
Hello all,
[sorry if this is a duplicate, not sure why my 1st attempt didn't come
through]
I do have two Kafka clusters in action, test and prod. The two are
formed by 3 nodes each, are independent and run their own zookeeper
setups. My prod cluster is running fine. My test cluster is half-broken
Hello all,
I do have two Kafka clusters in action, test and prod. The two are formed by 3
nodes each, are independent and run their own zookeeper setups. My prod cluster
is running fine. My test cluster is half-broken and I'm struggling to fix it. I
could wipe it but I prefer to understand what
Are you using ZooKeeper 3.5.6 client libraries with Kafka 2.3.1? Kafka
2.3.1 ships with ZooKeeper 3.4.x.
Ismael
On Thu, Dec 5, 2019 at 8:18 AM Charles Bueche wrote:
> Hello all,
>
> I do have two Kafka clusters in action, test and prod. The two are formed
> by 3 nodes each, are independent and
Hello, my consumers are reporting invalid IP address. When running
kafka-consumer-groups –describe… I see the following:
TOPICPARTITION CURRENT-OFFSET LOG-END-OFFSET LAG
CONSUMER-ID HOST CLIENT-ID
Topic1 12 1319627
I was thinking more of a builder api at DSL level.
Something like this:
StreamsBuilder.joineBuilder()
.join(kstream1)
.leftJoin(kstream2)
.leftJoin(kstream3)
.joiner((k,v1,v2,v3...) -> ...)
.window(
