zilla
zilla copied to clipboard
Support create, update, delete and list Kafka topics via psql client using sql syntax
Describe the desired outcome from the user's perspective As an appdev, I want to use familiar SQL syntax to manage strongly typed Kafka topics and passthrough to other psql endpoint for other sql statements.
Acceptance criteria
-
CREATE TOPIC
sql statement to create a Kafka topic with schema (via catalog) -
DROP TOPIC
sql statement to delete a Kafka topic with schema -
ALTER TOPIC
sql statement to update a Kafka topic schema (via catalog) -
SHOW TOPICS
sql state to list Kafka topics with schemas (via catalog)
Note: consider CREATE TABLE
style syntax.
Additional context
Requires psql
binding server
and client
to proxy to remote psql
server, route by command
to send CREATE TOPIC
etc to specific processing, and psql-kafka
binding to map to CreateTopicRequest
and DeleteTopicRequest
plus catalog
support to register new schemas.
See psql
protocol specification.
Tasks
- https://github.com/aklivity/zilla/issues/1057
- https://github.com/aklivity/zilla/issues/1058
- https://github.com/aklivity/zilla/issues/1059
- https://github.com/aklivity/zilla/issues/1060