+1 hailin0 <[email protected]> 于2023年4月8日周六 22:47写道：
> 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 > > > > > > -- Best Regards ------------ EricJoy2048 [email protected]
