chore: improve kafks_flush and precompile

jsvitolo · jsvitolo · commit 7bcc33937ee2 · 2024-08-07T10:09:04.000-03:00
diff --git a/.gitignore b/.gitignore
@@ -25,4 +25,6 @@ exrdkafka-*.tar
 # Temporary files, for example, from tests.
 /tmp/
 
-/priv/exrdkafka_nif.so
+/priv/exrdkafka_nif.so
+checksum.exs
+.cursorignore
diff --git a/c_src/exrdkafka_producer.cc b/c_src/exrdkafka_producer.cc
@@ -545,7 +545,7 @@ ERL_NIF_TERM enif_produce_sync(ErlNifEnv* env, int argc, const ERL_NIF_TERM argv
     }
 
     // Flush messages to broker
-    rd_kafka_resp_err_t flush_result = rd_kafka_flush(producer->kf, 1000); // 1000 is the timeout in milliseconds
+    rd_kafka_resp_err_t flush_result = rd_kafka_flush(producer->kf, 1);
 
     if(flush_result != RD_KAFKA_RESP_ERR_NO_ERROR)
         return make_error(env, enif_make_int(env, flush_result));
diff --git a/mix.exs b/mix.exs
@@ -79,7 +79,7 @@ defmodule Exrdkafka.MixProject do
         "mix.exs",
         "README.md",
         "LICENSE",
-        "checksum-*.exs",
+        "checksum.exs",
         "VERSION"
       ],
       description: "Elixir Kafka client NIF for librdkafka",

Original file line number	Diff line number	Diff line change
`@@ -545,7 +545,7 @@ ERL_NIF_TERM enif_produce_sync(ErlNifEnv* env, int argc, const ERL_NIF_TERM argv`
`545`	`545`	`}`
`546`	`546`
`547`	`547`	`// Flush messages to broker`
`548`		`- rd_kafka_resp_err_t flush_result = rd_kafka_flush(producer->kf, 1000); // 1000 is the timeout in milliseconds`
	`548`	`+ rd_kafka_resp_err_t flush_result = rd_kafka_flush(producer->kf, 1);`
`549`	`549`
`550`	`550`	`if(flush_result != RD_KAFKA_RESP_ERR_NO_ERROR)`
`551`	`551`	`return make_error(env, enif_make_int(env, flush_result));`