feat(kafka-rust): add avro support (#19843)

hongbo-miao · Oct 25, 2024 · 7f3bbc1 · 7f3bbc1
1 parent f37f54f
commit 7f3bbc1
Show file tree

Hide file tree

Showing 7 changed files with 1,114 additions and 122 deletions.
diff --git a/Makefile b/Makefile
@@ -156,6 +156,8 @@ rust-update:
 rust-version:
 	rustc --version
 
+rustup-set-default-rust-version:
+	rustup default 1.80.1
 rustup-update:
 	rustup self update
 rustup-add:

diff --git a/hm-kafka/kafka-client/kafka-c/avro-producer/src/main.c b/hm-kafka/kafka-client/kafka-c/avro-producer/src/main.c
@@ -20,8 +20,8 @@
 int main(int argc, char **argv) {
   const char *confluent_schema_registry_url =
     "https://confluent-schema-registry.internal.hongbomiao.com";
-  const char *topic = "production.iot.device.json";
-  const char *schema_name = "production.iot.device.json-value";
+  const char *topic = "production.iot.device.avro";
+  const char *schema_name = "production.iot.device.avro-value";
 
   rd_kafka_t *producer;
   rd_kafka_conf_t *conf;