Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Update Apache Kafka client libraries to 3.0.0 (#11735) 

Release notes:
https://downloads.apache.org/kafka/3.0.0/RELEASE_NOTES.html
https://blogs.apache.org/kafka/entry/what-s-new-in-apache6
This commit is contained in:
Xavier Léauté 2021-10-05 10:23:19 -07:00 committed by GitHub
parent a31d99fb37
commit bc3b038712
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
extensions-core/kafka-extraction-namespace/src/test/java/org/apache/druid/query/lookup/TestKafkaExtractionCluster.java
View File

@ -150,7 +150,7 @@ public class TestKafkaExtractionCluster
private Map<String, String> getConsumerProperties() private Map<String, String> getConsumerProperties()
{ {
final Map<String, String> props = new HashMap<>(KAFKA_PROPERTIES); final Map<String, String> props = new HashMap<>(KAFKA_PROPERTIES);
int port = kafkaServer.socketServer().config().port(); int port = kafkaServer.socketServer().config().advertisedListeners().apply(0).port();
props.put("bootstrap.servers", StringUtils.format("127.0.0.1:%d", port)); props.put("bootstrap.servers", StringUtils.format("127.0.0.1:%d", port));
return props; return props;
} }
@ -194,7 +194,7 @@ public class TestKafkaExtractionCluster
{ {
final Properties kafkaProducerProperties = new Properties(); final Properties kafkaProducerProperties = new Properties();
kafkaProducerProperties.putAll(KAFKA_PROPERTIES); kafkaProducerProperties.putAll(KAFKA_PROPERTIES);
int port = kafkaServer.socketServer().config().port(); int port = kafkaServer.socketServer().config().advertisedListeners().apply(0).port();
kafkaProducerProperties.put("bootstrap.servers", StringUtils.format("127.0.0.1:%d", port)); kafkaProducerProperties.put("bootstrap.servers", StringUtils.format("127.0.0.1:%d", port));
kafkaProducerProperties.put("key.serializer", ByteArraySerializer.class.getName()); kafkaProducerProperties.put("key.serializer", ByteArraySerializer.class.getName());
kafkaProducerProperties.put("value.serializer", ByteArraySerializer.class.getName()); kafkaProducerProperties.put("value.serializer", ByteArraySerializer.class.getName());

2
extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/test/TestBroker.java
View File

@ -95,7 +95,7 @@ public class TestBroker implements Closeable
public int getPort() public int getPort()
{ {
return server.socketServer().config().port(); return server.socketServer().config().advertisedListeners().apply(0).port();
} }
public KafkaProducer<byte[], byte[]> newProducer() public KafkaProducer<byte[], byte[]> newProducer()

4
licenses.yaml
View File

@ -3654,7 +3654,7 @@ libraries:
--- ---
name: Apache Kafka name: Apache Kafka
version: 2.8.0 version: 3.0.0
license_category: binary license_category: binary
module: extensions/druid-kafka-indexing-service module: extensions/druid-kafka-indexing-service
license_name: Apache License version 2.0 license_name: Apache License version 2.0
@ -4564,7 +4564,7 @@ name: Apache Kafka
license_category: binary license_category: binary
module: extensions/kafka-extraction-namespace module: extensions/kafka-extraction-namespace
license_name: Apache License version 2.0 license_name: Apache License version 2.0
version: 2.8.0 version: 3.0.0
libraries: libraries:
- org.apache.kafka: kafka-clients - org.apache.kafka: kafka-clients
notices: notices:

2
pom.xml
View File

@ -77,7 +77,7 @@
<aether.version>0.9.0.M2</aether.version> <aether.version>0.9.0.M2</aether.version>
<apache.curator.version>4.3.0</apache.curator.version> <apache.curator.version>4.3.0</apache.curator.version>
<apache.curator.test.version>2.12.0</apache.curator.test.version> <apache.curator.test.version>2.12.0</apache.curator.test.version>
<apache.kafka.version>2.8.0</apache.kafka.version> <apache.kafka.version>3.0.0</apache.kafka.version>
<apache.ranger.version>2.0.0</apache.ranger.version> <apache.ranger.version>2.0.0</apache.ranger.version>
<apache.ranger.gson.version>2.2.4</apache.ranger.gson.version> <apache.ranger.gson.version>2.2.4</apache.ranger.gson.version>
<avatica.version>1.17.0</avatica.version> <avatica.version>1.17.0</avatica.version>