Kayrock.Client (kayrock v1.0.0-rc1)

Development client for communicating with a Kafka cluster.

Limitations

This client lacks:

Connection pooling
Proper supervision tree
Circuit breaker patterns
Automatic reconnection handling
Production-grade error handling
Telemetry/monitoring

Summary

Functions

broker_call(pid, node_selector, request)

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

cluster_metadata(pid)

start_link(seed_broker_uris \\ [{"localhost", 9092}], opts \\ [])

stop(pid)

Functions

broker_call(pid, node_selector, request)

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

cluster_metadata(pid)

start_link(seed_broker_uris \\ [{"localhost", 9092}], opts \\ [])

stop(pid)