You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
to also pass payload size but it would violate https://github.com/mlowicki/librdkafka/blob/master/CONTRIBUTING.md#changes-to-existing-apis as e.g. signature of rd_kafka_topic_conf_set_partitioner_cb would change. Additional parameter could be used to implement more sophisticated partitioner like sticky partitioner based on the batch size so next partition will be elected when there is plenty data batched already to form big enough batch to sent to the current sticky partition.
Any thoughts on the change itself and how it could be rolled out to make sure we follow compatibility guarantees?
reacted with thumbs up emoji reacted with thumbs down emoji reacted with laugh emoji reacted with hooray emoji reacted with confused emoji reacted with heart emoji reacted with rocket emoji reacted with eyes emoji
-
I would like to change
librdkafka/src/rdkafka_msg.c
Lines 1192 to 1205 in 966b63d
Any thoughts on the change itself and how it could be rolled out to make sure we follow compatibility guarantees?
Beta Was this translation helpful? Give feedback.
All reactions