Daisuke Kobayashi
Daisuke Kobayashi
Added tests. Below runs tests and outputs results. ``` $ ./schemas_command_generator.py dummy -t ##### Test: offset not in order ##### Original: [ {"topic": "_schemas", "key": "{\"keytype\":\"NOOP\",\"magic\":0}", "value": "", "offset": 0},...
@andrewhsu , this can be closed.
@fabriziofortino, if you're still seeing `MESSAGE_TOO_LARGE`, it's possible that the property isn't set in the server side. Can you let us know the result of `rpk cluster config get kafka_batch_max_bytes`?
@fabriziofortino, seems like it's bounded by the underlying go library, [franz-go](https://github.com/twmb/franz-go), which enforces the max batch size at the client side. Apparently there's no way to tweak from rpk side,...
/backport v22.2.8
/backport v22.3.4
Fixed the failed test.
/backport v22.2.x
/backport v22.3.x
`rpk cluster partitions move` is the thing. I'm happy to help to documenting it.