 Mike Cao
|
8525188e42
|
Changed import path.
|
2025-02-05 15:59:59 -08:00 |
|
|
Mike Cao
|
aaa51e72d3
|
Adding logging for Kafka. Refactor send method.
|
2025-01-17 19:56:59 -08:00 |
|
|
Mike Cao
|
1da81150d5
|
Added timeout for Kafka producer.
|
2025-01-17 19:10:00 -08:00 |
|
|
Francis Cao
|
089137ef8d
|
update kafka ack setting
|
2025-01-02 10:31:19 -08:00 |
|
|
Francis Cao
|
702be4e9fb
|
update kafka client config
|
2024-12-17 20:44:41 -08:00 |
|
|
Francis Cao
|
8f692a150c
|
update kafka client to take in environement variables to declare SASL/SSL options
|
2024-12-14 11:49:15 -08:00 |
|
|
Mike Cao
|
04de691893
|
Removed custom date format. Use ISO string everywhere.
|
2024-08-13 22:16:21 -07:00 |
|
|
Mike Cao
|
72b3b6158a
|
Changed kafka method signature.
|
2024-07-05 02:29:12 -07:00 |
|
|
Francis Cao
|
a2e4ab7d46
|
update kafka connection to upstash config
|
2024-04-15 13:44:16 -07:00 |
|
|
Mike Cao
|
ede658771e
|
Moved code into src folder. Added build for component library.
|
2023-08-21 02:06:09 -07:00 |
|