You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@solr.apache.org by ab...@apache.org on 2023/11/20 10:40:12 UTC
(solr-sandbox) branch main updated: Increase MAX_ATTEMPTS for this test, to avoid sending messages to DLQ. Fix slf4j binding issue. (#90)
This is an automated email from the ASF dual-hosted git repository.
ab 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 2760bfb Increase MAX_ATTEMPTS for this test, to avoid sending messages to DLQ. Fix slf4j binding issue. (#90)
2760bfb is described below
commit 2760bfb4a02a6969c5ea46e01799c117dcc1cfc6
Author: Andrzej Białecki <ab...@apache.org>
AuthorDate: Mon Nov 20 11:40:06 2023 +0100
Increase MAX_ATTEMPTS for this test, to avoid sending messages to DLQ. Fix slf4j binding issue. (#90)
---
crossdc-producer/build.gradle | 1 +
.../test/java/org/apache/solr/crossdc/RetryQueueIntegrationTest.java | 5 +++--
2 files changed, 4 insertions(+), 2 deletions(-)
diff --git a/crossdc-producer/build.gradle b/crossdc-producer/build.gradle
index 20389bb..3371fc5 100644
--- a/crossdc-producer/build.gradle
+++ b/crossdc-producer/build.gradle
@@ -45,6 +45,7 @@ dependencies {
testImplementation group: 'org.apache.solr', name: 'solr-core', version: '8.11.2'
testImplementation group: 'org.apache.solr', name: 'solr-test-framework', version: '8.11.2'
+ testImplementation group: 'org.slf4j', name: 'slf4j-simple', version: '2.0.9'
testImplementation 'org.apache.kafka:kafka-clients:3.5.1:test'
testImplementation 'org.apache.kafka:kafka_2.13:3.5.1'
testImplementation 'org.apache.kafka:kafka-streams:3.5.1'
diff --git a/crossdc-producer/src/test/java/org/apache/solr/crossdc/RetryQueueIntegrationTest.java b/crossdc-producer/src/test/java/org/apache/solr/crossdc/RetryQueueIntegrationTest.java
index 3877dfc..0371fc3 100644
--- a/crossdc-producer/src/test/java/org/apache/solr/crossdc/RetryQueueIntegrationTest.java
+++ b/crossdc-producer/src/test/java/org/apache/solr/crossdc/RetryQueueIntegrationTest.java
@@ -114,6 +114,7 @@ import java.util.Properties;
properties.put(KafkaCrossDcConf.ZK_CONNECT_STRING, solrCluster2.getZkServer().getZkAddress());
properties.put(KafkaCrossDcConf.TOPIC_NAME, TOPIC);
properties.put(KafkaCrossDcConf.GROUP_ID, "group1");
+ properties.put(KafkaCrossDcConf.MAX_ATTEMPTS, 100);
consumer.start(properties);
}
@@ -224,7 +225,7 @@ import java.util.Properties;
}
}
- assertTrue("results=" + results, foundUpdates);
+ assertTrue("expected updates not found, results=" + results, foundUpdates);
System.out.println("Rest: " + results);
}
@@ -278,7 +279,7 @@ import java.util.Properties;
}
}
- assertTrue("results=" + results, foundUpdates);
+ assertTrue("expected updates not found, results=" + results, foundUpdates);
System.out.println("Rest: " + results);
}