fkafka_ffi 1.0.2 copy "fkafka_ffi: ^1.0.2" to clipboard
fkafka_ffi: ^1.0.2 copied to clipboard

Use librdkafka via Dart FFI, wraps admin and producer and consumer clients.

fkafka - Dart wrapper of the librdkafka #

Overview #

Use librdkafka via Dart FFI, wraps admin and producer and consumer clients.

Features #

1. Admin Client #

  • create topic
  • query topics
  • query groups
  • query topic offsets
  • query group committed offsets

2. Producer Client #

(coming soon)

3. Consumer Client #

(coming soon)

Usage #

  1. ready librdkafka

    • if windows, can download dll file form this, and then put the file in current dir or set env LIBRDKAFKA_ROOT the value is dll file dir.
  2. in your code

    1. instantiate the client
    var client = FkafkaAdminClient(
      conf: FkafkaConf({
        'bootstrap.servers': '127.0.0.1:9092'
      })
    );
    
    1. use its method like create topic
    client.newTopic('first-topic');
    
    1. release when no longer in use
    client.release();
    
4
likes
120
pub points
13%
popularity

Publisher

verified publisherheadone.cn

Use librdkafka via Dart FFI, wraps admin and producer and consumer clients.

Repository (GitHub)
View/report issues

Documentation

API reference

License

BSD-3-Clause (license)

Dependencies

ffi

More

Packages that depend on fkafka_ffi