#bin/zookeeper-server-start.sh config/zookeeper.properties
#bin/kafka-server-start.sh config/server.properties

#bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic mytopic

CREATE TABLE mytable (
  id varchar(80)
);

#bin/kafka-console-producer.sh --broker-list localhost:9092 --topic mytopic
{"id": "12"}

COPY public.mytable SOURCE KafkaSource (stream='mytopic|1|1', brokers='localhost:9092', stop_on_eof=TRUE) 
PARSER KafkaJSONParser(flatten_arrays=False, flatten_maps=False) 
REJECTED DATA AS TABLE public.mytable_rej TRICKLE;

 Rows Loaded
-------------
           0
(1 row)