{"repo":"vinted/kafka-connect-vespa","free":true,"listed":false,"github":"https://github.com/vinted/kafka-connect-vespa","clone":"git clone https://github.com/vinted/kafka-connect-vespa.git","description":"Kafka Connect Vespa sink connector","language":"Java","stars":17,"topics":["kafka","kafka-connect","vespa","vinted"],"license":"MIT","category":"data-pipelines","readme_excerpt":"Kafka Connect Vespa Sink Connector Introduction The Vespa Sink Connector is used to write data from Kafka to a Vespa search engine. Installation This connector has not yet been published to Confluent Hub. To install it, download the latest component package and install it using confluent-hub command line tool. Operational modes The connector can work in two operational modes which act very differently and serve two distinct cases. It can be configured using the vespa.operational.mode configuration parameter. UPSERT Upsert mode will replace existing documents, tombstones messages will be converted to delete operations. Document keys are constructed using the following format: namespace:documenttype:id . By default, the topic names are used for both the namespace and the document type, but they can be overriden using the vespa.namespace and vespa.document.type configuration properties. If you need something more complex, consider using single message transforms to change the topic name. RAW Raw mode will execute kafka messages as vespa document api operations using document JSON format. If you want those operations to be executed in order, make sure they have a unique kafka key so that the operations are sent to the same kafka partitions. In this mode, connector does not use the kafka keys at all. Configuration Connector vespa.endpoint The comma-separated list of one or more Vespa URLs, such as https://node1:8080,http://node2:8080 or https://node3:8080 . HTTPS is used for all c","default_branch":null,"files":null,"tree":[],"storefront":"/r/vinted","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/vinted/kafka-connect-vespa/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}