Skip to content

v1.6.0
Compare
Choose a tag to compare
@sshanks-kx sshanks-kx released this 06 Jul 13:25
· 16 commits to master since this release
v1.6.0
7fd7c4a
This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
GPG key ID: 4AEE18F83AFDEB23
Expired
Learn about vigilant mode.

Additions:

  • '.kfk.Sub' & '.kfk.Subscribe' can now be given a list of symbols/topics to subscribe to in place of the single symbol. The function can also be used as before, where a single topic/symbol can be provided. 'partition' param no longer tries to set partitions/offsets (ignored by kafka). Examples changed to show subscriptions to multiple symbols. e.g.
    q) .kfk.Sub[client;(topic1;topic2);enlist .kfk.PARTITION_UA]
  • '.kfk.Assign' can now be used to subscribe to multiple symbol partitions and their offsets. Can be used as before (Symbol!Long dictionary mapping the name of a topic to an associated partition), but now can also be given a Symbol!Dictionary mapping of topic to partitions/offset (dictionary mapping of integer partition to long offset location) e.g. subscribe to test1 (partition 0 from offset 10) and test2 (partition 0 from offset 10)
    q).kfk.Assign[client;`test1`test2!(((1#0i)!1#10);((1#0i)!1#10))]

Fixes:

  • 'test_offsetc.q' example should not be using both '.kfk.AssignOffsets' & '.kfk.Sub' calls. '.kfk.AssignOffsets' removed. A client should not be using both manual and dynamically assigned partitions.
Assets 2
Loading