Kafka®-compatible brokers by Selfhost.dev, with the data kept in S3.

# client.properties, as the Connection tab gives it
bootstrap.servers=YOUR_BROKER:9092
# SASL_PLAINTEXT until the certificate lands
security.protocol=SASL_SSL
sasl.mechanism=SCRAM-SHA-256
sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="YOUR_USER" password="YOUR_PASSWORD";

# create a topic: replication factor 1, the data lives in S3
kafka-topics.sh --bootstrap-server YOUR_BROKER:9092 \
  --command-config client.properties \
  --create --topic events --partitions 3 --replication-factor 1

# pip install confluent-kafka
import os
from confluent_kafka import Producer

producer = Producer({
    "bootstrap.servers": "YOUR_BROKER:9092",
    "security.protocol": "SASL_SSL",  # SASL_PLAINTEXT until the certificate lands
    "sasl.mechanism": "SCRAM-SHA-256",
    "sasl.username": "YOUR_USER",
    "sasl.password": os.environ["KAFKA_PASSWORD"],
})
producer.produce("events", b'{"order": 1042}')
producer.flush()

// npm install kafkajs
const { Kafka } = require('kafkajs');

const kafka = new Kafka({
  brokers: ['YOUR_BROKER:9092'],
  ssl: true, // false until the certificate lands
  sasl: { mechanism: 'scram-sha-256', username: 'YOUR_USER', password: process.env.KAFKA_PASSWORD },
});

const producer = kafka.producer();
await producer.connect();
await producer.send({ topic: 'events', messages: [{ value: '{"order":1042}' }] });
await producer.disconnect();