Supplementary:https://github.com/apache/incubator-seatunnel/pull/4513

陈卓宇 <[email protected]> 于2023年4月7日周五 19:00写道:

> 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
>>
>

Reply via email to