Klife
▼
Project version
v0.5.0
v0.4.0
v0.3.0
v0.2.0
v0.1.0
Pages
Modules
Mix
Tasks
API Reference
Modules
Mix Tasks
README
Features
Installation
Basic Usage
Producer performance
Compatibility with Kafka versions
Examples
Client configuration
Simplest configuration
SSL with SASL and custom socket opts
Defining and using multiple producers
Defining and using custom partitioner
Defining multiple transactional (txn) pools
Using custom default producer, partitioner and txn pool
Klife
Klife.TestUtils.AsyncProducerBenchmark
Summary
Functions
run/2
Client
Klife.Client
Sections
Using it in a module
Configuration
Starting it
Producer API overview
Summary
Producer API
produce/2
produce_async/2
produce_batch/2
produce_batch_async/2
Transaction API
produce_batch_txn/2
transaction/2
Types
list_of_records/0
record/0
Klife.Record
Summary
Types
t/0
Functions
t/0
verify_batch/1
verify_batch!/1
Klife.Topic
Sections
Client configurations
Producer
Klife.Producer
Sections
Client configurations
Interacting with producers
How many producers?
Order guarantees
Dynamic batching
Batchers Count
Topic default producer
Client default producer
Summary
Functions
produce_async/3
Klife.Producer.DefaultPartitioner
Klife.TxnProducerPool
Sections
Client configurations
How to use?
Basic understanding
Semantics
Summary
Functions
in_txn?/1
Testing
Klife.Testing
Summary
Functions
all_produced/3
get_latest_offsets/3
setup/1
Behaviours
Klife.Behaviours.Partitioner
Summary
Callbacks
get_partition/2
Example
MyClient
Summary
Functions
child_spec/1
get_default_partitioner/0
get_default_producer/0
get_default_txn_pool/0
produce/2
produce_async/2
produce_batch/2
produce_batch_async/2
produce_batch_txn/2
transaction/2
mix benchmark
Summary
Functions
do_run_bench/2
do_run_bench/3
run/1
Search documentation of Klife
Settings
View Source
mix benchmark
(Klife v0.5.0)
Summary
Functions
do_run_bench(binary, parallel)
do_run_bench(binary, parallel, rec_qty)
run(args)
Callback implementation for
Mix.Task.run/1
.
Functions
Link to this function
do_run_bench(binary, parallel)
View Source
Link to this function
do_run_bench(binary, parallel, rec_qty)
View Source
Link to this function
run(args)
View Source
Callback implementation for
Mix.Task.run/1
.
×