Commit graph

6 commits

Author SHA1 Message Date
Travis Turner
44e4b30e9f
Switch fbsql from using kafka_static to kafka_sasl
Since we likely want to use the ConfluentCommand support in the future,
this uses kafka_sasl package instead of kafka_static. That allows us to
continue using non-avro headers (which the kafka package uses), but still
use ConfluentCommand.

This also adds the Timeout logic to the kafka_sasl package.
2023-03-06 15:14:39 -06:00
Travis Turner
35211cb8c0
Rename Basic() to SetBasic() 2023-03-06 13:31:17 -06:00
Travis Turner
599205ae15
Re-organize the fbsql kafka config and setup.
Allow field config to use the table schema if no fields provided.
2023-03-06 13:31:16 -06:00
Travis Turner
6107ddef47
Fold decimal(scale) into kafka.source-type 2023-03-06 13:31:16 -06:00
Travis Turner
634553d3c3
Move "Molecula Consumer" message to the logger; hide it in basic mode 2023-03-06 13:31:16 -06:00
Travis Turner
7a7bb0c928
Add kafka support to CLI (fbsql)
This commit adds the ability to provide a `--kafka-config` command line
argument referncing a toml file to configure kafka.
2023-03-06 13:31:15 -06:00