Skip to content

Commit 7fc0635

Browse files
authored
chore: release fluvio 0.14.1 (#326)
1 parent a528292 commit 7fc0635

File tree

196 files changed

+17151
-4
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

196 files changed

+17151
-4
lines changed

Justfile

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -47,8 +47,8 @@ lint: build
4747

4848

4949
resync-ver:
50-
rm -rf versioned_docs/version-0.14.0
51-
rsync -aurv docs/ versioned_docs/version-0.14.0
50+
rm -rf versioned_docs/version-0.14.1
51+
rsync -aurv docs/ versioned_docs/version-0.14.1
5252

5353
sync-ver:
54-
rsync -aurv docs/ versioned_docs/version-0.14.0
54+
rsync -aurv docs/ versioned_docs/version-0.14.1

docusaurus.config.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@ import sdfVersionsList from "./sdf_versions.json" with { type: "json" };
99

1010
const FLUVIO_REPOSITORY_URL = "https://github.com/InfinyOn/fluvio";
1111

12-
const STABLE_VERSION = "0.14.0";
12+
const STABLE_VERSION = "0.14.1";
1313

1414
// read sdf-versions.json and build versions object
1515
const sdfVersions = sdfVersionsList.reduce((acc, version) => ({

news/this-week-in-fluvio-0068.md

Lines changed: 77 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,77 @@
1+
---
2+
title: "This Week in Fluvio #68"
3+
date: 2025-01-09
4+
weight: 20
5+
---
6+
Fluvio is a distributed, programmable streaming platform written in Rust.
7+
8+
---
9+
We released **Fluvio 0.14.1** last week.
10+
11+
## New release
12+
Fluvio **v0.14.1** is now available!
13+
14+
To update you can run `fvm update`
15+
16+
```bash
17+
$ fvm update
18+
19+
info: Updating fluvio stable to version 0.14.1. Current version is 0.12.1.
20+
info: Downloading (1/5): fluvio@0.14.1
21+
info: Downloading (2/5): fluvio-cloud@0.2.26
22+
info: Downloading (3/5): fluvio-run@0.14.1
23+
info: Downloading (4/5): cdk@0.14.1
24+
info: Downloading (5/5): smdk@0.14.1
25+
done: Installed fluvio version 0.14.1
26+
done: Now using fluvio version 0.14.1
27+
28+
```
29+
30+
If you don't have Fluvio in your machine run:
31+
32+
```
33+
curl -fsS https://hub.infinyon.cloud/install/install.sh | bash
34+
```
35+
36+
If you are enjoying Fluvio please share with your friends!
37+
38+
:::info
39+
Also check out the Stateful Data Flow (SDF) streaming analytics in beta [SDF Examples](https://github.com/infinyon/stateful-dataflows-examples)
40+
:::
41+
42+
Notable changes in this new version:
43+
44+
- Enhance of error message for upgrading a cluster when an incompatible cluster version error is raised.
45+
46+
See the [CHANGELOG] for more details
47+
48+
## Good First Issues
49+
We love our open source community contributors. Here are some issues that you could contribute to. All the best.
50+
51+
- [Improve fluvio topic describe with additional information]
52+
- [Different default SPU port]
53+
- [Delete the consumer when delete topic]
54+
55+
56+
---
57+
58+
Get in touch with us on [GitHub Discussions] or join [our Discord channel] and come say hello!
59+
60+
See some of the interesting community projects, examples, and utilities in the [Fluvio Community] GitHub org.
61+
62+
63+
For the full list of changes this week, be sure to check out [our CHANGELOG].
64+
65+
[Fluvio open source]: https://github.com/infinyon/fluvio
66+
[our CHANGELOG]: https://github.com/infinyon/fluvio/blob/master/CHANGELOG.md
67+
[our Discord channel]: https://discordapp.com/invite/bBG2dTz
68+
[GitHub Discussions]: https://github.com/infinyon/fluvio/discussions
69+
70+
[this form]: https://infinyon.com/request/ss-early-access/
71+
[CHANGELOG]: https://github.com/infinyon/fluvio/blob/v0.14.1/CHANGELOG.md
72+
[When a topic is deleted, connected clients should have their connection closed]: https://github.com/infinyon/fluvio/issues/3836
73+
[Delete the consumer when delete topic]: https://github.com/infinyon/fluvio/issues/4308
74+
[Remove localhost from fluvio in favor of 127.0.0.1]: https://github.com/infinyon/fluvio/issues/3866
75+
[Improve fluvio topic describe with additional information]: https://github.com/infinyon/fluvio/issues/3968
76+
[Different default SPU port]: https://github.com/infinyon/fluvio/issues/3739
77+
[Fluvio Community]: https://github.com/fluvio-community
Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
cdk deploy start --ipkg infinyon-http-sink-0.2.11.ipkg --config <CONFIG>
Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
cdk deploy start --ipkg infinyon-http-source-0.3.8.ipkg --config ./http-cat-facts-transform.yaml
Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
cdk deploy start --ipkg infinyon-http-source-0.3.8.ipkg --config ./http-cat-facts.yaml
Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
cdk deploy start --ipkg infinyon-http-source-0.3.8.ipkg -c quotes-source-connector.yml
Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
cdk deploy start --ipkg infinyon-http-source-0.3.8.ipkg -c string-quotes-source-connector.yml
Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
cdk deploy start --ipkg infinyon-sql-sink-0.4.3.ipkg --config ./sql-cat-fact.yaml
Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
cdk hub download infinyon/http-sink@0.2.11
Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
trying connection to fluvio router.infinyon.cloud:9003
2+
downloading infinyon/jolt@0.4.1 to infinyon-jolt-0.4.1.ipkg
3+
... downloading complete
4+
... checking package
5+
... cluster smartmodule install complete
Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
cdk hub download infinyon/http-source@0.3.8
Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
cdk hub download infinyon/sql-sink@0.4.3
Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,13 @@
1+
fluvio hub connector list
2+
CONNECTOR Visibility
3+
infinyon-labs/graphite-sink@0.2.0 public
4+
infinyon/duckdb-sink@0.1.0 public
5+
infinyon/http-sink@0.2.11 public
6+
infinyon/http-source@0.4.3 public
7+
infinyon/ic-webhook-source@0.1.4 public
8+
infinyon/inf-webhook-source@0.1.9 public
9+
infinyon/kafka-sink@0.2.9 public
10+
infinyon/kafka-source@0.2.7 public
11+
infinyon/mqtt-source@0.2.9 public
12+
infinyon/sql-sink@0.4.3 public
13+
qdrant/qdrant-sink@0.1.0 public
Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
trying connection to fluvio router.infinyon.cloud:9003
2+
downloading infinyon/jolt@0.4.1 to infinyon-jolt-0.4.1.ipkg
3+
... downloading complete
4+
... checking package
5+
... cluster smartmodule install complete
Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
fluvio hub smartmodule download infinyon/jolt@0.4.1
Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
trying connection to fluvio router.infinyon.cloud:9003
2+
downloading infinyon/json-sql@0.2.1 to infinyon-json-sql-0.2.1.ipkg
3+
... downloading complete
4+
... checking package
5+
... cluster smartmodule install complete
Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
fluvio hub sm download infinyon/json-sql@0.2.1
Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,4 @@
1+
fluvio hub smartmodule list
2+
SMARTMODULE Visibility
3+
infinyon/jolt@0.4.1 public
4+
...
Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,15 @@
1+
fluvio hub smartmodule list
2+
SMARTMODULE Visibility
3+
infinyon-labs/array-map-json@0.1.1 public
4+
infinyon-labs/csv-json@0.2.0 public
5+
infinyon-labs/dedup-filter@0.0.2 public
6+
infinyon-labs/json-formatter@0.1.3 public
7+
infinyon-labs/key-gen-json@0.1.1 public
8+
infinyon-labs/regex-map-json@0.1.2 public
9+
infinyon-labs/regex-map@0.1.1 public
10+
infinyon-labs/rss-json@0.1.1 public
11+
infinyon-labs/stars-forks-changes@0.1.4 public
12+
infinyon/csv-json@0.2.0 public
13+
infinyon/jolt@0.4.1 public
14+
infinyon/json-sql@0.2.1 public
15+
infinyon/regex-filter@0.2.0 public
Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
fluvio smartmodule list
2+
SMARTMODULE SIZE
3+
infinyon/jolt@0.4.1 589.3 KB
Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,4 @@
1+
fluvio sm list
2+
SMARTMODULE SIZE
3+
infinyon/json-sql@0.2.1 559.6 KB
4+
infinyon/jolt@0.4.1 589.3 KB
Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,11 @@
1+
apiVersion: 0.1.0
2+
meta:
3+
version: 0.3.8
4+
name: cat-facts
5+
type: http-source
6+
topic: cat-facts
7+
create-topic: true
8+
9+
http:
10+
endpoint: "https://catfact.ninja/fact"
11+
interval: 10s
Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,18 @@
1+
apiVersion: 0.1.0
2+
meta:
3+
version: 0.3.8
4+
name: cat-facts-transformed
5+
type: http-source
6+
topic: cat-facts-data-transform
7+
8+
http:
9+
endpoint: https://catfact.ninja/fact
10+
interval: 10s
11+
12+
transforms:
13+
- uses: infinyon/jolt@0.4.1
14+
with:
15+
spec:
16+
- operation: default
17+
spec:
18+
source: "http"
Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,17 @@
1+
# string-quotes-source-connector.yml
2+
apiVersion: 0.1.0
3+
meta:
4+
version: 0.3.8
5+
name: string-quotes
6+
type: http-source
7+
topic: string-quotes
8+
http:
9+
endpoint: https://demo-data.infinyon.com/api/quote
10+
interval: 3s
11+
transforms:
12+
- uses: infinyon/jolt@0.4.1
13+
with:
14+
spec:
15+
- operation: shift
16+
spec:
17+
quote: ""
Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
# quotes-source-connector.yml
2+
apiVersion: 0.1.0
3+
meta:
4+
version: 0.3.8
5+
name: http-quotes
6+
type: http-source
7+
topic: quotes
8+
http:
9+
endpoint: https://demo-data.infinyon.com/api/quote
10+
interval: 3s
Lines changed: 27 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,27 @@
1+
# sql.yaml
2+
apiVersion: 0.1.0
3+
meta:
4+
name: simple-cat-facts-sql
5+
type: sql-sink
6+
version: 0.4.3
7+
topic: cat-facts
8+
sql:
9+
url: "postgres://user:password@db.postgreshost.example/dbname"
10+
transforms:
11+
- uses: infinyon/json-sql@0.2.1
12+
invoke: insert
13+
with:
14+
mapping:
15+
table: "animalfacts"
16+
map-columns:
17+
"length":
18+
json-key: "length"
19+
value:
20+
type: "int"
21+
default: "0"
22+
required: true
23+
"raw_fact_json":
24+
json-key: "$"
25+
value:
26+
type: "jsonb"
27+
required: true
Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,8 @@
1+
#transforms.yml
2+
transforms:
3+
- uses: infinyon/jolt@0.4.1
4+
with:
5+
spec:
6+
- operation: shift
7+
spec:
8+
quote: ""
Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
const versions = {
2+
infinyon_http_source: 'infinyon-http-source@0.3.8',
3+
}
4+
5+
export default versions;
Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
{
2+
"label": "Cloud CLI",
3+
"collapsed": true,
4+
"position": 30
5+
}

0 commit comments

Comments
 (0)