dalelane

version: "3"

services:
    zookeeper:
        platform: linux/amd64
        image: cp.icr.io/cp/ibm-eventstreams-kafka:11.1.2
        container_name: zookeeper
        hostname: zookeeper
        command:
            [

dalelane

asyncapi: 2.3.0

# ---

id: 'urn:dalelane:stock-level-events'

# ---

info:
  title: Stock level events

dalelane

# -------------------------------------------------------------------
# update these to match your Event Endpoint Management instance
# -------------------------------------------------------------------
NAMESPACE=eventendpointmanagement
INSTANCE=eem

echo "\n\033[1;33m getting SSL/TLS details for Event Gateway in...\033[0m"
echo "namespace      : $NAMESPACE"
echo "instance       : $INSTANCE"

dalelane

# -------------------------------------------------------------------
# update these to match your Event Endpoint Management instance
# -------------------------------------------------------------------
NAMESPACE=eventendpointmanagement
INSTANCE=eem

echo "\n\033[1;33m getting SSL/TLS details for Event Gateway in...\033[0m"
echo "namespace      : $NAMESPACE"
echo "instance       : $INSTANCE"

dalelane

asyncapi: 2.0.0

# ---

id: 'urn:dalelane:stock-level-events'

# ---

info:
  title: Stock level events

dalelane

{
    "type": "record",
    "namespace": "co.uk.dalelane",
    "name": "TemperatureReading",
    "fields": [
        {
            "name": "warehouse",
            "type": {
              "type": "enum",
              "name": "Warehouse",

dalelane

Describing Kafka schema usage using AsyncAPI

I've picked a dozen scenarios to illustrate the range of things that I think AsyncAPI needs to be able to describe. My goal is to have enough information in the AsyncAPI spec for a developer writing an app to consume messages from the topic.

Updated following feedback in Slack and Github - see revisions to see what has changed

• Binary-encoded Avro
• JSON-encoded Avro
• Confluent using schema registry
• Confluent

dalelane

asyncapi: '2.0.0'
id: 'urn:some:unique:id'
info:
  title: The whole spec
  ...
servers:
  nameofmycluster:
    url: someaddress:port
    protocol: kafka-secure
    security:

dalelane

asyncapi: '2.0.0'
...
channels:
  my.topic.name:
    ...
    subscribe:
      ...
      message:
        ...
        schemaFormat: 'application/vnd.apache.avro;version=1.9.0'

dalelane

asyncapi: '2.0.0'
...
channels:
  my.topic.name:
    ...
    subscribe:
      ...
      message:
        ...
        schemaFormat: 'application/vnd.apache.avro;version=1.9.0'