You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@solr.apache.org by ma...@apache.org on 2023/08/11 19:28:18 UTC
[solr-sandbox] branch main updated: Revert some config defaults to Kafka defaults.
This is an automated email from the ASF dual-hosted git repository.
markrmiller pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/solr-sandbox.git
The following commit(s) were added to refs/heads/main by this push:
new b2d6106 Revert some config defaults to Kafka defaults.
b2d6106 is described below
commit b2d610633812f73a15f25fef16edac6b564a0020
Author: markrmiller <ma...@apache.org>
AuthorDate: Fri Aug 11 14:28:11 2023 -0500
Revert some config defaults to Kafka defaults.
---
.../main/java/org/apache/solr/crossdc/common/KafkaCrossDcConf.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/crossdc-commons/src/main/java/org/apache/solr/crossdc/common/KafkaCrossDcConf.java b/crossdc-commons/src/main/java/org/apache/solr/crossdc/common/KafkaCrossDcConf.java
index 92d8c7b..c1fb102 100644
--- a/crossdc-commons/src/main/java/org/apache/solr/crossdc/common/KafkaCrossDcConf.java
+++ b/crossdc-commons/src/main/java/org/apache/solr/crossdc/common/KafkaCrossDcConf.java
@@ -44,12 +44,12 @@ public class KafkaCrossDcConf extends CrossDcConf {
public static final String DEFAULT_MAX_POLL_RECORDS = "500"; // same default as Kafka
- private static final String DEFAULT_FETCH_MIN_BYTES = "512000";
- private static final String DEFAULT_FETCH_MAX_WAIT_MS = "1000"; // Kafka default is 500
+ private static final String DEFAULT_FETCH_MIN_BYTES = "1";
+ private static final String DEFAULT_FETCH_MAX_WAIT_MS = "500"; // Kafka default is 500
public static final String DEFAULT_FETCH_MAX_BYTES = "100663296";
- public static final String DEFAULT_MAX_PARTITION_FETCH_BYTES = "33554432";
+ public static final String DEFAULT_MAX_PARTITION_FETCH_BYTES = "1048576";
public static final String DEFAULT_MAX_POLL_INTERVAL_MS = "90000";