markusthoemmes commented on a change in pull request #3209: Make payload limit
configurable.
URL:
https://github.com/apache/incubator-openwhisk/pull/3209#discussion_r163247636
##########
File path:
common/scala/src/main/scala/whisk/connector/kafka/KafkaProducerConnector.scala
##########
@@ -87,6 +87,9 @@ class KafkaProducerConnector(kafkahosts: String,
val props = new Properties
props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkahosts)
props.put(ProducerConfig.ACKS_CONFIG, 1.toString)
+ // Allow messages with up to 5 MiB size
+ // The target topic must support this message size as well because it's
larger as the default
+ props.put(ProducerConfig.MAX_REQUEST_SIZE_CONFIG, 5242880.toString)
Review comment:
Presumably, yes. Need to thing how to cleverly thread that through ?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
