@@ -187,7 +187,7 @@ public Receive createReceive() {
187
187
final int attempt = rejected .getAttempt ();
188
188
final Response response = rejected .getResponse ();
189
189
if (_retryableStatusCodes .contains (response .getStatusCode ()) && attempt < _sink .getMaximumAttempts ()) {
190
- LOGGER .warn ()
190
+ POST_RETRY_LOGGER .warn ()
191
191
.setMessage ("Attempt rejected" )
192
192
.addData ("sink" , _sink )
193
193
.addData ("status" , response .getStatusCode ())
@@ -206,7 +206,7 @@ public Receive createReceive() {
206
206
.match (PostFailure .class , failure -> {
207
207
final int attempt = failure .getAttempt ();
208
208
if (attempt < _sink .getMaximumAttempts ()) {
209
- LOGGER .warn ()
209
+ POST_RETRY_LOGGER .warn ()
210
210
.setMessage ("Attempt failed" )
211
211
.addData ("sink" , _sink )
212
212
.addData ("error" , failure .getCause ())
@@ -262,7 +262,7 @@ private void processRejectedRequest(final PostRejected rejected) {
262
262
responseStatusClass == i ? 1 : 0 );
263
263
}
264
264
265
- LOGGER .warn ()
265
+ POST_ERROR_LOGGER .warn ()
266
266
.setMessage ("Post rejected" )
267
267
.addData ("sink" , _sink )
268
268
.addData ("status" , responseStatusCode )
@@ -449,6 +449,7 @@ private void scheduleRetry(final RequestEntry requestEntry, final int attempt) {
449
449
private final String _samplesDroppedName ;
450
450
451
451
private static final Logger LOGGER = LoggerFactory .getLogger (HttpSinkActor .class );
452
+ private static final Logger POST_RETRY_LOGGER = LoggerFactory .getRateLimitLogger (HttpSinkActor .class , Duration .ofSeconds (30 ));
452
453
private static final Logger POST_ERROR_LOGGER = LoggerFactory .getRateLimitLogger (HttpSinkActor .class , Duration .ofSeconds (30 ));
453
454
private static final Logger EVICTED_LOGGER = LoggerFactory .getRateLimitLogger (HttpSinkActor .class , Duration .ofSeconds (30 ));
454
455
private static final ImmutableList <Integer > STATUS_CLASSES = com .google .common .collect .ImmutableList .of (2 , 3 , 4 , 5 );
0 commit comments