produce
and consume
permissions to a namespace for the target topic.If you are using a Ursa-Engine powered cluster, please note that KStreams and KSQLDB support in Ursa Engine has certain limitations. It doesn’t support functionalities that require transactions and topic compaction.kcat
will be equal to token:<API KEY>
.etc/ksqldb/ksql-server.properties
file and configure the KSQL server with the following properties:
bootstrap.servers
: the Kafka service URL of your StreamNative cluster.password
: an API key of your service account.riderLocations
:
currentLocation
and ridersNearMountainView
) to track the latest location of the riders using a materialized view.