search

tamediadigital / librdkafka-d

11 stars 2 forks source link

improve vibe.d support! #6

Closed 9il closed 7 years ago

9il commented 7 years ago

The idea is:

  1. Use version(Have_vibe_d) to estimate if vibe.d is used.
  2. Use mixin to generate proper code.
  3. Use separate worker thread for rdkafka.
  4. Send delegate to the worker thread to execute them.
  5. Use vibed Tasks, Mutexes, and Conditions.
yannick commented 7 years ago

approach looks great. please add two examples, one for producer and one for consumer including loading of a config file that has metadata call enabled.

9il commented 7 years ago

please add two examples, one for producer and one for consumer including loading of a config file that has metadata call enabled.

OK

yannick commented 7 years ago

in the example please show how to use the kafka timestamp feature

9il commented 7 years ago

A combination of https://github.com/dlang/dub/issues/904 and other bug which runs dub in infinity loop (100% CPU load). Because that I have changed the dub.json files. No to add vibe.d support project must be compiled with --combined flag

9il commented 7 years ago

Configuration files are presented for producer_vibed and consumer_vibed.

9il commented 7 years ago

Consumer has example with timestamps. Producer has not timestamp support because #7. Should I fix #7 ?