kcat
will be equal to token:<API KEY>
.test-transaction-topic
topic. In this case, the isolation level to read_committed
, which means only 5 committed messages will be consumed, if you want to consume both committed and uncommitted messages, set it to read_uncommitted
.
serverUrl
: the Kafka service URL of your StreamNative cluster.jwtToken
: an API key of your service account.test-transaction-topic
topic and commit it, then send 5 messages and abort it.
serverUrl
: the Kafka service URL of your StreamNative cluster.jwtToken
: an API key of your service account.