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.<kafka-stream-application-name>-counts-store-repartition
and <kafka-stream-application-name>-counts-store-changelog
.java.lang.UnsatisfiedLinkError
error when starting the Kafka Stream application.
wordcount-application
.
serverUrl
: the Kafka service URL of your StreamNative cluster.keyPath
: the path to your downloaded OAuth2 credential file.audience
: the audience
parameter is a combination of the urn:sn:pulsar
, your organization name, and your Pulsar instance name.TextLinesTopic
topic.