Skip to content

Qos2 idempotent producer#152

Closed
su-Insight wants to merge 44 commits intofeature/mqtt-kafkafrom
qos2_idempontent
Closed

Qos2 idempotent producer#152
su-Insight wants to merge 44 commits intofeature/mqtt-kafkafrom
qos2_idempontent

Conversation

@su-Insight
Copy link
Copy Markdown
Owner

pr_rerun qos2_idempontent to feature/mqtt-kafka

@su-Insight su-Insight closed this Feb 16, 2025
su-Insight pushed a commit that referenced this pull request May 4, 2025
* example-startup-compose

- update set flag
- cache docker images
- make scripts runnable
- feat: add test runner for examples with changes
- feat: rename and remove examples as cookbooks
- update karapace to schema registry
- update compose files
- remove authority from routes
- update shell to sh
- feat: add zilla version from env var
- chore: update actions versions

* update readmes

* update action naming

* clean up some docker syntax

* remove uneeded compose

* use kafkacat name

* run formatter

* remove the pull_policy and add versioning instructions

* add params to the test runner

* remove container name

* add test.

* feat: add tests and mark failures

* fix: compare strings

* fix: test syntax

* feat: add sse tests

* fix test

* add grpc echo tests

* add more tests

* implement tests

* Configure ghz to use plaintext

* Increase bench total message count to 1000

* Change http.kafka.oneway example use sasl ssl (#154)

* fix: asyncapi.http.kafka.proxy

* `asyncapi.mqtt.kafka.proxy` test script fix

* `grpc.echo` fix

* `grpc.echo` test fix

* `grpc.kafka.echo` & `grpc.echo` fix

* `grpc.kafka.proxy` fix

* fix `tls.echo`

* fix `sse.kafka.fanout`

* add delay to `sse.kafka.fanout`

* update `sse.kafka.fanout`

* create kafka topic `sse.kafka.fanout`

* `sse.kafka.fanout` update

* fix: `mqtt.jwt`

* fix `teardown.sh` for `mqtt.jwt`

* fix `http.kafka.avro.json`

* update `karapace-registry` service in `http.kafka.avro.json`

* fix `http.json.schema`

* fix: `grpc.proxy`

* add `test.sh` : `grpc.kafka.fanout`

* fix `grpc.kafka.fanout`

* add `test.sh` : `http.proxy`

* add `test.sh` : `ws.echo` & `ws.reflect`

* fix `ws.*`

* fix `ws`

* fix `ws`

* install `wscat` as part of github action

* add `test.sh` : `http.jwt`

* update `http.jwt`

* update `http.jwt`

* update `http`

* add `test.sh` : `mqtt.jwt`

* add `test.sh` : `sse.jwt`

* fix `sse.jwt`

* fix `sse`

* message update `sse.jwt`

* fix `sse.jwt`

* fix `ws.echo`

* update `ws.echo`

* use `websocat`

* fix `ws.reflect`

* `ws` update

* update `ws`

* update `ws`

* update `ws.refect`

* update

* update `ws`

* add `test` : http.kafka.async`

* add `test` : `http.kafka.proto.oneway`

* fix `http.kafka.avro.json`

* add `test`: `tcp.reflect`

* add `test` : `tls.reflect`

* update

* `http.kafka.proto.json` readme update

* update: `optimise test script setup`

* addressing review comments

* `ws.reflect` update

* update `ws.reflect`

* Use insecure instead of skipTLS for plaintext

* fix `grpc.proxy` health check

* update `tls` examples with `-no_ign_eof`

* add `mqtt.kafka.proxy` example

* update `exit`

* fix `mqtt` test

* addressing review comments

* rename `http.jwt` to `http.proxy.jwt`

* addressing review comments

* addressing review comments

* update compose with `watch`

* update `hostname`

* addressing review comments

* move `.proto` files under `./etc/protos`

* update `grpc.echo`

* fix `grpc.echo`

* addressing review comments

* update `test.sh`

* update `compose` to remove `watch`

* update `README`

* remove `setup.sh` & `teardown.sh`

* add issue link for failing tests

---------

Co-authored-by: John Fallows <john.r.fallows@gmail.com>
Co-authored-by: bmaidics <b.maidics@gmail.com>
Co-authored-by: Ankit Kumar <ankitjames25@gmail.com>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

5 participants