Configuring maximum message size limit

When running a Restore, Kannika Armory should automatically detect the maximum message size allowed for a topic during initialization and configure the producer accordingly.

However, should you need to set that limit explicitly, you can set the message.max.bytes property in the configuration of a Restore in spec.sinkAdditionalProps:.

apiVersion: kannika.io/v1alpha
kind: Restore
metadata:
  name: restore
spec:
  source: storage
  sink: kafka
  sinkAdditionalProps:
    message.max.bytes: "10485760" # must be a string (quoted)
  config:
    mapping:
      topic-with-large-messages:
        target: topic-with-large-messages

For more information about configuring properties, check the section about configuring additional properties.