File tree Expand file tree Collapse file tree 1 file changed +1
-3
lines changed
spring-kafka-test/src/main/java/org/springframework/kafka/test Expand file tree Collapse file tree 1 file changed +1
-3
lines changed Original file line number Diff line number Diff line change @@ -228,9 +228,7 @@ public void afterPropertiesSet() {
228
228
brokerConfigProperties .setProperty (KafkaConfig .OffsetsTopicReplicationFactorProp (), "1" );
229
229
brokerConfigProperties .setProperty (KafkaConfig .ReplicaHighWatermarkCheckpointIntervalMsProp (),
230
230
String .valueOf (Long .MAX_VALUE ));
231
- if (this .brokerProperties != null ) {
232
- this .brokerProperties .forEach (brokerConfigProperties ::put );
233
- }
231
+ this .brokerProperties .forEach (brokerConfigProperties ::put );
234
232
if (!this .brokerProperties .containsKey (KafkaConfig .NumPartitionsProp ())) {
235
233
brokerConfigProperties .setProperty (KafkaConfig .NumPartitionsProp (), "" + this .partitionsPerTopic );
236
234
}
You can’t perform that action at this time.
0 commit comments