Update to zig 0.15.1

Author: theothornhill

build.zig

@@ -12,6 +12,7 @@ pub fn build(b: *std.Build) void {
     });
 
     const librdkafka_artifact = librdkafka.artifact("rdkafka");
+    b.installArtifact(librdkafka_artifact);
 
     const zk = b.addModule("zig-kafka", .{
         .root_source_file = b.path("lib/kafka.zig"),
@@ -36,10 +37,14 @@ pub fn build(b: *std.Build) void {
     zk.linkSystemLibrary("liblz4", .{ .needed = true, .preferred_link_mode = .static });
     zk.linkSystemLibrary("libsasl2", .{ .needed = true, .preferred_link_mode = .static });
 
+    // b.installArtifact(zk);
+
     const exe_unit_tests = b.addTest(.{
-        .root_source_file = b.path("lib/kafka.zig"),
-        .target = target,
-        .optimize = optimize,
+        .root_module = b.createModule(.{
+            .root_source_file = b.path("lib/kafka.zig"),
+            .target = target,
+            .optimize = optimize,
+        }),
     });
 
     exe_unit_tests.addIncludePath(librdkafka_artifact.getEmittedIncludeTree());

build.zig.zon

@@ -1,15 +1,15 @@
 .{
     .name = .zigkafka,
     .fingerprint = 0xcef3e6efcff2a10e,
-    .version = "4.0.2",
+    .version = "5.0.0",
     .dependencies = .{
         .librdkafka = .{
-            .url = "https://github.com/theothornhill/librdkafka/archive/refs/tags/2.8.0+4.zip",
-            .hash = "librdkafka-2.8.0-WaVnhWBgkAB5V1DwZrkkFFf6gYDex2g4OtZSUS0jX5hV",
+            .url = "https://github.com/theothornhill/librdkafka/archive/refs/tags/2.8.0+5.zip",
+            .hash = "librdkafka-2.8.0-WaVnhedgkABjPXsz_2L10ORZmLCXhQd3eFpFJJqJdn_g",
         },
         .@"zig-avro" = .{
-            .url = "https://github.com/theothornhill/zig-avro/archive/refs/tags/3.0.1.zip",
-            .hash = "zig_avro-3.0.1-LSuFEQ94AgDwMaOoQlLqsq1m8A9FBx003kUoz3gEpEdu",
+            .url = "https://github.com/theothornhill/zig-avro/archive/refs/tags/4.0.0.tar.gz",
+            .hash = "zig_avro-4.0.0-LSuFEfaCAgCFXlX1IlE5SWxHQf3vUYF-4eDxy2QqevY0",
         },
     },
     .paths = .{

lib/config.zig

@@ -16,7 +16,7 @@ pub fn init(allocator: std.mem.Allocator) !Config {
         };
 
         try cfg.set(allocator, "client.software.name", "zig-kafka");
-        try cfg.set(allocator, "client.software.version", "4.0.2");
+        try cfg.set(allocator, "client.software.version", "5.0.0");
 
         return cfg;
     }

lib/producer.zig

@@ -11,7 +11,7 @@ const Producer = @This();
 
 handle: *c.rd_kafka_t,
 queue: ?*c.rd_kafka_queue_t,
-buffer: std.ArrayList(u8),
+buffer: std.Io.Writer.Allocating,
 allocator: std.mem.Allocator,
 
 pub fn init(allocator: std.mem.Allocator, cfg: *Config) !Producer {
@@ -27,7 +27,7 @@ pub fn init(allocator: std.mem.Allocator, cfg: *Config) !Producer {
             .allocator = allocator,
             .handle = ph,
             .queue = c.rd_kafka_queue_get_main(ph),
-            .buffer = try std.ArrayList(u8).initCapacity(allocator, 1024),
+            .buffer = try .initCapacity(allocator, 1024),
         };
     }
     @panic("Producer handle failed initializing");
@@ -63,7 +63,7 @@ pub fn poller(self: @This(), timeout_ms: usize, healthy: *bool) !void {
         std.log.debug("Producer poll", .{});
         try self.poll(timeout_ms);
 
-        std.time.sleep(std.time.ns_per_s * 15);
+        std.Thread.sleep(std.time.ns_per_s * 15);
     }
 }
 

lib/schemaregistry.zig

@@ -20,7 +20,7 @@ fn authUrl(self: @This(), url_path: []const u8) !std.Uri {
     };
 }
 
-fn fetchSchema(self: @This(), response_storage: *std.ArrayList(u8), subject: []const u8, schema: []const u8) !void {
+fn fetchSchema(self: @This(), response_storage: *std.Io.Writer, subject: []const u8, schema: []const u8) !void {
     const Schema = struct { schema: []const u8 };
     var client = std.http.Client{ .allocator = self.allocator };
     defer client.deinit();
@@ -29,34 +29,41 @@ fn fetchSchema(self: @This(), response_storage: *std.ArrayList(u8), subject: []c
     const auth_url = try self.authUrl(url_path);
     const shb = try self.allocator.alloc(u8, 1024);
     defer self.allocator.free(shb);
-    var schema_json = std.ArrayList(u8).init(self.allocator);
+    var schema_json: std.Io.Writer.Allocating = .init(self.allocator);
     defer schema_json.deinit();
-    try std.json.stringify(Schema{ .schema = schema }, .{}, schema_json.writer());
+    var json_writer: std.json.Stringify = .{ .writer = &schema_json.writer };
+
+    try json_writer.write(Schema{ .schema = schema });
+
     const result = client.fetch(.{
-        .response_storage = .{ .dynamic = response_storage },
-        .server_header_buffer = shb,
+        .response_writer = response_storage,
         .method = std.http.Method.POST,
         .location = .{ .uri = auth_url },
-        .payload = schema_json.items,
+        .payload = schema_json.written(),
     }) catch |err| {
         std.log.err("error reaching {s} on {} port {}: {}", .{ url_path, auth_url.host.?, auth_url.port.?, err });
         return errors.SchemaError.RegistryUnreachable;
     };
     if (result.status != std.http.Status.ok) {
-        std.log.err("response {} not 200 OK on {s} getting schema at {s}: {s}", .{ result.status, subject, url_path, response_storage.items });
+        std.log.err("response {} not 200 OK on {s} getting schema at {s}: {s}", .{
+            result.status,
+            subject,
+            url_path,
+            response_storage.buffer[0..response_storage.end],
+        });
         return errors.SchemaError.RegistryAngry;
     }
 }
 
 pub fn findSchemaId(self: @This(), topic: []const u8, schema: []const u8) !u32 {
     const SchemaVersionResponse = struct { id: u32 };
-    var response_storage = std.ArrayList(u8).init(self.allocator);
-    try self.fetchSchema(&response_storage, topic, schema);
+    var response_storage: std.Io.Writer.Allocating = .init(self.allocator);
+    try self.fetchSchema(&response_storage.writer, topic, schema);
     errdefer response_storage.deinit();
     const parsed = try std.json.parseFromSlice(
         SchemaVersionResponse,
         self.allocator,
-        response_storage.items,
+        response_storage.written(),
         .{ .ignore_unknown_fields = true },
     );
     defer parsed.deinit();