diff --git a/README.md b/README.md index c68dbb9..5a6fde9 100644 --- a/README.md +++ b/README.md @@ -10,11 +10,11 @@ This connector has not yet been published to Confluent Hub. To install it, downl install it using `confluent-hub` command line tool. ```sh -wget https://github.com/vinted/kafka-connect-vespa/releases/download/v1.0.10/vinted-kafka-connect-vespa-v1.0.10.zip -O /tmp/vinted-kafka-connect-vespa-v1.0.10.zip -q +wget https://github.com/vinted/kafka-connect-vespa/releases/download/v1.0.11/vinted-kafka-connect-vespa-v1.0.11.zip -O /tmp/vinted-kafka-connect-vespa-v1.0.11.zip -q ``` ```sh -confluent-hub install --no-prompt /tmp/vinted-kafka-connect-vespa-v1.0.10.zip +confluent-hub install --no-prompt /tmp/vinted-kafka-connect-vespa-v1.0.11.zip ``` ### Operational modes @@ -59,7 +59,7 @@ cluster to feed, so load can be balanced across these containers. In general, th possible, but poor connectivity between feeder and cluster may also warrant a higher number of connections. * Type: int -* Default: 8 +* Default: 1 * Valid Values: [1,...] * Importance: low @@ -71,7 +71,7 @@ possible. The feed client automatically throttles load to achieve the best throu per connection is usually lower than the maximum. * Type: int -* Default: 128 +* Default: 16 * Valid Values: [1,...] * Importance: low diff --git a/pom.xml b/pom.xml index 8863822..1572cbb 100644 --- a/pom.xml +++ b/pom.xml @@ -5,7 +5,7 @@ 4.0.0 com.vinted.kafka.connect.vespa kafka-connect-vespa - 1.0.10-SNAPSHOT + 1.0.11-SNAPSHOT kafka-connect-vespa The Vespa Sink Connector is used to write data from Kafka to a Vespa search engine. https://github.com/vinted/kafka-connect-vespa @@ -17,7 +17,7 @@ 2.17.1 1.7.30 1.2.17-cp2 - 8.273.20 + 8.340.17 0.7.177 5.9.3 diff --git a/src/main/java/com/vinted/kafka/connect/vespa/VespaSinkConfig.java b/src/main/java/com/vinted/kafka/connect/vespa/VespaSinkConfig.java index c2a808b..2aedc62 100644 --- a/src/main/java/com/vinted/kafka/connect/vespa/VespaSinkConfig.java +++ b/src/main/java/com/vinted/kafka/connect/vespa/VespaSinkConfig.java @@ -32,7 +32,7 @@ public class VespaSinkConfig extends AbstractConfig { + "number of connections."; private static final String CONNECTIONS_PER_ENDPOINT_DISPLAY = "Connections per endpoint"; - private static final int CONNECTIONS_PER_ENDPOINT_DEFAULT = 8; + private static final int CONNECTIONS_PER_ENDPOINT_DEFAULT = 1; public static final String MAX_STREAMS_PER_CONNECTION_CONFIG = "vespa.max.streams.per.connection"; private static final String MAX_STREAMS_PER_CONNECTION_DOC = "This determines the maximum number of concurrent, " @@ -41,7 +41,7 @@ public class VespaSinkConfig extends AbstractConfig { + "when possible. The feed client automatically throttles load to achieve the best throughput, and the " + "actual number of streams per connection is usually lower than the maximum."; private static final String MAX_STREAMS_PER_CONNECTION_DISPLAY = "Max streams per connection"; - private static final int MAX_STREAMS_PER_CONNECTION_DEFAULT = 128; + private static final int MAX_STREAMS_PER_CONNECTION_DEFAULT = 17; public static final String DRYRUN_CONFIG = "vespa.dryrun"; private static final String DRYRUN_DOC = "Turns on dryrun mode, where each operation succeeds after a given "