trival change to increase default producer request timeout
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/7ad742d8 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/7ad742d8 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/7ad742d8 Branch: refs/heads/trunk Commit: 7ad742d802498542d0b60e87c331053805a94ac7 Parents: 23acbd3 Author: Jun Rao <jun...@gmail.com> Authored: Mon Jun 17 08:27:59 2013 -0700 Committer: Jun Rao <jun...@gmail.com> Committed: Mon Jun 17 08:27:59 2013 -0700 ---------------------------------------------------------------------- core/src/main/scala/kafka/producer/SyncProducerConfig.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/7ad742d8/core/src/main/scala/kafka/producer/SyncProducerConfig.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/kafka/producer/SyncProducerConfig.scala b/core/src/main/scala/kafka/producer/SyncProducerConfig.scala index ef32620..69b2d0c 100644 --- a/core/src/main/scala/kafka/producer/SyncProducerConfig.scala +++ b/core/src/main/scala/kafka/producer/SyncProducerConfig.scala @@ -58,5 +58,5 @@ trait SyncProducerConfigShared { object SyncProducerConfig { val DefaultClientId = "" val DefaultRequiredAcks : Short = 0 - val DefaultAckTimeoutMs = 1500 + val DefaultAckTimeoutMs = 10000 } \ No newline at end of file
