tamediadigital / librdkafka-d Goto Github PK

• create a easy interface to set the rebalance callback so it can be a D delegate.
• add it to the example

document each step escpecially in the vibed examples.

e.g.

• why is the __gshared needed
• can the tasks crash, and if so what happens? how can this be made fail-safe so the app never stops / retries until the server is rechable again. (please test locally by killing of kafka)
• showcase timestamp
• document / use flag usage RD_KAFKA_MSG_F_FREE (if usable with D) RD_KAFKA_MSG_F_COPY RD_KAFKA_MSG_F_BLOCK
• delivery report doable?

D wrapper as CPP wrapper successor uses rd_kafka_produce instead of new variadic interface that have timestamp support.

is there a problem with switching timeout_ms to be the last parameter with a default for the consume method family ?
it would remove a bit of clutter in the interface

On windows compiling X86_64 architecture, there are syntax errors:

dependencies/librdkafka-d/source/rdkafkad/handler/package.d(114,63): Error: function deimos.rdkafka.rd_kafka_query_watermark_offsets(rd_kafka_s* rk, const(char)* topic, int partition, __c_long* low, __c_long* high, int timeout_ms) is not callable using argument types (rd_kafka_s*, const(char), int, long, long*, int)
dependencies/librdkafka-d/source/rdkafkad/handler/package.d(114,63): cannot pass argument &low of type long* to parameter __c_long* low
dependencies/librdkafka-d/source/rdkafkad/handler/package.d(410,62): Error: function deimos.rdkafka.rd_kafka_get_watermark_offsets(rd_kafka_s* rk, const(char)* topic, int partition, __c_long* low, __c_long* high) is not callable using argument types (rd_kafka_s*, const(char), int, long, long*)
dependencies/librdkafka-d/source/rdkafkad/handler/package.d(410,62): cannot pass argument &low of type long* to parameter __c_long* low
/usr/bin/dmd failed with exit code 1.

__c_long is an alias for ddoc_long which is int on windows.
See module core.stdc.config line 31