{"repo":"thmeitz/ksqldb-go","free":true,"listed":false,"github":"https://github.com/thmeitz/ksqldb-go","clone":"git clone https://github.com/thmeitz/ksqldb-go.git","description":"ksqldb-go client","language":"Go","stars":43,"topics":["sql","kafka","kafka-streams","antlr4","ksqldb-go","golang","go"],"license":"Apache-2.0","category":"databases-storage","readme_excerpt":"ksqlDB Go library This is a unconnected fork from Robin Moffatt and will be developed on its own. Thank you Robin and all other contributors for their work! Attention - WIP If you use this library, be warned as the client will be completely overhauled! This client is not production ready and the interfaces can be changed without notification!!! ⚠️ Disclaimer #1: This is a personal project and not supported or endorsed by Confluent. Breaking Changes v0.2.0 - Logger Migration (logrus → slog) The library now uses Go's standard library log/slog instead of logrus/log-go. The net.NewHTTPClient() function now accepts slog.Logger . Quick Migration : v0.1.0 - Context Support All API calls must now contain a context object. KsqldbClient Changes: - Execute(ctx context.Context, options ExecOptions) - GetClusterStatus(ctx context.Context) - GetQueryStatus(ctx context.Context, commandId string) - GetServerInfo(ctx context.Context) - GetServerStatus(ctx context.Context) - TerminateCluster(ctx context.Context, topics ...string) - ValidateProperty(ctx context.Context, property string) HTTPClient Interface Changes: - Get(ctx context.Context, url string) - Post(ctx context.Context, url, contentType string, body io.Reader) Migration? Checkout ksqldb-migrate, a tool to run your ksqlDB migrations. Description This is a Go client for ksqlDB. - [x] Execute a statement (/ksql endpoint) - [x] Run push and pull queries (/query-stream endpoint) - [x] Close push query (/close-query endpoint) - [x] Termin","default_branch":null,"files":null,"tree":[],"storefront":"/r/thmeitz","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/thmeitz/ksqldb-go/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."}