Skip to content

Commit bd6fc4f

Browse files
author
Stephen Powis
committed
reduce log level to debug
1 parent 994fa30 commit bd6fc4f

File tree

2 files changed

+5
-5
lines changed

2 files changed

+5
-5
lines changed

src/main/java/org/sourcelab/kafka/connect/apiclient/KafkaConnectClient.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -272,7 +272,7 @@ private <T> T submitRequest(final Request<T> request) {
272272
String responseStr = restResponse.getResponseStr();
273273

274274
// If we have a valid response
275-
logger.info("Response: {}", restResponse);
275+
logger.debug("Response: {}", restResponse);
276276

277277
// Check for invalid http status codes
278278
if (responseCode >= 200 && responseCode < 300) {

src/main/java/org/sourcelab/kafka/connect/apiclient/rest/HttpClientRestClient.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -211,7 +211,7 @@ private <T> T submitGetRequest(final String url, final Map<String, String> getPa
211211
// Conditionally add content-type header?
212212
get.addHeader(new BasicHeader("Content-Type", "application/json"));
213213

214-
logger.info("Executing request {}", get.getRequestLine());
214+
logger.debug("Executing request {}", get.getRequestLine());
215215

216216
// Execute and return
217217
return httpClient.execute(get, responseHandler);
@@ -253,7 +253,7 @@ private <T> T submitPostRequest(final String url, final Object requestBody, fina
253253

254254
post.setEntity(new StringEntity(jsonPayloadStr));
255255

256-
logger.info("Executing request {} with {}", post.getRequestLine(), jsonPayloadStr);
256+
logger.debug("Executing request {} with {}", post.getRequestLine(), jsonPayloadStr);
257257

258258
// Execute and return
259259
return httpClient.execute(post, responseHandler);
@@ -292,7 +292,7 @@ private <T> T submitPutRequest(final String url, final Object requestBody, final
292292
final String jsonPayloadStr = JacksonFactory.newInstance().writeValueAsString(requestBody);
293293
put.setEntity(new StringEntity(jsonPayloadStr));
294294

295-
logger.info("Executing request {} with {}", put.getRequestLine(), jsonPayloadStr);
295+
logger.debug("Executing request {} with {}", put.getRequestLine(), jsonPayloadStr);
296296

297297
// Execute and return
298298
return httpClient.execute(put, responseHandler);
@@ -336,7 +336,7 @@ private <T> T submitDeleteRequest(final String url, final Object requestBody, fi
336336
// Convert to Json
337337
final String jsonPayloadStr = JacksonFactory.newInstance().writeValueAsString(requestBody);
338338

339-
logger.info("Executing request {} with {}", delete.getRequestLine(), jsonPayloadStr);
339+
logger.debug("Executing request {} with {}", delete.getRequestLine(), jsonPayloadStr);
340340

341341
// Execute and return
342342
return httpClient.execute(delete, responseHandler);

0 commit comments

Comments
 (0)