Skip to content

Commit

Permalink
Update connector defaults
Browse files Browse the repository at this point in the history
  • Loading branch information
buinauskas committed May 13, 2024
1 parent 5795622 commit bf26e0b
Show file tree
Hide file tree
Showing 3 changed files with 8 additions and 8 deletions.
8 changes: 4 additions & 4 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down Expand Up @@ -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

Expand All @@ -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

Expand Down
4 changes: 2 additions & 2 deletions pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
<modelVersion>4.0.0</modelVersion>
<groupId>com.vinted.kafka.connect.vespa</groupId>
<artifactId>kafka-connect-vespa</artifactId>
<version>1.0.10-SNAPSHOT</version>
<version>1.0.11-SNAPSHOT</version>
<name>kafka-connect-vespa</name>
<description>The Vespa Sink Connector is used to write data from Kafka to a Vespa search engine.</description>
<url>https://github.com/vinted/kafka-connect-vespa</url>
Expand All @@ -17,7 +17,7 @@
<log4j.version>2.17.1</log4j.version>
<slf4j.version>1.7.30</slf4j.version>
<confluent-log4j.version>1.2.17-cp2</confluent-log4j.version>
<vespa.version>8.273.20</vespa.version>
<vespa.version>8.340.17</vespa.version>
<connect.utils.version>0.7.177</connect.utils.version>
<junit.version>5.9.3</junit.version>
</properties>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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, "
Expand All @@ -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 "
Expand Down

0 comments on commit bf26e0b

Please sign in to comment.