Affects Version/s: 0.8.0
Fix Version/s: 0.8.0
ProducerPool.scala contains the following code:
def createSyncProducer(configOpt: Option[ProducerConfig], broker: Broker): SyncProducer =
Note also, that ClientUtils.getTopicMetadata() does the following:
As a result there is no way to control the socket settings for the get metadata request.
My recommendation is that we require the config to be specified in the
Note that this creates a new sync producer without using ANY of the settings the user had given for the producer. In particular the socket timeout is defaulted to 500ms.
This causes unit tests to fail a lot since a newly started test may easily timeout on a 500ms request.