Hi Aeden,
I just checked the code and your assumption is correct. Without an explicit
partitioner, Flink just writes ProducerRecord without partition (null), so
that whatever Kafka usually does applies.
On Tue, Jan 5, 2021 at 1:53 AM Aeden Jameson
wrote:
> Based on these docs,
>
> https://ci.ap
Based on these docs,
https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/kafka.html,
the default partitioning behavior is not quite clear to me.
If no value for sink-partitioner is given, is the default behavior
just that of the native Kafka library? (with key use murm
