Skip to content

Commit 131f124

Browse files
authored
Merge branch 'eugenp:master' into BAEL-9151
2 parents c766df9 + ddff9b1 commit 131f124

File tree

317 files changed

+3753
-600
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

317 files changed

+3753
-600
lines changed

akka-modules/akka-http/pom.xml

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@
2121
<dependency>
2222
<groupId>com.typesafe.akka</groupId>
2323
<artifactId>akka-stream_${scala.version}</artifactId>
24-
<version>${akka.stream.version}</version>
24+
<version>${akkastreams.version}</version>
2525
</dependency>
2626
<dependency>
2727
<groupId>com.typesafe.akka</groupId>
@@ -38,7 +38,6 @@
3838

3939
<properties>
4040
<akka.http.version>10.0.11</akka.http.version>
41-
<akka.stream.version>2.5.11</akka.stream.version>
4241
</properties>
4342

4443
</project>

akka-modules/akka-streams/pom.xml

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -25,8 +25,4 @@
2525
</dependency>
2626
</dependencies>
2727

28-
<properties>
29-
<akkastreams.version>2.5.2</akkastreams.version>
30-
</properties>
31-
3228
</project>

akka-modules/pom.xml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,7 @@
3333

3434
<properties>
3535
<scala.version>2.12</scala.version>
36+
<akkastreams.version>2.5.11</akkastreams.version>
3637
</properties>
3738

3839
</project>

algorithms-modules/algorithms-miscellaneous-1/pom.xml

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,6 @@
6868
</reporting>
6969

7070
<properties>
71-
<combinatoricslib3.version>3.3.0</combinatoricslib3.version>
7271
<xml-bind-api.version>4.0.0</xml-bind-api.version>
7372
</properties>
7473

algorithms-modules/algorithms-miscellaneous-4/pom.xml

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -37,8 +37,4 @@
3737
</dependency>
3838
</dependencies>
3939

40-
<properties>
41-
<combinatoricslib3.version>3.3.3</combinatoricslib3.version>
42-
</properties>
43-
4440
</project>

algorithms-modules/pom.xml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,7 @@
3737
<commons-math3.version>3.6.1</commons-math3.version>
3838
<cobertura.plugin.version>2.7</cobertura.plugin.version>
3939
<tradukisto.version>1.0.1</tradukisto.version>
40+
<combinatoricslib3.version>3.3.3</combinatoricslib3.version>
4041
</properties>
4142

4243
</project>

apache-cxf-modules/cxf-introduction/pom.xml

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -47,9 +47,4 @@
4747
</plugins>
4848
</build>
4949

50-
<properties>
51-
<jakarta-xml.version>4.0.0</jakarta-xml.version>
52-
<jakarta.jws.version>3.0.0</jakarta.jws.version>
53-
</properties>
54-
5550
</project>

apache-cxf-modules/cxf-jaxrs-implementation/pom.xml

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@
3131
<dependency>
3232
<groupId>jakarta.jws</groupId>
3333
<artifactId>jakarta.jws-api</artifactId>
34-
<version>${jakarta-jws.version}</version>
34+
<version>${jakarta.jws.version}</version>
3535
</dependency>
3636
<dependency>
3737
<groupId>jakarta.platform</groupId>
@@ -66,8 +66,6 @@
6666

6767
<properties>
6868
<httpclient.version>4.5.2</httpclient.version>
69-
<jakarta-xml.version>4.0.0</jakarta-xml.version>
70-
<jakarta-jws.version>3.0.0</jakarta-jws.version>
7169
<jakarta-platform.version>9.0.0</jakarta-platform.version>
7270
</properties>
7371

apache-cxf-modules/pom.xml

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -38,6 +38,8 @@
3838
<properties>
3939
<cxf.version>4.0.0</cxf.version>
4040
<jakarta-ws.version>3.1.0</jakarta-ws.version>
41+
<jakarta.jws.version>3.0.0</jakarta.jws.version>
42+
<jakarta-xml.version>4.0.0</jakarta-xml.version>
4143
</properties>
4244

4345
</project>
Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
package com.baeldung.kafka;
2+
3+
import java.util.Collections;
4+
import java.util.Properties;
5+
6+
import org.apache.kafka.clients.admin.AdminClient;
7+
import org.apache.kafka.clients.admin.NewPartitions;
8+
9+
public class KafkaAddPartitionExample {
10+
11+
public static void main(String[] args) {
12+
Properties props = new Properties();
13+
props.put("bootstrap.servers", "localhost:9092");
14+
try (AdminClient adminClient = AdminClient.create(props)) {
15+
adminClient.createPartitions(Collections.singletonMap("my-topic", NewPartitions.increaseTo(3)))
16+
.all()
17+
.get();
18+
} catch (Exception e) {
19+
throw new RuntimeException(e);
20+
}
21+
}
22+
23+
}

0 commit comments

Comments
 (0)