hongbo-miao/hongbomiao.com

View on GitHub
hm-kafka/kafka-client/kafka-c/avro-producer/src/schema.c

Summary

Maintainability
Test Coverage
#include "../include/schema.h"

void print_serdes_schema(serdes_schema_t *serdes_schema) {
  if (!serdes_schema) {
    g_print("serdes_schema is NULL.\n");
    return;
  }

  const char *schema_name = serdes_schema_name(serdes_schema);
  if (schema_name) {
    g_print("schema_name: %s\n", schema_name);
  } else {
    g_print("Failed to retrieve schema_name.\n");
  }

  int schema_id = serdes_schema_id(serdes_schema);
  g_print("schema_id: %d\n", schema_id);

  const char *schema_definition = serdes_schema_definition(serdes_schema);
  if (schema_definition) {
    g_print("serdes_schema: %s\n", schema_definition);
  } else {
    g_print("Failed to retrieve serdes_schema.\n");
  }
}

void print_avro_schema(avro_schema_t schema) {
  char schema_str[8192];
  avro_writer_t writer = avro_writer_memory(schema_str, sizeof(schema_str));
  avro_schema_to_json(schema, writer);
  g_print("schema: %s\n", schema_str);
}