kwonghung-YIP/spring-kafka-stream

Java

docker compose -f docker-compose.yaml up -d

watch docker compose -f docker-compose.yaml ps

create or replace stream rand_quote (
   ticker varchar key,
   price double
) with (
    kafka_topic = 'random-quote',
    partitions = '1',
    value_format = 'JSON'
);

create or replace table quote_tbl (
   ticker varchar primary key,
   price double
) with (
    kafka_topic = 'random-quote',
    partitions = '1',
    value_format = 'JSON'
);

References