This is an automated email from the ASF dual-hosted git repository.
jackie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new 608cf9af86c Change default kafka consumer to use Kafka 3 (#16858)
608cf9af86c is described below
commit 608cf9af86c1c98c63c5009bb4d6d141fb7816c3
Author: Xiang Fu <[email protected]>
AuthorDate: Wed Oct 8 02:37:53 2025 +0800
Change default kafka consumer to use Kafka 3 (#16858)
---
pinot-spi/src/main/java/org/apache/pinot/spi/stream/StreamConfig.java | 2 +-
.../src/test/java/org/apache/pinot/spi/config/ConfigUtilsTest.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git
a/pinot-spi/src/main/java/org/apache/pinot/spi/stream/StreamConfig.java
b/pinot-spi/src/main/java/org/apache/pinot/spi/stream/StreamConfig.java
index aea77e44a20..7f502fd23f3 100644
--- a/pinot-spi/src/main/java/org/apache/pinot/spi/stream/StreamConfig.java
+++ b/pinot-spi/src/main/java/org/apache/pinot/spi/stream/StreamConfig.java
@@ -44,7 +44,7 @@ public class StreamConfig {
public static final int DEFAULT_FLUSH_AUTOTUNE_INITIAL_ROWS = 100_000;
public static final String DEFAULT_CONSUMER_FACTORY_CLASS_NAME_STRING =
- "org.apache.pinot.plugin.stream.kafka20.KafkaConsumerFactory";
+ "org.apache.pinot.plugin.stream.kafka30.KafkaConsumerFactory";
public static final long DEFAULT_STREAM_CONNECTION_TIMEOUT_MILLIS = 30_000;
public static final int DEFAULT_STREAM_FETCH_TIMEOUT_MILLIS = 5_000;
diff --git
a/pinot-spi/src/test/java/org/apache/pinot/spi/config/ConfigUtilsTest.java
b/pinot-spi/src/test/java/org/apache/pinot/spi/config/ConfigUtilsTest.java
index 4cbda36441f..25a7dec1c3b 100644
--- a/pinot-spi/src/test/java/org/apache/pinot/spi/config/ConfigUtilsTest.java
+++ b/pinot-spi/src/test/java/org/apache/pinot/spi/config/ConfigUtilsTest.java
@@ -79,7 +79,7 @@ public class ConfigUtilsTest {
String streamType = "fakeStream";
String topic = "fakeTopic";
String tableName = "fakeTable_REALTIME";
- String defaultConsumerFactoryClass =
"org.apache.pinot.plugin.stream.kafka20.StreamConsumerFactory";
+ String defaultConsumerFactoryClass =
"org.apache.pinot.plugin.stream.kafka30.StreamConsumerFactory";
String defaultDecoderClass =
"org.apache.pinot.plugin.inputformat.avro.KafkaAvroMessageDecoder";
String consumerFactoryClass = "${CONSUMER_FACTORY_CLASS:" +
defaultConsumerFactoryClass + "}";
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
