RE: Kafka Sink Key and Value Avro Schema Usage Issues

block keyEncoder.flush(); // TODO Auto-generated catch block keyOut.close(); // TODO Auto-generated catch block } catch (Exception e) { } return keyOut.toByteArray(); } From: Ghiya, Jay (GE Healthcare) Sent: 18 May

Kafka Sink Key and Value Avro Schema Usage Issues

Hi Team, This is regarding Flink Kafka Sink. We have a usecase where we have headers and both key and value as Avro Schema. Below is the expectation in terms of intuitiveness for avro kafka key and value: KafkaSink.>builder() .setBootstrapServers(cloudkafkaBrokerAPI)

RE: EXT: Re: Flink cassandra connector performance issue

uld all help out :) > > Best regards, > > Martijn Visser > https://twitter.com/MartijnVisser82 > > [1] https://lists.apache.org/thread/1qokt5tp8dcp58dmshbwjc43ssbm1vvk > > > On Tue, 22 Mar 2022 at 07:33, Ghiya, Jay (GE Healthcare) > > wrote: > >> Hi @dev@flin

Flink cassandra connector performance issue

Hi @dev@flink.apache.org, Greetings from gehc. This is regarding flink Cassandra connector implementation that could be causing the performance issue that we are facing. The summary of the error is "Insertions into scylla might be suffering. Expect performance prob