mirror of
https://github.com/featurebasedb/featurebase.git
synced 2026-10-09 12:27:52 +00:00
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. |
||
|---|---|---|
| .. | ||
| config.go | ||
| runner.go | ||