@@ -177,7 +177,7 @@ void setDeleteStreams(String input) throws Exception {
177
177
this .deleteStreams = Converters .BOOLEAN_TYPE_CONVERTER .convert (input );
178
178
}
179
179
180
- boolean deleteStreams ;
180
+ volatile boolean deleteStreams ;
181
181
182
182
@ CommandLine .Option (
183
183
names = {"--offset" , "-o" },
@@ -279,7 +279,7 @@ void setVersion(String input) throws Exception {
279
279
this .version = Converters .BOOLEAN_TYPE_CONVERTER .convert (input );
280
280
}
281
281
282
- boolean version ;
282
+ volatile boolean version ;
283
283
284
284
@ CommandLine .Option (
285
285
names = {"--summary-file" , "-sf" },
@@ -291,7 +291,7 @@ void setSummaryFile(String input) throws Exception {
291
291
this .summaryFile = Converters .BOOLEAN_TYPE_CONVERTER .convert (input );
292
292
}
293
293
294
- boolean summaryFile ;
294
+ volatile boolean summaryFile ;
295
295
296
296
@ CommandLine .Option (
297
297
names = {"--producers-by-connection" , "-pbc" },
@@ -335,7 +335,7 @@ void setLoadBalancer(String input) throws Exception {
335
335
this .loadBalancer = Converters .BOOLEAN_TYPE_CONVERTER .convert (input );
336
336
}
337
337
338
- boolean loadBalancer ;
338
+ volatile boolean loadBalancer ;
339
339
340
340
@ CommandLine .Option (
341
341
names = {"--consumer-names" , "-cn" },
@@ -356,7 +356,7 @@ void setIncludeByteRates(String input) throws Exception {
356
356
this .includeByteRates = Converters .BOOLEAN_TYPE_CONVERTER .convert (input );
357
357
}
358
358
359
- boolean includeByteRates ;
359
+ volatile boolean includeByteRates ;
360
360
361
361
@ CommandLine .Option (
362
362
names = {"--memory-report" , "-mr" },
@@ -368,7 +368,7 @@ void setMemoryReport(String input) throws Exception {
368
368
this .memoryReport = Converters .BOOLEAN_TYPE_CONVERTER .convert (input );
369
369
}
370
370
371
- boolean memoryReport ;
371
+ volatile boolean memoryReport ;
372
372
373
373
@ CommandLine .Option (
374
374
names = {"--server-name-indication" , "-sni" },
@@ -393,7 +393,7 @@ void setEnvironmentVariables(String input) throws Exception {
393
393
this .environmentVariables = Converters .BOOLEAN_TYPE_CONVERTER .convert (input );
394
394
}
395
395
396
- boolean environmentVariables ;
396
+ volatile boolean environmentVariables ;
397
397
398
398
@ CommandLine .Option (
399
399
names = {"--rpc-timeout" , "-rt" },
@@ -412,7 +412,7 @@ void setConfirmLatency(String input) throws Exception {
412
412
this .confirmLatency = Converters .BOOLEAN_TYPE_CONVERTER .convert (input );
413
413
}
414
414
415
- boolean confirmLatency ;
415
+ volatile boolean confirmLatency ;
416
416
417
417
@ CommandLine .Option (
418
418
names = {"--super-streams" , "-sst" },
@@ -424,7 +424,7 @@ void setSuperStreams(String input) throws Exception {
424
424
this .superStreams = Converters .BOOLEAN_TYPE_CONVERTER .convert (input );
425
425
}
426
426
427
- boolean superStreams ;
427
+ volatile boolean superStreams ;
428
428
429
429
@ CommandLine .Option (
430
430
names = {"--super-stream-partitions" , "-ssp" },
@@ -474,7 +474,7 @@ void setMetricsCommandLineArguments(String input) throws Exception {
474
474
this .metricsCommandLineArguments = Converters .BOOLEAN_TYPE_CONVERTER .convert (input );
475
475
}
476
476
477
- boolean metricsCommandLineArguments ;
477
+ volatile boolean metricsCommandLineArguments ;
478
478
479
479
@ CommandLine .Option (
480
480
names = {"--requested-max-frame-size" , "-rmfs" },
@@ -493,7 +493,7 @@ void setNativeEpoll(String input) throws Exception {
493
493
this .nativeEpoll = Converters .BOOLEAN_TYPE_CONVERTER .convert (input );
494
494
}
495
495
496
- boolean nativeEpoll ;
496
+ volatile boolean nativeEpoll ;
497
497
498
498
@ ArgGroup (exclusive = false , multiplicity = "0..1" )
499
499
InstanceSyncOptions instanceSyncOptions ;
@@ -527,7 +527,7 @@ void setForceReplicaForConsumers(String input) throws Exception {
527
527
this .forceReplicaForConsumers = Converters .BOOLEAN_TYPE_CONVERTER .convert (input );
528
528
}
529
529
530
- boolean forceReplicaForConsumers ;
530
+ volatile boolean forceReplicaForConsumers ;
531
531
532
532
@ CommandLine .Option (
533
533
names = {"--no-dev-mode" , "-ndm" },
@@ -539,7 +539,7 @@ void setNoDevMode(String input) throws Exception {
539
539
this .noDevMode = Converters .BOOLEAN_TYPE_CONVERTER .convert (input );
540
540
}
541
541
542
- boolean noDevMode ;
542
+ volatile boolean noDevMode ;
543
543
544
544
@ CommandLine .Option (
545
545
names = {"--dynamic-batch-size" , "-dbs" },
@@ -563,7 +563,7 @@ void setIncludeByteSizeMetric(String input) throws Exception {
563
563
this .includeBatchSizeMetric = Converters .BOOLEAN_TYPE_CONVERTER .convert (input );
564
564
}
565
565
566
- boolean includeBatchSizeMetric ;
566
+ volatile boolean includeBatchSizeMetric ;
567
567
568
568
static class InstanceSyncOptions {
569
569
0 commit comments