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.

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

Support dynamic asyncapi specs as sql changes #169

Merged
merged 70 commits into from
Feb 3, 2025
Merged
Changes from 1 commit
Commits
Show all changes
70 commits
Select commit Hold shift + click to select a range
93cc848
WIP
akrambek Jan 15, 2025
15d89b5
WIP
akrambek Jan 15, 2025
d3c2633
WIP
akrambek Jan 16, 2025
f55b492
WIP
akrambek Jan 16, 2025
bb3c709
WIP
akrambek Jan 16, 2025
a1f0f22
WIP
akrambek Jan 16, 2025
785b059
WIP
akrambek Jan 16, 2025
9caa515
WIP
akrambek Jan 16, 2025
8384620
WIP
akrambek Jan 16, 2025
b961388
WIP
akrambek Jan 16, 2025
bdf91e5
WIP
akrambek Jan 16, 2025
51fc42d
WIP
akrambek Jan 17, 2025
03f1922
WIP
akrambek Jan 17, 2025
aa79d25
WIP
akrambek Jan 17, 2025
295bd81
WIP
akrambek Jan 18, 2025
0f6336e
WIP
akrambek Jan 18, 2025
4d6b806
WIP
akrambek Jan 18, 2025
d14221a
WIP
akrambek Jan 18, 2025
72b0c18
WIP
akrambek Jan 18, 2025
4cbf85b
WIP
akrambek Jan 18, 2025
68289ee
WIP
akrambek Jan 18, 2025
04764e0
WIP
akrambek Jan 18, 2025
6645480
WIP
akrambek Jan 18, 2025
241da5a
WIP
akrambek Jan 19, 2025
db6b3bc
WIP
akrambek Jan 19, 2025
109225b
WIP
akrambek Jan 19, 2025
91823af
Remove printing
akrambek Jan 19, 2025
2e7cb63
WIP
akrambek Jan 19, 2025
2b0c818
WIP
akrambek Jan 19, 2025
1783c47
WIP
akrambek Jan 19, 2025
5554353
WIP
akrambek Jan 19, 2025
0f96b7c
WIP
akrambek Jan 19, 2025
8f64ef7
WIP
akrambek Jan 19, 2025
aa1b577
WIP
akrambek Jan 19, 2025
5de2541
WIP
akrambek Jan 20, 2025
d67aeb6
WIP
akrambek Jan 20, 2025
aa4bd3b
WIP
akrambek Jan 20, 2025
50929e7
WIP
akrambek Jan 20, 2025
134d854
WIP
akrambek Jan 20, 2025
98a4d95
WIP
akrambek Jan 20, 2025
d875658
WIP
akrambek Jan 20, 2025
aafc3a3
WIP
akrambek Jan 20, 2025
66bc84a
WIP
akrambek Jan 20, 2025
b9ad3f7
Revert back the change
akrambek Jan 20, 2025
dc277e1
Use docker tag instead of hard coded value
akrambek Jan 20, 2025
4b4af2d
WIP
akrambek Jan 21, 2025
b76b77f
WIP
akrambek Jan 23, 2025
3d88c5e
Remove print statements
akrambek Jan 23, 2025
e0a1ede
WIP
akrambek Jan 23, 2025
90103b3
WIP
akrambek Jan 23, 2025
b2590f9
WIP
akrambek Jan 24, 2025
60e99c5
WIP
akrambek Jan 25, 2025
822db95
WIP
akrambek Jan 25, 2025
ce3a76f
WIP
akrambek Jan 25, 2025
2314fa4
WIP
akrambek Jan 25, 2025
632e526
WIP
akrambek Jan 25, 2025
2e46d1c
Checkpoint
akrambek Jan 25, 2025
dc8c9ad
WIP
akrambek Jan 25, 2025
5ddf96d
WIP
akrambek Jan 25, 2025
aedab04
Merge branch 'develop' into feature/autorestart
akrambek Jan 25, 2025
7a0238d
Remove debug logging
akrambek Jan 25, 2025
bc27c4e
Revert back the change
akrambek Jan 26, 2025
f03812f
Revert back the change
akrambek Jan 26, 2025
1375944
Revert back the change
akrambek Jan 26, 2025
c693581
Workaround zilla config update
akrambek Jan 26, 2025
cb14982
Merge branch 'develop' into feature/autorestart
akrambek Jan 28, 2025
0b88c46
WIP
akrambek Jan 28, 2025
a84acfc
Use new format
akrambek Jan 28, 2025
4b245e2
Fix typo
akrambek Jan 28, 2025
97ca9d3
Remove zb_catalog"."zstreams
akrambek Jan 28, 2025
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
Prev Previous commit
Next Next commit
Use new format
akrambek committed Jan 28, 2025
commit a84acfcce22a9b872d61e9ff403ba21c5b3d1f26
Original file line number Diff line number Diff line change
@@ -163,7 +163,7 @@ private String generateHttpAsyncApiSpecs(
for (Map.Entry<String, JsonValue> channelJson : channelsJson.entrySet())
{
String channelName = channelJson.getKey();
if (channelName.endsWith("_replies_sink"))
if (channelName.endsWith("_replies"))
{
continue;
}
Original file line number Diff line number Diff line change
@@ -189,7 +189,7 @@ private String generateKafkaAsyncApiSpecs(
operation.setMessages(Collections.singletonList(reference));
if (name.endsWith("_commands"))
{
String replyTopic = name.replace("_commands", "_replies_sink");
String replyTopic = name.replace("_commands", "_replies");
OperationReply reply = new OperationReply();
reference = new Reference("#/channels/%s".formatted(replyTopic));
reply.setChannel(reference);
Original file line number Diff line number Diff line change
@@ -233,7 +233,7 @@ private void extractedHeaders(
List<KafkaTopicSchemaRecord> records = kafkaService.resolve();
for (KafkaTopicSchemaRecord record : records)
{
if (record.name.endsWith("_replies_sink"))
if (record.name.endsWith("_replies"))
{
ZillaBindingOptionsConfig.KafkaTopicConfig topicConfig =
new ZillaBindingOptionsConfig.KafkaTopicConfig();