CDC usually only needs to send the data of the same table or the same primary key to the same partition, but does not care which partition.
It can be done by partition_key_fields 陈卓宇 <[email protected]> 于2023年4月7日周五 19:01写道： > A scenario comes to mind: to ensure the orderliness of the messages, the > messages are typed under a specified partition > > 陈卓宇 <[email protected]> 于2023年4月7日周五 17:53写道： > > > A user recently gave feedback about a kafkaSink exception that could not > > be written [https://github.com/apache/incubator-seatunnel/issues/4498], > > and I set out to track down the problem. > > By reading the source code, I found that the error was reported because > > the `parameter` parameter filled in by the user was not in the range of > the > > real partition number of the specified topic, but the program did not > > report an explicit exception. > > Later, I communicated with the user what the intent of configuring this > > parameter was, and he said: he copied the official website example. I > then > > felt that there is no scenario to send data to the specified partition, > why > > not remove this parameter Remove this function > > >
