@@ -59,7 +59,10 @@ object ProducerConf {
59
59
.withFallback(kinesisConfig.getConfig(" default-producer" ))
60
60
61
61
val streamName = producerConfig.getString(" stream-name" )
62
- require(! streamName.isEmpty, s " Config field `stream-name` missing, a value must be provided to start the Kinesis Producer! " )
62
+ require(
63
+ ! streamName.isEmpty,
64
+ s " Config field `stream-name` missing, a value must be provided to start the Kinesis Producer! "
65
+ )
63
66
64
67
val dispatcher : Option [String ] =
65
68
if (producerConfig.getIsNull(" akka.dispatcher" ))
@@ -77,9 +80,9 @@ object ProducerConf {
77
80
buildKPLConfig(kplConfig, credentialsProvider)
78
81
79
82
new ProducerConf (streamName,
80
- kplLibConfiguration,
81
- dispatcher,
82
- parseThrottlingConfig(producerConfig))
83
+ kplLibConfiguration,
84
+ dispatcher,
85
+ parseThrottlingConfig(producerConfig))
83
86
}
84
87
85
88
private def buildKPLConfig (kplConfig : Config ,
@@ -109,18 +112,18 @@ object ProducerConf {
109
112
110
113
private def parseThrottlingConfig (producerConfig : Config ): Option [ThrottlingConf ] = {
111
114
if (! producerConfig.hasPath(" akka.max-outstanding-requests" )
112
- || producerConfig.getIsNull(" akka.max-outstanding-requests" ))
115
+ || producerConfig.getIsNull(" akka.max-outstanding-requests" ))
113
116
None
114
117
else {
115
118
val maxOutstandingRequests = producerConfig.getInt(" akka.max-outstanding-requests" )
116
119
117
120
if (! producerConfig.hasPath(" akka.throttling-retry-millis" )
118
- || producerConfig.getIsNull(" akka.throttling-retry-millis" ))
121
+ || producerConfig.getIsNull(" akka.throttling-retry-millis" ))
119
122
Some (ThrottlingConf (maxOutstandingRequests))
120
123
else
121
124
Some (
122
125
ThrottlingConf (maxOutstandingRequests,
123
- producerConfig.getLong(" akka.throttling-retry-millis" ).millis)
126
+ producerConfig.getLong(" akka.throttling-retry-millis" ).millis)
124
127
)
125
128
}
126
129
}
0 commit comments