kafka_ex
▼
Project version
v0.14.0
v0.14.0-rc.1
v0.13.0
v0.12.1
v0.11.0
v0.10.0
v0.9.0
v0.8.3
v0.8.2
v0.8.1
v0.8.0
v0.7.0
v0.6.5
v0.6.4
v0.6.3
v0.6.2
v0.6.1
v0.6.0
v0.5.0
v0.4.0
v0.3.0
v0.2.1
v0.2.0
v0.1.0
v0.0.2
v0.0.1
Pages
Modules
API Reference
Modules
KafkaEx
IMPORTANT - Kayrock and The Future of KafkaEx
Using KafkaEx in an Elixir project
Configuration
Timeouts with SSL
Usage Examples
Testing
Contributing
Default snappy algorithm use snappyer package
Kayrock-Based KafkaEx Client
Using the New Client
Common Use Case - Store Offsets In Kafka
Common Use Case - Message Timestamps / New Storage Format
KafkaEx 1.0 API
Status
Major Differences from the Legacy API
Design Philosophy
Contributing
KafkaEx
Summary
Types
ssl_options/0
uri/0
worker_init/0
worker_setting/0
Functions
api_versions/1
build_worker_options/1
consumer_group/1
consumer_group_metadata/2
create_topics/2
create_worker/2
delete_topics/2
describe_group/2
earliest_offset/3
fetch/3
heartbeat/2
join_group/2
latest_offset/3
leave_group/2
metadata/1
offset/4
offset_commit/2
offset_fetch/2
produce/2
produce/4
start/2
start_link_worker/2
stop_worker/1
stream/3
sync_group/2
valid_consumer_group?/1
KafkaEx.Compression
Summary
Types
attribute_t/0
compression_type_t/0
Functions
compress/2
decompress/2
snappy_decompress_chunk/2
KafkaEx.Config
KafkaEx.ConsumerGroup
Sections
Example
Summary
Types
option/0
options/0
Functions
active?/2
assignments/2
child_spec/1
consumer_pids/1
consumer_supervisor_pid/2
generation_id/2
get_manager_pid/1
group_name/2
leader?/2
leader_id/2
member_id/2
partition_consumer_map/1
start_link/4
KafkaEx.ConsumerGroup.PartitionAssignment
Summary
Types
callback/0
member_id/0
partition/0
partition_id/0
topic/0
Functions
round_robin/2
KafkaEx.DefaultPartitioner
Summary
Functions
assign_partition/2
KafkaEx.GenConsumer
Sections
Example
Committing Offsets
Handler state and interaction
Testing
Summary
Types
option/0
options/0
Callbacks
handle_call/3
handle_cast/2
handle_info/2
handle_message_set/2
init/2
init/3
Functions
call/3
cast/2
child_spec/1
init/1
partition/2
start_link/5
KafkaEx.GenConsumer.Supervisor
Summary
Functions
active?/1
child_pids/1
child_spec/1
start_link/1
start_link/4
KafkaEx.LegacyPartitioner
Summary
Functions
assign_partition/2
KafkaEx.NetworkClient
KafkaEx.NetworkClient.Behaviour
Summary
Types
host/0
host_port/0
kafka_ex_broker/0
kafka_ex_socket/0
request_data/0
response_data/0
use_ssl/0
Callbacks
close_socket/1
create_socket/2
create_socket/3
create_socket/4
format_host/1
send_async_request/2
send_sync_request/3
KafkaEx.New.Client
Summary
Types
args/0
Functions
child_spec/1
send_request/4
start_link/2
KafkaEx.New.Client.Protocol
Summary
Types
api_version/0
consumer_group/0
params/0
Callbacks
build_request/3
parse_response/2
KafkaEx.New.Client.RequestBuilder
Summary
Functions
describe_groups_request/2
KafkaEx.New.Client.ResponseParser
Summary
Functions
describe_groups_response/1
KafkaEx.New.KafkaExAPI
Summary
Types
client/0
consumer_group_name/0
correlation_id/0
error_atom/0
node_id/0
offset/0
partition_id/0
topic_name/0
Functions
cluster_metadata/1
correlation_id/1
describe_group/2
latest_offset/3
set_consumer_group_for_auto_commit/2
topics_metadata/3
KafkaEx.New.Protocols.Kayrock.DescribeGroups
Summary
Types
t/0
KafkaEx.New.Protocols.Kayrock.DescribeGroups.Request
Summary
Types
t/0
Functions
build_request/2
KafkaEx.New.Protocols.Kayrock.DescribeGroups.Response
Summary
Types
t/0
Functions
parse_response/1
KafkaEx.New.Protocols.KayrockProtocol
Summary
Functions
build_request/3
parse_response/2
KafkaEx.New.Structs.Broker
Summary
Types
t/0
Functions
has_socket?/2
KafkaEx.New.Structs.ClusterMetadata
Summary
Types
node_select_error/0
t/0
Functions
broker_by_node_id/2
brokers/1
from_metadata_v1_response/1
known_topics/1
put_consumer_group_coordinator/3
remove_topics/2
select_node/2
topics_metadata/2
KafkaEx.New.Structs.ConsumerGroup
Summary
Types
t/0
Functions
from_describe_group_response/1
KafkaEx.New.Structs.ConsumerGroup.Member
Summary
Types
partial_response/0
t/0
Functions
from_describe_group_response/1
KafkaEx.New.Structs.ConsumerGroup.Member.MemberAssignment
Summary
Types
response_partial/0
t/0
Functions
from_describe_group_response/1
KafkaEx.New.Structs.ConsumerGroup.Member.MemberAssignment.PartitionAssignment
Summary
Types
response_partial/0
t/0
Functions
from_describe_group_response/1
KafkaEx.New.Structs.NodeSelector
Summary
Types
t/0
valid_strategy/0
Functions
consumer_group/1
controller/0
first_available/0
node_id/1
random/0
topic_partition/2
KafkaEx.New.Structs.Partition
Summary
Types
t/0
KafkaEx.New.Structs.Topic
Summary
Types
t/0
KafkaEx.Partitioner
Summary
Callbacks
assign_partition/2
Functions
get_key/1
KafkaEx.Protocol.ApiVersions
Summary
Functions
create_request/3
parse_response/2
KafkaEx.Protocol.Common
Summary
Functions
encode_nullable_string/1
encode_string/1
map_encode/2
parse_topics/3
read_array/3
topic_data/1
KafkaEx.Protocol.ConsumerMetadata
Summary
Functions
create_request/3
parse_response/1
KafkaEx.Protocol.CreateTopics
Summary
Functions
api_version/1
create_request/4
parse_response/2
KafkaEx.Protocol.DeleteTopics
Summary
Functions
api_version/1
create_request/4
parse_response/2
KafkaEx.Protocol.Fetch
Summary
Functions
create_request/1
parse_partitions/4
parse_response/1
KafkaEx.Protocol.Heartbeat
Summary
Functions
create_request/3
parse_response/1
KafkaEx.Protocol.JoinGroup
Summary
Functions
create_request/3
parse_response/1
KafkaEx.Protocol.LeaveGroup
Summary
Functions
create_request/3
parse_response/1
KafkaEx.Protocol.Metadata
Summary
Functions
api_version/1
create_request/4
parse_response/1
parse_response/2
KafkaEx.Protocol.Offset
Summary
Functions
create_request/5
parse_response/1
parse_time/1
KafkaEx.Protocol.OffsetCommit
Summary
Functions
create_request/3
parse_response/1
KafkaEx.Protocol.OffsetFetch
Summary
Functions
create_request/3
parse_partitions/4
parse_response/1
KafkaEx.Protocol.Produce
Summary
Functions
create_request/3
parse_partitions/4
parse_response/1
KafkaEx.Protocol.Produce.Message
Summary
Types
t/0
KafkaEx.Protocol.Produce.Request
Summary
Types
t/0
KafkaEx.Protocol.SyncGroup
Summary
Functions
create_request/3
parse_response/1
KafkaEx.Server
Summary
Callbacks
kafka_server_api_versions/1
kafka_server_consumer_group/1
kafka_server_consumer_group_metadata/1
kafka_server_create_topics/3
kafka_server_delete_topics/3
kafka_server_fetch/2
kafka_server_heartbeat/3
kafka_server_init/1
kafka_server_join_group/3
kafka_server_leave_group/3
kafka_server_metadata/2
kafka_server_offset/4
kafka_server_offset_commit/2
kafka_server_offset_fetch/2
kafka_server_produce/2
kafka_server_sync_group/3
kafka_server_update_consumer_metadata/1
kafka_server_update_metadata/1
KafkaEx.Server0P10AndLater
Summary
Functions
broker_for_consumer_group_with_update/2
consumer_group?/1
handle_call/3
handle_info/2
init/1
kafka_server_api_versions/1
kafka_server_consumer_group/1
kafka_server_consumer_group_metadata/1
kafka_server_create_topics/3
kafka_server_delete_topics/3
kafka_server_fetch/2
kafka_server_heartbeat/3
kafka_server_init/1
kafka_server_join_group/3
kafka_server_leave_group/3
kafka_server_metadata/2
kafka_server_offset/4
kafka_server_offset_commit/2
kafka_server_offset_fetch/2
kafka_server_produce/2
kafka_server_produce_send_request/4
kafka_server_sync_group/3
kafka_server_update_consumer_metadata/1
kafka_server_update_metadata/1
retrieve_metadata/5
retrieve_metadata/7
retrieve_metadata_with_version/7
start_link/2
terminate/2
update_consumer_metadata/3
update_metadata/1
KafkaEx.Server0P8P0
Summary
Functions
handle_call/3
handle_info/2
init/1
kafka_server_api_versions/1
kafka_server_consumer_group/1
kafka_server_consumer_group_metadata/1
kafka_server_create_topics/3
kafka_server_delete_topics/3
kafka_server_fetch/2
kafka_server_heartbeat/3
kafka_server_init/1
kafka_server_join_group/3
kafka_server_leave_group/3
kafka_server_metadata/2
kafka_server_offset/4
kafka_server_offset_commit/2
kafka_server_offset_fetch/2
kafka_server_produce/2
kafka_server_produce_send_request/4
kafka_server_sync_group/3
kafka_server_update_consumer_metadata/1
kafka_server_update_metadata/1
retrieve_metadata/5
retrieve_metadata/7
retrieve_metadata_with_version/7
start_link/2
terminate/2
update_metadata/1
KafkaEx.Server0P8P2
Summary
Functions
consumer_group?/1
consumer_group_if_auto_commit?/2
handle_call/3
handle_info/2
init/1
kafka_server_api_versions/1
kafka_server_consumer_group/1
kafka_server_consumer_group_metadata/1
kafka_server_create_topics/3
kafka_server_delete_topics/3
kafka_server_fetch/2
kafka_server_heartbeat/3
kafka_server_init/1
kafka_server_join_group/3
kafka_server_leave_group/3
kafka_server_metadata/2
kafka_server_offset/4
kafka_server_offset_commit/2
kafka_server_offset_fetch/2
kafka_server_produce/2
kafka_server_produce_send_request/4
kafka_server_sync_group/3
kafka_server_update_consumer_metadata/1
kafka_server_update_metadata/1
retrieve_metadata/5
retrieve_metadata/7
retrieve_metadata_with_version/7
start_link/2
terminate/2
update_consumer_metadata/3
update_metadata/1
KafkaEx.Server0P9P0
Summary
Functions
broker_for_consumer_group_with_update/2
consumer_group?/1
handle_call/3
handle_info/2
init/1
kafka_server_api_versions/1
kafka_server_consumer_group/1
kafka_server_consumer_group_metadata/1
kafka_server_create_topics/3
kafka_server_delete_topics/3
kafka_server_fetch/2
kafka_server_heartbeat/3
kafka_server_init/1
kafka_server_join_group/3
kafka_server_leave_group/3
kafka_server_metadata/2
kafka_server_offset/4
kafka_server_offset_commit/2
kafka_server_offset_fetch/2
kafka_server_produce/2
kafka_server_produce_send_request/4
kafka_server_sync_group/3
kafka_server_update_consumer_metadata/1
kafka_server_update_metadata/1
retrieve_metadata/5
retrieve_metadata/7
retrieve_metadata_with_version/7
start_link/2
terminate/2
update_consumer_metadata/3
update_metadata/1
KafkaEx.Socket
Summary
Types
t/0
Functions
close/1
create/4
info/1
open?/1
recv/2
recv/3
send/2
setopts/2
KafkaEx.Utils.Murmur
Summary
Functions
murmur2/1
umurmur2/1
umurmur2_legacy/1
Exceptions
KafkaEx.ConsumerGroupRequiredError
KafkaEx.InvalidConsumerGroupError
KafkaEx.TimestampNotSupportedError
Search documentation of kafka_ex
Settings
View Source
KafkaEx.NetworkClient
(kafka_ex v0.14.0)
KafkaEx implementation of Client used to connect to Kafka Broker
×