Tags

Tags give the ability to mark specific points in history as being important

  • 0.5.0

    0833ebf2 · Generated docs · 
    0.5.0 Release

8894f6d Cleanup compiler warnings.
b700f8c Update tests wrt sync timeout setting
6f01dd4 Merge branch 'master' into disable_default_worker
06689ee Merge branch 'test_fixes' of git://github.com/dantswain/kafka_ex into dantswain-test_fixes
b3fee89 Merge branch 'handle_first_broker_down' of git://github.com/dantswain/kafka_ex into dantswain-handle_first_broker_down
87c629b Fix return values in examples
359e323 Add some missing typespecs, fix spec for produce
ed3210e Fix typespecs
b92ff59 Update dialyzer to 0.2
de17e28 Handle the case where the first broker is down
8643523 Merge pull request #82 from dantswain/fix_link
51ceda2 Fix link in mix.exs
93c4b37 Wait for stream offset commit
0b26c99 Ensure consume before asserting no offset commit
784ec56 Attempt to wait for metadata response
3a0431a Minor indentation fixes
eb51716 Fix potential race condition for start_streaming
1899c1e Add more async helpers, try to remove more sleeps
9a16318 Handle async issue in another streaming test case
620e865 Remove `require Logger`
868a620 Raise out when unable to fetch metadata at all
50aa538 Add logging for invalid metadata response
f0d1b23 Add async test helper, fix one test
3d78529 Merge branch 'master' into disable_default_worker
bb644ee Add test for disable_default_worker
ba56ef1 Merge branch 'dantswain-remove_consumer_group_defaults'
143ab1e Move defaulting latest_offset_number to 0 into TestHelper.
a586b46 Allow disabling the default worker, update README
330ce14 Fix OffsetFetch consumer group usage
9fc1d4a Fix OffsetCommit consumer group usage
5aa5c6d Fix edge case on consumer group test
df97bf0 Remove "kafka_ex" default from fn call
ec9cee8 Replace magic number(3) for retries with @retry_count module attribute.
8412e99 Remove hack to support `consumer_group: false`
280cf0f Merge branch 'master' into fix_overriding_consumer_group
5637182 Remove stray debug and change `consumer_group: false` to `consumer_group: :no_consumer_group`
aa0b22a Merge branch 'dantswain-no_default_partition'
7543ab9 Merge branch 'no_default_partition' of git://github.com/dantswain/kafka_ex into dantswain-no_default_partition
62abd1b Merge branch 'dantswain-fix_parameter_merging'
6bc0277 Merge branch 'fix_parameter_merging' of git://github.com/dantswain/kafka_ex into dantswain-fix_parameter_merging
a97a20a Merge branch 'dantswain-enable_topic_deletes'
80cdf17 KafkaEx workers overrides the consumer_group to "kafka_ex" everytime KafkaEx.offset_fetch and KafkaEx.offset_commit is called, this ensures that the consumer_group is consistent and not overriden.
0ddc0fe Allow topic deletes in server.properties
4aa5f5d Add back missing test
d6a9614 Remove defaults for topic and partition
ec88d6e Add assertions on consumer group where required
67d07b5 Fix server logic wrt auto commit and consumer groups
50d894a Refactor option parsing, add :no_consumer_group
75595b2 Merge branch 'master' into fix_parameter_merging
7eaec64 Merge branch 'dantswain-server_state'
b65deba Merge branch 'server_state' of git://github.com/dantswain/kafka_ex into dantswain-server_state
4e2665a Remove KafkaEx.Protocol.Fetch.Request
7821f1c Introduce Server.State module
03447f7 Update worker_init type
6d20a3e Remove default consumer group name from server.ex
13a271c Fix defaults merging in create_worker
a465354 Merge pull request #70 from dantswain/fix_contributing
29c938f Fix CONTRIBUTING.md

  • 0.4.0

    58ad6f74 · Generate docs. · 
    0.4.0 Release

58ad6f7 Generate docs.
372c261 Bump version to 0.4.0.
44149bf Merge branch 'barruumrex-config_timeout'
eb7c8d2 Merge branch 'config_timeout' of git://github.com/barruumrex/kafka_ex into barruumrex-config_timeout
1840621 Bump version of kafka for test.
eb1b3c7 Added sync_timeout config
23013c3 Remove reference to creating worker via a Supervisor in the README.
13cdce4 Merge branch 'localshred-master'
709066c Fix heading in readme
b75b0c4 Allow creating unnamed server workers
90058fb Fix `format_host` to correctly handle string hostname that has an ip address in its hostname.
1317dbd Merge branch 'ibizaman-enhance_connection_doc'
cc33ae5 Merge branch 'enhance_connection_doc' of git://github.com/ibizaman/kafka_ex into ibizaman-enhance_connection_doc
4d46e78 Merge branch 'peburrows-snappy-hex'
1aadea1 fix locked SHA for snappy
91a9e1b The snappy version in the main github repo now supports Erlang 18
8aa3f50 document overriding options when creating worker
feb3da3 Change contributors to maintainers to make hex happy.

  • 0.3.0

    c2892200 · Generate docs for 0.3.0 · 
    Features in 0.3.0

 - Gzip compression introduce (this completes implementation of compression);
 -  Correctly display error messages, when consumer_group metadata update fails;
 - `KafkaEx.create_stream` will fail more cleanly (log error) when it is called for a worker that is already streaming;
 - Optional init argument for stream handler;
 - Make workers start streaming from `last_offset + 1` instead of `last_committed_offset`;
 - Bug Fixes

  • 0.2.1

    bbba9918 · Generate docs for 0.2.1. · 
    0.2.1

  • 0.2.0

    560dd5fa · Clear unused variable warning. · 
    Make the API compatible with pre 0.8.2 kafka (kafka without direct support for consumer_group
Add Snappy Compression
Add CI(Travis)
Bug Fixes

  • 0.1.0

    4537dedb · Regenerated docs · 
    0.1.0

  • 0.0.2

    1d720e9a · Generated docs · 
    0.0.2

  • 0.0.1

    7b9a449f · Add docs! · 
    0.0.1