Skip to content

Commit b91dcd5

Browse files
scala-stewardscala-steward
committed
Reformat with sbt-java-formatter 0.10.0
Executed command: sbt javafmtAll
1 parent 1423580 commit b91dcd5

File tree

9 files changed

+101
-87
lines changed

9 files changed

+101
-87
lines changed

‎tests/src/test/java/docs/javadsl/AssignmentTest.java‎

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,8 @@
55

66
package docs.javadsl;
77

8+
import static org.junit.Assert.assertEquals;
9+
810
import akka.Done;
911
import akka.actor.ActorSystem;
1012
import akka.kafka.AutoSubscription;
@@ -13,31 +15,29 @@
1315
import akka.kafka.Subscriptions;
1416
import akka.kafka.javadsl.Consumer;
1517
// #testkit
18+
import akka.kafka.javadsl.Producer;
1619
import akka.kafka.testkit.javadsl.TestcontainersKafkaJunit4Test;
1720
// #testkit
18-
import akka.kafka.javadsl.Producer;
1921
import akka.kafka.tests.javadsl.LogCapturingJunit4;
2022
import akka.stream.javadsl.Sink;
2123
import akka.stream.javadsl.Source;
2224
// #testkit
2325
import akka.testkit.javadsl.TestKit;
2426
// #testkit
27+
import java.util.Arrays;
28+
import java.util.List;
29+
import java.util.concurrent.CompletionStage;
30+
import java.util.stream.Collectors;
31+
import java.util.stream.IntStream;
2532
import org.apache.kafka.clients.consumer.ConsumerRecord;
2633
import org.apache.kafka.clients.producer.ProducerRecord;
2734
import org.apache.kafka.common.TopicPartition;
2835
// #testkit
2936
import org.junit.AfterClass;
30-
import org.junit.Test;
31-
// #testkit
3237
import org.junit.Rule;
38+
import org.junit.Test;
3339

34-
import java.util.Arrays;
35-
import java.util.List;
36-
import java.util.concurrent.CompletionStage;
37-
import java.util.stream.Collectors;
38-
import java.util.stream.IntStream;
39-
40-
import static org.junit.Assert.assertEquals;
40+
// #testkit
4141

4242
// #testkit
4343

‎tests/src/test/java/docs/javadsl/ClusterShardingExample.java‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,7 @@ static final class User {
4040
this.mame = mame;
4141
}
4242
}
43+
4344
// #user-entity
4445

4546
public static Behavior<User> userBehaviour() {

‎tests/src/test/java/docs/javadsl/ConsumerExampleTest.java‎

Lines changed: 24 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,10 @@
55

66
package docs.javadsl;
77

8+
import static org.hamcrest.CoreMatchers.*;
9+
import static org.hamcrest.MatcherAssert.*;
10+
import static org.junit.Assert.assertEquals;
11+
812
import akka.Done;
913
import akka.NotUsed;
1014
import akka.actor.AbstractLoggingActor;
@@ -13,25 +17,36 @@
1317
import akka.actor.Props;
1418
import akka.actor.typed.Behavior;
1519
import akka.actor.typed.javadsl.ActorContext;
20+
import akka.actor.typed.javadsl.Adapter;
21+
// #consumerActorTyped
22+
// #withTypedRebalanceListenerActor
1623
import akka.actor.typed.javadsl.Behaviors;
1724
// #withTypedRebalanceListenerActor
1825
// #consumerActorTyped
1926
// adds support for actors to a classic actor system and context
20-
import akka.actor.typed.javadsl.Adapter;
21-
// #consumerActorTyped
22-
// #withTypedRebalanceListenerActor
2327
import akka.japi.Pair;
2428
import akka.kafka.*;
2529
import akka.kafka.javadsl.Committer;
2630
import akka.kafka.javadsl.Consumer;
27-
import akka.kafka.javadsl.Producer;
2831
import akka.kafka.javadsl.PartitionAssignmentHandler;
32+
import akka.kafka.javadsl.Producer;
2933
import akka.kafka.testkit.javadsl.TestcontainersKafkaTest;
3034
import akka.kafka.tests.javadsl.LogCapturingExtension;
3135
import akka.stream.RestartSettings;
3236
import akka.stream.javadsl.*;
3337
import akka.testkit.javadsl.TestKit;
3438
import com.typesafe.config.Config;
39+
import java.time.Duration;
40+
import java.util.List;
41+
import java.util.Map;
42+
import java.util.Set;
43+
import java.util.concurrent.CompletableFuture;
44+
import java.util.concurrent.CompletionStage;
45+
import java.util.concurrent.Executor;
46+
import java.util.concurrent.Executors;
47+
import java.util.concurrent.atomic.AtomicLong;
48+
import java.util.concurrent.atomic.AtomicReference;
49+
import java.util.function.Function;
3550
import org.apache.kafka.clients.consumer.ConsumerConfig;
3651
import org.apache.kafka.clients.consumer.ConsumerRecord;
3752
import org.apache.kafka.clients.producer.ProducerRecord;
@@ -45,22 +60,6 @@
4560
import org.junit.jupiter.api.TestInstance;
4661
import org.junit.jupiter.api.extension.ExtendWith;
4762

48-
import java.time.Duration;
49-
import java.util.List;
50-
import java.util.Map;
51-
import java.util.Set;
52-
import java.util.concurrent.CompletableFuture;
53-
import java.util.concurrent.CompletionStage;
54-
import java.util.concurrent.Executor;
55-
import java.util.concurrent.Executors;
56-
import java.util.concurrent.atomic.AtomicLong;
57-
import java.util.concurrent.atomic.AtomicReference;
58-
import java.util.function.Function;
59-
60-
import static org.hamcrest.CoreMatchers.*;
61-
import static org.hamcrest.MatcherAssert.*;
62-
import static org.junit.Assert.assertEquals;
63-
6463
@TestInstance(TestInstance.Lifecycle.PER_CLASS)
6564
@ExtendWith(LogCapturingExtension.class)
6665
class ConsumerExampleTest extends TestcontainersKafkaTest {
@@ -99,6 +98,7 @@ private <T> Flow<T, T, NotUsed> business() {
9998
consumerSettings
10099
.withProperty(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, "true")
101100
.withProperty(ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG, "5000");
101+
102102
// #settings-autocommit
103103

104104
@Test
@@ -156,6 +156,7 @@ public CompletionStage<Done> storeProcessedOffset(long offset) { // ... }
156156

157157
// #plainSource
158158
}
159+
159160
// #plainSource
160161

161162
@Test
@@ -640,7 +641,9 @@ void consumerMetrics() throws Exception {
640641
// #consumerMetrics
641642
sleepMillis(
642643
100,
643-
"to let the control establish itself (fails with `java.lang.IllegalStateException: not yet initialized: only setHandler is allowed in GraphStageLogic constructor)` otherwise");
644+
"to let the control establish itself (fails with `java.lang.IllegalStateException: not yet"
645+
+ " initialized: only setHandler is allowed in GraphStageLogic constructor)`"
646+
+ " otherwise");
644647
// #consumerMetrics
645648
CompletionStage<Map<MetricName, Metric>> metrics = control.getMetrics();
646649
metrics.thenAccept(map -> System.out.println("Metrics: " + map));

‎tests/src/test/java/docs/javadsl/ConsumerSettingsTest.java‎

Lines changed: 11 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,8 @@
55

66
package docs.javadsl;
77

8+
import static org.junit.jupiter.api.Assertions.*;
9+
810
import akka.actor.ActorSystem;
911
import akka.kafka.ConsumerSettings;
1012
import akka.kafka.ConsumerSettingsSpec$;
@@ -18,8 +20,6 @@
1820
import org.apache.kafka.common.serialization.StringDeserializer;
1921
import org.junit.jupiter.api.Test;
2022

21-
import static org.junit.jupiter.api.Assertions.*;
22-
2323
public class ConsumerSettingsTest {
2424

2525
@Test
@@ -44,13 +44,15 @@ public void discoverySetup() throws Exception {
4444
@Test
4545
public void setAssignor() throws Exception {
4646
ActorSystem system = ActorSystem.create("ConsumerSettingsTest");
47-
ConsumerSettings<String, String> settings = ConsumerSettings.create(system, new StringDeserializer(), new StringDeserializer())
48-
.withPartitionAssignmentStrategies(new String[] {
49-
org.apache.kafka.clients.consumer.CooperativeStickyAssignor.class.getName(),
50-
org.apache.kafka.clients.consumer.StickyAssignor.class.getName()
51-
});
47+
ConsumerSettings<String, String> settings =
48+
ConsumerSettings.create(system, new StringDeserializer(), new StringDeserializer())
49+
.withPartitionAssignmentStrategies(
50+
new String[] {
51+
org.apache.kafka.clients.consumer.CooperativeStickyAssignor.class.getName(),
52+
org.apache.kafka.clients.consumer.StickyAssignor.class.getName()
53+
});
5254
assertEquals(
53-
settings.getProperty(ConsumerConfig.PARTITION_ASSIGNMENT_STRATEGY_CONFIG),
54-
"org.apache.kafka.clients.consumer.CooperativeStickyAssignor,org.apache.kafka.clients.consumer.StickyAssignor");
55+
settings.getProperty(ConsumerConfig.PARTITION_ASSIGNMENT_STRATEGY_CONFIG),
56+
"org.apache.kafka.clients.consumer.CooperativeStickyAssignor,org.apache.kafka.clients.consumer.StickyAssignor");
5557
}
5658
}

‎tests/src/test/java/docs/javadsl/MetadataClientTest.java‎

Lines changed: 13 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -6,22 +6,19 @@
66
package docs.javadsl;
77

88
// #metadataClient
9+
import static java.util.stream.Collectors.toSet;
10+
import static org.hamcrest.MatcherAssert.assertThat;
11+
import static org.hamcrest.Matchers.containsInAnyOrder;
12+
import static org.hamcrest.core.Is.is;
13+
914
import akka.actor.ActorSystem;
1015
import akka.kafka.ConsumerSettings;
1116
import akka.kafka.javadsl.MetadataClient;
1217
import akka.kafka.testkit.javadsl.TestcontainersKafkaJunit4Test;
18+
import akka.kafka.tests.javadsl.LogCapturingJunit4;
1319
import akka.testkit.javadsl.TestKit;
1420
import akka.util.Timeout;
1521
// #metadataClient
16-
import akka.kafka.tests.javadsl.LogCapturingJunit4;
17-
import org.apache.kafka.common.PartitionInfo;
18-
import org.apache.kafka.common.TopicPartition;
19-
import org.hamcrest.core.IsInstanceOf;
20-
import org.junit.AfterClass;
21-
import org.junit.Rule;
22-
import org.junit.Test;
23-
import org.junit.rules.ExpectedException;
24-
2522
import java.util.Collections;
2623
import java.util.List;
2724
import java.util.Map;
@@ -31,11 +28,13 @@
3128
import java.util.concurrent.Executor;
3229
import java.util.concurrent.Executors;
3330
import java.util.concurrent.TimeUnit;
34-
35-
import static java.util.stream.Collectors.toSet;
36-
import static org.hamcrest.MatcherAssert.assertThat;
37-
import static org.hamcrest.Matchers.containsInAnyOrder;
38-
import static org.hamcrest.core.Is.is;
31+
import org.apache.kafka.common.PartitionInfo;
32+
import org.apache.kafka.common.TopicPartition;
33+
import org.hamcrest.core.IsInstanceOf;
34+
import org.junit.AfterClass;
35+
import org.junit.Rule;
36+
import org.junit.Test;
37+
import org.junit.rules.ExpectedException;
3938

4039
public class MetadataClientTest extends TestcontainersKafkaJunit4Test {
4140

‎tests/src/test/java/docs/javadsl/ProducerTest.java‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,9 @@
55

66
package docs.javadsl;
77

8+
import static org.junit.Assert.assertEquals;
9+
import static org.junit.Assert.assertFalse;
10+
811
import akka.Done;
912
import akka.actor.ActorSystem;
1013
import akka.kafka.*;
@@ -20,6 +23,10 @@
2023
import akka.testkit.javadsl.TestKit;
2124
// #testkit
2225
import com.typesafe.config.Config;
26+
import java.util.Arrays;
27+
import java.util.List;
28+
import java.util.Map;
29+
import java.util.concurrent.*;
2330
import org.apache.kafka.clients.consumer.ConsumerRecord;
2431
import org.apache.kafka.clients.producer.ProducerRecord;
2532
import org.apache.kafka.clients.producer.RecordMetadata;
@@ -28,15 +35,8 @@
2835
import org.junit.jupiter.api.*;
2936
import org.junit.jupiter.api.TestInstance.Lifecycle;
3037
import org.junit.jupiter.api.extension.ExtendWith;
31-
// #testkit
3238

33-
import java.util.Arrays;
34-
import java.util.List;
35-
import java.util.Map;
36-
import java.util.concurrent.*;
37-
38-
import static org.junit.Assert.assertEquals;
39-
import static org.junit.Assert.assertFalse;
39+
// #testkit
4040

4141
// #testkit
4242

‎tests/src/test/java/docs/javadsl/SchemaRegistrySerializationTest.java‎

Lines changed: 11 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,9 @@
55

66
package docs.javadsl;
77

8+
import static org.hamcrest.CoreMatchers.is;
9+
import static org.hamcrest.MatcherAssert.assertThat;
10+
811
import akka.Done;
912
import akka.actor.ActorSystem;
1013
import akka.kafka.ConsumerSettings;
@@ -23,6 +26,14 @@
2326
import io.confluent.kafka.serializers.KafkaAvroDeserializer;
2427
import io.confluent.kafka.serializers.KafkaAvroSerializer;
2528
// #imports
29+
import java.util.Arrays;
30+
import java.util.HashMap;
31+
import java.util.List;
32+
import java.util.Map;
33+
import java.util.concurrent.CompletionStage;
34+
import java.util.concurrent.Executor;
35+
import java.util.concurrent.Executors;
36+
import java.util.concurrent.TimeUnit;
2637
import org.apache.kafka.clients.consumer.ConsumerConfig;
2738
import org.apache.kafka.clients.consumer.ConsumerRecord;
2839
import org.apache.kafka.clients.producer.ProducerRecord;
@@ -35,18 +46,6 @@
3546
import org.junit.AfterClass;
3647
import org.junit.Test;
3748

38-
import java.util.Arrays;
39-
import java.util.HashMap;
40-
import java.util.List;
41-
import java.util.Map;
42-
import java.util.concurrent.CompletionStage;
43-
import java.util.concurrent.Executor;
44-
import java.util.concurrent.Executors;
45-
import java.util.concurrent.TimeUnit;
46-
47-
import static org.hamcrest.CoreMatchers.is;
48-
import static org.hamcrest.MatcherAssert.assertThat;
49-
5049
// #schema-registry-settings
5150
public class SchemaRegistrySerializationTest extends TestcontainersKafkaJunit4Test {
5251

‎tests/src/test/java/docs/javadsl/SerializationTest.java‎

Lines changed: 12 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,9 @@
55

66
package docs.javadsl;
77

8+
import static org.hamcrest.CoreMatchers.is;
9+
import static org.hamcrest.MatcherAssert.assertThat;
10+
811
import akka.Done;
912
import akka.actor.ActorSystem;
1013
import akka.kafka.ConsumerSettings;
@@ -19,34 +22,30 @@
1922
import akka.stream.javadsl.Source;
2023
import akka.testkit.javadsl.TestKit;
2124
// #jackson-imports
22-
import com.fasterxml.jackson.databind.ObjectMapper;
23-
import com.fasterxml.jackson.databind.ObjectReader;
24-
import com.fasterxml.jackson.databind.ObjectWriter;
2525
import com.fasterxml.jackson.core.JsonParseException;
2626
// #jackson-imports
2727
// #protobuf-imports
2828
// the Protobuf generated class
29+
import com.fasterxml.jackson.databind.ObjectMapper;
30+
import com.fasterxml.jackson.databind.ObjectReader;
31+
import com.fasterxml.jackson.databind.ObjectWriter;
2932
import docs.javadsl.proto.OrderMessages;
33+
import java.nio.charset.StandardCharsets;
34+
import java.util.Arrays;
35+
import java.util.List;
36+
import java.util.concurrent.*;
37+
import org.apache.kafka.clients.consumer.ConsumerRecord;
38+
import org.apache.kafka.clients.producer.ProducerRecord;
3039
import org.apache.kafka.common.serialization.ByteArrayDeserializer;
3140
import org.apache.kafka.common.serialization.ByteArraySerializer;
3241
// #protobuf-imports
33-
import org.apache.kafka.clients.consumer.ConsumerRecord;
34-
import org.apache.kafka.clients.producer.ProducerRecord;
3542
import org.apache.kafka.common.serialization.StringDeserializer;
3643
import org.apache.kafka.common.serialization.StringSerializer;
3744
import org.junit.jupiter.api.AfterAll;
3845
import org.junit.jupiter.api.Test;
3946
import org.junit.jupiter.api.TestInstance;
4047
import org.junit.jupiter.api.extension.ExtendWith;
4148

42-
import java.nio.charset.StandardCharsets;
43-
import java.util.Arrays;
44-
import java.util.List;
45-
import java.util.concurrent.*;
46-
47-
import static org.hamcrest.CoreMatchers.is;
48-
import static org.hamcrest.MatcherAssert.assertThat;
49-
5049
@TestInstance(TestInstance.Lifecycle.PER_CLASS)
5150
@ExtendWith(LogCapturingExtension.class)
5251
public class SerializationTest extends TestcontainersKafkaTest {

0 commit comments

Comments
 (0)