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