Topic Pub/Sub SQL

Topic Pub/Sub SQL in KalamDB is documented in the Topic Pub/Sub section because the same workflow covers setup, inspection, and consumer-group behavior.

For the canonical command reference, see SQL Topics & Consumers.

Syntax Covered

The topic SQL reference covers:

• CREATE TOPIC ... PARTITIONS ...
• ALTER TOPIC ... SET RETENTION ...
• ALTER TOPIC ... ADD SOURCE ... ON INSERT|UPDATE|DELETE ...
• CONSUME FROM ... GROUP ... FROM ... LIMIT ...
• ACK ... GROUP ... UPTO OFFSET ...
• RESET CONSUMER GROUP ... ON ... TO ...
• CLEAR TOPIC and DROP TOPIC

Quick Example

1CREATE TOPIC app.user_events PARTITIONS 1;2 3ALTER TOPIC app.user_events4ADD SOURCE app.users5ON INSERT6WITH (payload = 'full');7 8CONSUME FROM app.user_events9GROUP 'ai-worker'10FROM EARLIEST11LIMIT 10;12 13ACK app.user_events14GROUP 'ai-worker'15UPTO OFFSET 9;

Continue with SQL Topics & Consumers for retention options, payload modes, consumer group offset rules, ACK behavior, and admin reset commands.