I'm not sure. After deleting the partition parameter, how do users specify which specific partition to send data to？
JUN GAO <[email protected]> 于2023年4月10日周一 15:30写道： > +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] > > -- Best Regards ------------ EricJoy2048 [email protected]
