View Source KafkaEx.Server0P9P0 (kafka_ex v0.13.0)
Implements KafkaEx.Server behaviors for Kafka >= 0.9.0 < 0.10.1 API.
Link to this section Summary
Functions
Callback implementation for KafkaEx.Server.kafka_server_api_versions/1
.
Callback implementation for KafkaEx.Server.kafka_server_consumer_group/1
.
Callback implementation for KafkaEx.Server.kafka_server_consumer_group_metadata/1
.
Callback implementation for KafkaEx.Server.kafka_server_create_topics/3
.
Callback implementation for KafkaEx.Server.kafka_server_delete_topics/3
.
Callback implementation for KafkaEx.Server.kafka_server_fetch/2
.
Callback implementation for KafkaEx.Server.kafka_server_heartbeat/3
.
Callback implementation for KafkaEx.Server.kafka_server_init/1
.
Callback implementation for KafkaEx.Server.kafka_server_join_group/3
.
Callback implementation for KafkaEx.Server.kafka_server_leave_group/3
.
Callback implementation for KafkaEx.Server.kafka_server_metadata/2
.
Callback implementation for KafkaEx.Server.kafka_server_offset/4
.
Callback implementation for KafkaEx.Server.kafka_server_offset_commit/2
.
Callback implementation for KafkaEx.Server.kafka_server_offset_fetch/2
.
Callback implementation for KafkaEx.Server.kafka_server_produce/2
.
Callback implementation for KafkaEx.Server.kafka_server_sync_group/3
.
Callback implementation for KafkaEx.Server.kafka_server_update_consumer_metadata/1
.
Callback implementation for KafkaEx.Server.kafka_server_update_metadata/1
.
Link to this section Functions
broker_for_consumer_group_with_update(state, use_first_as_default \\ false)
View SourceCallback implementation for KafkaEx.Server.kafka_server_api_versions/1
.
Callback implementation for KafkaEx.Server.kafka_server_consumer_group/1
.
Callback implementation for KafkaEx.Server.kafka_server_consumer_group_metadata/1
.
Callback implementation for KafkaEx.Server.kafka_server_create_topics/3
.
Callback implementation for KafkaEx.Server.kafka_server_delete_topics/3
.
Callback implementation for KafkaEx.Server.kafka_server_fetch/2
.
Callback implementation for KafkaEx.Server.kafka_server_heartbeat/3
.
Callback implementation for KafkaEx.Server.kafka_server_init/1
.
Callback implementation for KafkaEx.Server.kafka_server_join_group/3
.
Callback implementation for KafkaEx.Server.kafka_server_leave_group/3
.
Callback implementation for KafkaEx.Server.kafka_server_metadata/2
.
Callback implementation for KafkaEx.Server.kafka_server_offset/4
.
Callback implementation for KafkaEx.Server.kafka_server_offset_commit/2
.
Callback implementation for KafkaEx.Server.kafka_server_offset_fetch/2
.
Callback implementation for KafkaEx.Server.kafka_server_produce/2
.
kafka_server_produce_send_request(correlation_id, produce_request, produce_request_data, state)
View SourceCallback implementation for KafkaEx.Server.kafka_server_sync_group/3
.
Callback implementation for KafkaEx.Server.kafka_server_update_consumer_metadata/1
.
Callback implementation for KafkaEx.Server.kafka_server_update_metadata/1
.