File tree Expand file tree Collapse file tree 3 files changed +0
-48
lines changed
src/test/java/org/apache/flink/streaming/connectors/kafka Expand file tree Collapse file tree 3 files changed +0
-48
lines changed Original file line number Diff line number Diff line change @@ -133,32 +133,6 @@ under the License.
133
133
<type >test-jar</type >
134
134
</dependency >
135
135
136
-
137
- <dependency >
138
- <!-- include kafka server for tests -->
139
- <groupId >org.apache.kafka</groupId >
140
- <artifactId >kafka_${scala.binary.version}</artifactId >
141
- <version >${kafka.version} </version >
142
- <exclusions >
143
- <exclusion >
144
- <groupId >org.slf4j</groupId >
145
- <artifactId >slf4j-api</artifactId >
146
- </exclusion >
147
- <exclusion >
148
- <groupId >io.dropwizard.metrics</groupId >
149
- <artifactId >metrics-core</artifactId >
150
- </exclusion >
151
- </exclusions >
152
- <scope >test</scope >
153
- </dependency >
154
-
155
- <dependency >
156
- <groupId >org.apache.zookeeper</groupId >
157
- <artifactId >zookeeper</artifactId >
158
- <version >${zookeeper.version} </version >
159
- <scope >test</scope >
160
- </dependency >
161
-
162
136
<dependency >
163
137
<groupId >org.testcontainers</groupId >
164
138
<artifactId >kafka</artifactId >
Original file line number Diff line number Diff line change 55
55
import java .util .List ;
56
56
import java .util .Properties ;
57
57
import java .util .Set ;
58
- import java .util .concurrent .TimeUnit ;
59
58
import java .util .concurrent .atomic .AtomicReference ;
60
59
61
- import scala .concurrent .duration .FiniteDuration ;
62
-
63
60
import static org .assertj .core .api .Assertions .fail ;
64
61
65
62
/**
@@ -92,8 +89,6 @@ public abstract class KafkaTestBase extends TestLogger {
92
89
93
90
public static Properties standardProps ;
94
91
95
- public static FiniteDuration timeout = new FiniteDuration (10 , TimeUnit .SECONDS );
96
-
97
92
public static KafkaTestEnvironment kafkaServer ;
98
93
99
94
public static List <KafkaClusterTestEnvMetadata > kafkaClusters = new ArrayList <>();
Original file line number Diff line number Diff line change @@ -52,7 +52,6 @@ under the License.
52
52
<properties >
53
53
<flink .version>1.17.0</flink .version>
54
54
<kafka .version>3.4.0</kafka .version>
55
- <zookeeper .version>3.7.2</zookeeper .version>
56
55
<confluent .version>7.4.4</confluent .version>
57
56
58
57
<jackson-bom .version>2.15.2</jackson-bom .version>
@@ -232,22 +231,6 @@ under the License.
232
231
<version >${kafka.version} </version >
233
232
</dependency >
234
233
235
- <dependency >
236
- <groupId >org.apache.zookeeper</groupId >
237
- <artifactId >zookeeper</artifactId >
238
- <version >${zookeeper.version} </version >
239
- <exclusions >
240
- <exclusion >
241
- <groupId >log4j</groupId >
242
- <artifactId >log4j</artifactId >
243
- </exclusion >
244
- <exclusion >
245
- <groupId >org.slf4j</groupId >
246
- <artifactId >slf4j-log4j12</artifactId >
247
- </exclusion >
248
- </exclusions >
249
- </dependency >
250
-
251
234
<dependency >
252
235
<groupId >org.xerial.snappy</groupId >
253
236
<artifactId >snappy-java</artifactId >
You can’t perform that action at this time.
0 commit comments