Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

As part of the client-side configuration for producers, the following property could be added: socketmax.response.max.bytessize

It could be set as any other producer or consumer property:


Code Block
languagejava
Properties kafkaProducerConfigs = new Properties();
kafkaProducerConfigs.setProperty("socket.response.max.bytes", "104857600");
...
KafkaProducer<String, String> producer = new KafkaProducer<>(kafkaProducerConfigs);



Code Block
languagejava
Properties kafkaConsumerConfigs = new Properties();
kafkaConsumerConfigs.setProperty("socket.response.max.bytes", "104857600");
...
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(kafkaProducerConfigs);



Proposed Changes

This new element of configuration was originally suggested on the discussion thread and mirrors what already exists server-side, i.e. the property socket.request.max.bytes - which was actually added in brokers for the very same reason. 

...