Not sure what you mean by "pass it explicitly". The definition of 'to' is
given below. Can we pass it explicitly in this case. If yes, can you please
show me how?
def to(topic: String)(implicit produced: Produced[K, V]): Unit =
inner.to(topic, produced)
Also not sure how to use a self document
Hi Eric,
Ah, that’s a bummer. The correct serde is the session windowed serde, as I can
see you know. I’m afraid I’m a bit rusty on implicit resolution rules, so I
can’t be much help there.
But my general recommendation for implicits is that when things get weird, just
don’t use them at all.
I keep getting '*ambiguous implicit values*' message in the following code.
I tried several things (as can be seen from a couple of lines I've
commented out). Any ideas on how to fix this? This is in *Scala*.
def createTopology(conf: Config, properties: Properties): Topology =
{//implicit val
Matthias,
We recently ran into an issue where kafka brokers upgraded (i guess it was
rolling update) for Aiven business plan 4 to plan 8. This involves change
to cpu, memory and storage for each broker.
Since this should be rolling upgrade, we expected services to survive,
however in one service
Hi All,
Does anyone have any inputs?
Thanks,
Sambhaji
On 2020/11/12 13:13:44, Sambhaji Gayake wrote:
> Hi,
>
> While using Kafka, I found this strange behavior. Note that all topics are
> already created. Following is a sequence of events.
>
> 1. Kafka Producer sends 200+ records on a partic
