🦎 A multi-protocol edge & service proxy. Seamlessly interface web apps, IoT clients, & microservices to Apache Kafka® via declaratively defined, stateless APIs.
[ ] Implement codec support for graphql server; query, subscription, mutation
[ ] Map query to type-filtered kafka fetch, returning all fields, completing response after catching up to live messages
[ ] Map subscription to type-filtered kafka fetch, returning all fields
[ ] Map mutation to kafka produce with ack mode
[ ] Use typed sub-schema support to convey dynamic subset of selected fields for query and subscription
[ ] Provide example via graphql over ws in zilla-examples
[ ] Consider sse-graphql mapping to transform sse query params into graphqlsubscription fields
TODO: capture progress for reliable subscription message delivery and replay observed progress on subscription recovery, similar to query pagination cursor.
GraphQL (Octorber 2021) specification
graphql
server;query
,subscription
,mutation
query
to type-filteredkafka
fetch, returning all fields, completing response after catching up to live messagessubscription
to type-filteredkafka
fetch, returning all fieldsmutation
tokafka
produce withack
modequery
andsubscription
graphql
overws
inzilla-examples
sse-graphql
mapping to transformsse
query params intographql
subscription
fieldsTODO: capture progress for reliable subscription message delivery and replay observed progress on subscription recovery, similar to query pagination cursor.