File tree Expand file tree Collapse file tree 2 files changed +2
-8
lines changed
spring-kafka/src/main/java/org/springframework/kafka Expand file tree Collapse file tree 2 files changed +2
-8
lines changed Original file line number Diff line number Diff line change @@ -137,7 +137,7 @@ public void setStreamsConfiguration(Properties streamsConfig) {
137137
138138 @ Nullable
139139 public Properties getStreamsConfiguration () {
140- return this .properties ;
140+ return this .properties ; // NOSONAR - inconsistent synchronization
141141 }
142142
143143 public void setClientSupplier (KafkaClientSupplier clientSupplier ) {
@@ -281,10 +281,4 @@ public synchronized boolean isRunning() {
281281 return this .running ;
282282 }
283283
284- private Properties propertiesFromConfigs (Map <String , Object > configs ) {
285- Properties props = new Properties ();
286- props .putAll (configs );
287- return props ;
288- }
289-
290284}
Original file line number Diff line number Diff line change @@ -451,7 +451,7 @@ public void stop(Runnable callback) {
451451 * @return the {@link ConsumerRebalanceListener} currently assigned to this container.
452452 */
453453 protected final ConsumerRebalanceListener createSimpleLoggingConsumerRebalanceListener () {
454- return new ConsumerRebalanceListener () {
454+ return new ConsumerRebalanceListener () { // NOSONAR - anonymous inner class length
455455
456456 @ Override
457457 public void onPartitionsRevoked (Collection <TopicPartition > partitions ) {
You can’t perform that action at this time.
0 commit comments