Re: KafkaSink handling message size produce errors

>>> Best, >>> Shammon >>> >>> On Fri, Feb 17, 2023 at 9:54 AM yuxia >>> wrote: >>> >>>> Hi, Hatem. >>>> I think there is no way to catch the exception and then ignore it in >>>> current implementation for KafkaSi

Kafka Quotas & Consumer Group Client ID (Flink 1.15)

Hello, I have two questions that are related to each other: *First question:* I have been trying to set `client.id` to set a kafka client quota for consumer_byte_rate since whenever our kafka job gets redeployed it reads a lot of data f

Re: Kafka Quotas & Consumer Group Client ID (Flink 1.15)

explained > on > https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/kafka/#consumer-offset-committing > > Best regards, > > Martijn > > > On Tue, May 23, 2023 at 6:43 PM Hatem Mostafa wrote: > >> Hello, >> >> I have two questio

Re: Kafka Quotas & Consumer Group Client ID (Flink 1.15)

log is benign if you are using Flink's metric > system for monitoring the Kafka connector and it would be nice to introduce > an option in the connector to configure the same `client.id` across all > tasks for the quota feature you mentioned. > > Best, > Mason > >

Unsubscribe

Unsubscribe