A Kafka Connect OffsetBackingStore backed by Google Cloud Storage.
offset.storage=org.apache.kafka.connect.storage.gcs.GCSOffsetBackingStore
offset.storage.gcs.bucket=bucket
offset.storage.gcs.path=path/to/offsets.json
Keys and values are Base64-encoded to support both JSON and Avro representation.
Copyright © 2019 Haokang Den haokang.den@gmail.com
This program and the accompanying materials are made available under the terms of the Eclipse Public License 2.0 which is available at http://www.eclipse.org/legal/epl-2.0.
This Source Code may also be made available under the following Secondary Licenses when the conditions for such availability set forth in the Eclipse Public License, v. 2.0 are satisfied: GNU General Public License as published by the Free Software Foundation, either version 2 of the License, or (at your option) any later version, with the GNU Classpath Exception which is available at https://www.gnu.org/software/classpath/license.html.
Can you improve this documentation?Edit on GitHub
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close