hi,
KafkaIO.read()
.withBootstrapServers(bootstrapServers)
.withTopic(topic)
.withConsumerConfigUpdates(Map.ofEntries(
Map.entry("schema.registry.url", registryURL),
Map.entry(ConsumerConfig.GROUP_ID_CONFIG,
consumerGroup+
How are you using the schema registry? Do you have a code sample?
On Sun, Apr 9, 2023 at 3:06 AM Sigalit Eliazov wrote:
> Hello,
>
> I am trying to understand the effect of schema registry on our pipeline's
> performance. In order to do sowe created a very simple pipeline that reads
> from
Hello,
I am trying to understand the effect of schema registry on our pipeline's
performance. In order to do sowe created a very simple pipeline that reads
from kafka, runs a simple transformation of adding new field and writes of
kafka. the messages are in avro format
I ran this pipeline with
