Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

feat: kafka adapter #342

Merged
merged 63 commits into from
Jan 25, 2023
+20,315 −6,591
Merged

feat: kafka adapter #342

Show file tree
Hide file tree
Changes from 2 commits
Commits
Show all changes
63 commits
Select commit Hold shift + click to select a range
a805288
Draft PR it is
Ruchip16 Oct 8, 2022
71768e8
Changes updated
Ruchip16 Oct 26, 2022
5889511
EoS added but WIP
Ruchip16 Nov 14, 2022
48ccbde
Consuming and producing messages
Ruchip16 Nov 17, 2022
25cdefa
Producing and consuming messages
Ruchip16 Nov 23, 2022
99a16ef
Subscriber
Ruchip16 Nov 25, 2022
de5edec
recent version
Ruchip16 Dec 6, 2022
552fe90
test-push
Ruchip16 Dec 7, 2022
9399af3
gleemessage
Ruchip16 Dec 17, 2022
c069607
umm doing some stuff
Ruchip16 Dec 17, 2022
21a6b41
WIP
Ruchip16 Dec 17, 2022
2260e9b
WIP2
Ruchip16 Dec 17, 2022
70f4021
Testing
Ruchip16 Dec 17, 2022
4574fb0
example-test
Ruchip16 Dec 18, 2022
d0c6156
Updatess
Ruchip16 Dec 19, 2022
1c24e7f
Producer WIP
Ruchip16 Dec 20, 2022
46d5195
error
Ruchip16 Dec 22, 2022
780b5ea
WIP-Producer
Ruchip16 Dec 22, 2022
20dbe47
Producer - testing
Ruchip16 Dec 22, 2022
a788a8a
Producer
Ruchip16 Dec 22, 2022
7ad0f6e
Security Pseudocode
Ruchip16 Dec 23, 2022
2794b1d
cherry pick conflicts
Ruchip16 Oct 8, 2022
2706637
conflictss
Ruchip16 Oct 8, 2022
81391c8
chpick
Ruchip16 Oct 26, 2022
3771cf8
Changes updated
Ruchip16 Oct 26, 2022
69159be
EoS added but WIP
Ruchip16 Nov 14, 2022
ae12dbd
Consuming and producing messages
Ruchip16 Nov 17, 2022
a60092a
Producing and consuming messages
Ruchip16 Nov 23, 2022
7553fba
Subscriber
Ruchip16 Nov 25, 2022
8fd7d92
recent version
Ruchip16 Dec 6, 2022
66459a5
test-push
Ruchip16 Dec 7, 2022
b86a63d
gleemessage
Ruchip16 Dec 17, 2022
25b1716
umm doing some stuff
Ruchip16 Dec 17, 2022
010a275
WIP
Ruchip16 Dec 17, 2022
2b867e5
WIP2
Ruchip16 Dec 17, 2022
ca80a45
Testing
Ruchip16 Dec 17, 2022
6749366
example-test
Ruchip16 Dec 18, 2022
e41e453
Updatess
Ruchip16 Dec 19, 2022
eee69b5
Producer WIP
Ruchip16 Dec 20, 2022
2ab7767
error
Ruchip16 Dec 22, 2022
5281e59
WIP-Producer
Ruchip16 Dec 22, 2022
cd2ca10
Producer - testing
Ruchip16 Dec 22, 2022
bee0aa7
Producer
Ruchip16 Dec 22, 2022
a9ee43b
Security Pseudocode
Ruchip16 Dec 23, 2022
9676574
Conflict resolved
Ruchip16 Jan 11, 2023
b008e36
Conflicts resolving ..
Ruchip16 Jan 11, 2023
25091f9
Security WIP
Ruchip16 Jan 12, 2023
fed4ce3
++security
Ruchip16 Jan 12, 2023
51d2a87
Updatesss
Ruchip16 Jan 13, 2023
541ce52
v1 security
Ruchip16 Jan 17, 2023
e2c2587
just updating over here
Ruchip16 Jan 19, 2023
9548794
Included security requirements
Ruchip16 Jan 20, 2023
6abf362
Security mechanism
Ruchip16 Jan 23, 2023
60d632d
SSL Authentication
Ruchip16 Jan 23, 2023
751795c
Review Changes done
Ruchip16 Jan 24, 2023
6f442a1
Updating changes
Ruchip16 Jan 25, 2023
87db040
Merge remote-tracking branch 'origin/kafka-adapter' into kafka-adapter
Ruchip16 Jan 25, 2023
12a374d
Merge branch 'master' of https://github.com/asyncapi/glee into kafka-…
Ruchip16 Jan 25, 2023
75f6d4a
Pushing changes
Ruchip16 Jan 25, 2023
dfe1bf4
Lint Test Fix
Ruchip16 Jan 25, 2023
03563f8
final commit
Ruchip16 Jan 25, 2023
c3fc810
rebuilding package-lock.json
fmvilas Jan 25, 2023
1c32946
increase warnings
fmvilas Jan 25, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions examples/dummy/.env
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1 +1,2 @@
GLEE_SERVER_NAMES=mykafka
fmvilas marked this conversation as resolved.
Show resolved Hide resolved
GLEE_SERVER_CERTS=mosquitto:mosquitto.org.crt
3 changes: 3 additions & 0 deletions examples/dummy/asyncapi.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,9 @@ info:
version: 1.0.0
description: This service is in charge of processing user signups
servers:
mykafka:
fmvilas marked this conversation as resolved.
Show resolved Hide resolved
url: kafka://localhost:9092
protocol: kafka
fmvilas marked this conversation as resolved.
Show resolved Hide resolved
mosquitto:
url: mqtts://test.mosquitto.org
protocol: mqtts
Expand Down
Loading