kafka_ex v0.12.1

KafkaEx.Server0P10AndLater (kafka_ex v0.12.1) View Source

Implements kafkaEx.Server behaviors for kafka 0.10.1 API.

Link to this section Summary

Functions

broker_for_consumer_group_with_update(state, use_first_as_default \\ false)
consumer_group?(state)

See KafkaEx.Server0P9P0.consumer_group?/1.

handle_call(arg1, from, state)
handle_info(arg1, state)
init(list)
kafka_server_api_versions(state)

Callback implementation for KafkaEx.Server.kafka_server_api_versions/1.

kafka_server_consumer_group(state)

Callback implementation for KafkaEx.Server.kafka_server_consumer_group/1.

kafka_server_consumer_group_metadata(state)

Callback implementation for KafkaEx.Server.kafka_server_consumer_group_metadata/1.

kafka_server_create_topics(requests, network_timeout, state)

Callback implementation for KafkaEx.Server.kafka_server_create_topics/3.

kafka_server_delete_topics(topics, network_timeout, state)

Callback implementation for KafkaEx.Server.kafka_server_delete_topics/3.

kafka_server_fetch(fetch_request, state)

Callback implementation for KafkaEx.Server.kafka_server_fetch/2.

kafka_server_heartbeat(request, network_timeout, state_in)

Callback implementation for KafkaEx.Server.kafka_server_heartbeat/3.

kafka_server_init(list)

Callback implementation for KafkaEx.Server.kafka_server_init/1.

kafka_server_join_group(request, network_timeout, state_in)

Callback implementation for KafkaEx.Server.kafka_server_join_group/3.

kafka_server_leave_group(request, network_timeout, state_in)

Callback implementation for KafkaEx.Server.kafka_server_leave_group/3.

kafka_server_metadata(topic, state)

Callback implementation for KafkaEx.Server.kafka_server_metadata/2.

kafka_server_offset(topic, partition, time, state)

Callback implementation for KafkaEx.Server.kafka_server_offset/4.

kafka_server_offset_commit(offset_commit_request, state)

Callback implementation for KafkaEx.Server.kafka_server_offset_commit/2.

kafka_server_offset_fetch(offset_fetch, state)

Callback implementation for KafkaEx.Server.kafka_server_offset_fetch/2.

kafka_server_produce(produce_request, state)

Callback implementation for KafkaEx.Server.kafka_server_produce/2.

kafka_server_produce_send_request(correlation_id, produce_request, produce_request_data, state)
kafka_server_sync_group(request, network_timeout, state_in)

Callback implementation for KafkaEx.Server.kafka_server_sync_group/3.

kafka_server_update_consumer_metadata(state)

Callback implementation for KafkaEx.Server.kafka_server_update_consumer_metadata/1.

kafka_server_update_metadata(state)

Callback implementation for KafkaEx.Server.kafka_server_update_metadata/1.

retrieve_metadata(brokers, correlation_id, sync_timeout, topic \\ [], server_api_versions \\ [:unsupported])
retrieve_metadata(brokers, correlation_id, sync_timeout, topic, retry, error_code, server_api_versions \\ [:unsupported])
retrieve_metadata_with_version(brokers, correlation_id, sync_timeout, topic, retry, error_code, server_api_versions)
start_link(args, name \\ __MODULE__)
terminate(reason, state)
update_consumer_metadata(state, num, error_code)

See KafkaEx.Server0P8P2.update_consumer_metadata/3.

update_metadata(state)

Link to this section Functions

Link to this function

broker_for_consumer_group_with_update(state, use_first_as_default \\ false)

View Source
Link to this function

consumer_group?(state)

View Source

See KafkaEx.Server0P9P0.consumer_group?/1.

Link to this function

handle_call(arg1, from, state)

View Source
Link to this function

handle_info(arg1, state)

View Source
Link to this function

init(list)

View Source
Link to this function

kafka_server_api_versions(state)

View Source

Callback implementation for KafkaEx.Server.kafka_server_api_versions/1.

Link to this function

kafka_server_consumer_group(state)

View Source

Callback implementation for KafkaEx.Server.kafka_server_consumer_group/1.

Link to this function

kafka_server_consumer_group_metadata(state)

View Source

Callback implementation for KafkaEx.Server.kafka_server_consumer_group_metadata/1.

Link to this function

kafka_server_create_topics(requests, network_timeout, state)

View Source

Callback implementation for KafkaEx.Server.kafka_server_create_topics/3.

Link to this function

kafka_server_delete_topics(topics, network_timeout, state)

View Source

Callback implementation for KafkaEx.Server.kafka_server_delete_topics/3.

Link to this function

kafka_server_fetch(fetch_request, state)

View Source

Callback implementation for KafkaEx.Server.kafka_server_fetch/2.

Link to this function

kafka_server_heartbeat(request, network_timeout, state_in)

View Source

Callback implementation for KafkaEx.Server.kafka_server_heartbeat/3.

Link to this function

kafka_server_init(list)

View Source

Callback implementation for KafkaEx.Server.kafka_server_init/1.

Link to this function

kafka_server_join_group(request, network_timeout, state_in)

View Source

Callback implementation for KafkaEx.Server.kafka_server_join_group/3.

Link to this function

kafka_server_leave_group(request, network_timeout, state_in)

View Source

Callback implementation for KafkaEx.Server.kafka_server_leave_group/3.

Link to this function

kafka_server_metadata(topic, state)

View Source

Callback implementation for KafkaEx.Server.kafka_server_metadata/2.

Link to this function

kafka_server_offset(topic, partition, time, state)

View Source

Callback implementation for KafkaEx.Server.kafka_server_offset/4.

Link to this function

kafka_server_offset_commit(offset_commit_request, state)

View Source

Callback implementation for KafkaEx.Server.kafka_server_offset_commit/2.

Link to this function

kafka_server_offset_fetch(offset_fetch, state)

View Source

Callback implementation for KafkaEx.Server.kafka_server_offset_fetch/2.

Link to this function

kafka_server_produce(produce_request, state)

View Source

Callback implementation for KafkaEx.Server.kafka_server_produce/2.

Link to this function

kafka_server_produce_send_request(correlation_id, produce_request, produce_request_data, state)

View Source
Link to this function

kafka_server_sync_group(request, network_timeout, state_in)

View Source

Callback implementation for KafkaEx.Server.kafka_server_sync_group/3.

Link to this function

kafka_server_update_consumer_metadata(state)

View Source

Callback implementation for KafkaEx.Server.kafka_server_update_consumer_metadata/1.

Link to this function

kafka_server_update_metadata(state)

View Source

Callback implementation for KafkaEx.Server.kafka_server_update_metadata/1.

Link to this function

retrieve_metadata(brokers, correlation_id, sync_timeout, topic \\ [], server_api_versions \\ [:unsupported])

View Source
Link to this function

retrieve_metadata(brokers, correlation_id, sync_timeout, topic, retry, error_code, server_api_versions \\ [:unsupported])

View Source
Link to this function

retrieve_metadata_with_version(brokers, correlation_id, sync_timeout, topic, retry, error_code, server_api_versions)

View Source
Link to this function

start_link(args, name \\ __MODULE__)

View Source
Link to this function

terminate(reason, state)

View Source
Link to this function

update_consumer_metadata(state, num, error_code)

View Source

See KafkaEx.Server0P8P2.update_consumer_metadata/3.

Link to this function

update_metadata(state)

View Source