70 replace kafka rust library with rust rdkafka - #72

Merged

tribeiro merged 23 commits into

mainfrom

70-replace-kafka-rust-library-with-rust-rdkafka

Jan 11, 2026

Commits on Jan 1, 2026

Update gitignore to remove Cargo.lock.
tribeiro
committed
51f29a9
In ``Cargo.toml``, update dependencies.
tribeiro
committed
9a46d4f
Update generics to be compatible with latest version of ``apache-avro`` library.
tribeiro
committed
e096aba

Commits on Jan 11, 2026

In ``Cargo.toml``, replace the ``kafka`` library with ``rdkafka``.
tribeiro
committed
818d038
In ``src/domain/rs``, major refactor to replace the ``kafka`` library with ``rdkafka``.
tribeiro
committed
67e5dce
In ``src/topics/read_topic.rs``, refactor to replace the ``kafka`` library with ``rdkafka``.
tribeiro
committed
5f98157
In ``src/topics/write_topic.rs``, refactor to replace the ``kafka`` library with ``rdkafka``.
tribeiro
committed
8acf842
In ``src/topics/remote_command.rs``, update log statement to include the name of the topic.
tribeiro
committed
3dcbbe6
In ``src/topics/topic_info.rs``, remove unnecessary imports in the module test.
tribeiro
committed
5fcf0c5
In ``src/remote.rs``, update to account for the changes needed for the ``kafka`` -> ``rdkafka`` refactor.
tribeiro
committed
e0a1d9a
In ``src/controller.rs``, update to account for the changes needed for the ``kafka`` -> ``rdkafka`` refactor.
tribeiro
committed
bf5c607
In ``src/utils/schema_utils.rs``, improve error message when ``LSST_SCHEMA_PATH`` environment variable is not set and some additional minor updates reading files.
tribeiro
committed
0730c66
In ``src/csc/test_csc/topics/scalars.rs``, update to be compatible with latest version of apache-avro library.
tribeiro
committed
011f815
In ``src/topics/write_topic.rs``, update ``WriteTopic.write_typed`` to remove check of the sequence number (and some old comment).
tribeiro
committed
fb98d9f
In ``src/csc/test_csc/csc.rs``, update to account for the changes needed for the ``kafka`` -> ``rdkafka`` refactor.
tribeiro
committed
caaabf2
In ``src/csc/test_csc/csc.rs``, add debug message in the task that processes commands, also change ``to_owned`` to ``to_string`` when creating the ``CmdData`` object.
tribeiro
committed
ebfff7f
In ``src/csc/test_csc/csc.rs``, improve error message when processing the ``setScalars`` command.
tribeiro
committed
dbb508a
In ``src/bin/set_summary_state.rs``, update to account for the changes needed for the kafka -> rdkafka refactor.
tribeiro
committed
dbfaf70
In ``src/bin/run_test_csc.rs``, update to account for the changes needed for the ``kafka`` -> ``rdkafka`` refactor.
tribeiro
committed
57a5d1f
In ``examples/read_test_topic.rs``, update to account for the changes needed for the ``kafka`` -> ``rdkafka`` refactor.
tribeiro
committed
ada143c
In ``tests/test_base_csc.rs``, update to account for the changes needed for the ``kafka`` -> ``rdkafka`` refactor.
tribeiro
committed
3a277ac
Add ``Cargo.lock``.
tribeiro
committed
0e5c223
Update clippy check github workflow.
tribeiro
committed
bb60cba

Navigation Menu

70 replace kafka rust library with rust rdkafka - #72

70 replace kafka rust library with rust rdkafka#72
tribeiro merged 23 commits into
mainfrom
70-replace-kafka-rust-library-with-rust-rdkafka

Commits on Jan 1, 2026

Update gitignore to remove Cargo.lock.

In ``Cargo.toml``, update dependencies.

Update generics to be compatible with latest version of ``apache-avro`` library.

Commits on Jan 11, 2026

In ``Cargo.toml``, replace the ``kafka`` library with ``rdkafka``.

In ``src/domain/rs``, major refactor to replace the ``kafka`` library with ``rdkafka``.

In ``src/topics/read_topic.rs``, refactor to replace the ``kafka`` library with ``rdkafka``.

In ``src/topics/write_topic.rs``, refactor to replace the ``kafka`` library with ``rdkafka``.

In ``src/topics/remote_command.rs``, update log statement to include the name of the topic.

In ``src/topics/topic_info.rs``, remove unnecessary imports in the module test.

In ``src/remote.rs``, update to account for the changes needed for the ``kafka`` -> ``rdkafka`` refactor.

In ``src/controller.rs``, update to account for the changes needed for the ``kafka`` -> ``rdkafka`` refactor.

In ``src/utils/schema_utils.rs``, improve error message when ``LSST_SCHEMA_PATH`` environment variable is not set and some additional minor updates reading files.

In ``src/csc/test_csc/topics/scalars.rs``, update to be compatible with latest version of apache-avro library.

In ``src/topics/write_topic.rs``, update ``WriteTopic.write_typed`` to remove check of the sequence number (and some old comment).

In ``src/csc/test_csc/csc.rs``, update to account for the changes needed for the ``kafka`` -> ``rdkafka`` refactor.

In ``src/csc/test_csc/csc.rs``, add debug message in the task that processes commands, also change ``to_owned`` to ``to_string`` when creating the ``CmdData`` object.

In ``src/csc/test_csc/csc.rs``, improve error message when processing the ``setScalars`` command.

In ``src/bin/set_summary_state.rs``, update to account for the changes needed for the kafka -> rdkafka refactor.

In ``src/bin/run_test_csc.rs``, update to account for the changes needed for the ``kafka`` -> ``rdkafka`` refactor.

In ``examples/read_test_topic.rs``, update to account for the changes needed for the ``kafka`` -> ``rdkafka`` refactor.

In ``tests/test_base_csc.rs``, update to account for the changes needed for the ``kafka`` -> ``rdkafka`` refactor.

Add ``Cargo.lock``.

Update clippy check github workflow.