File tree Expand file tree Collapse file tree 1 file changed +0
-16
lines changed
spring-kafka/src/main/java/org/springframework/kafka/listener Expand file tree Collapse file tree 1 file changed +0
-16
lines changed Original file line number Diff line number Diff line change @@ -97,8 +97,6 @@ public class ConsumerProperties {
9797
9898 private LogIfLevelEnabled .Level commitLogLevel = LogIfLevelEnabled .Level .DEBUG ;
9999
100- private boolean onlyLogRecordMetadata = true ;
101-
102100 private Properties kafkaConsumerProperties = new Properties ();
103101
104102 private Duration authExceptionRetryInterval ;
@@ -402,20 +400,6 @@ public void setCommitRetries(int commitRetries) {
402400 this .commitRetries = commitRetries ;
403401 }
404402
405- public boolean isOnlyLogRecordMetadata () {
406- return this .onlyLogRecordMetadata ;
407- }
408-
409- /**
410- * Set to false to log {@code record.toString()} in log messages instead
411- * of {@code topic-partition@offset}.
412- * @param onlyLogRecordMetadata false to log the entire record.
413- * @since 2.2.14
414- */
415- public void setOnlyLogRecordMetadata (boolean onlyLogRecordMetadata ) {
416- this .onlyLogRecordMetadata = onlyLogRecordMetadata ;
417- }
418-
419403 /**
420404 * Whether or not to correct terminal transactional offsets.
421405 * @return true to fix.
You can’t perform that action at this time.
0 commit comments