Error/Throttle callback function additions closing #33 by cmccarthy1 · Pull Request #40 · KxSystems/kafka

cmccarthy1 · 2020-06-10T10:02:15Z

Addition of error and throttle callbacks in the creation of clients allowing these to be handled by q
This addition closes Expose .kfk.throttlecb and .kfk.errorcb to the interface #33

Example invocation would be to change .kfk.errcb function in the kfk.q file to

errcb:{[cid;err_int;reason]show (cid;err_int;reason);}

q).kfk.Consumer[`metadata.broker.list`group.id!`foobar`0]

q)0i
-193i
"foobar:9092/bootstrap: Failed to resolve 'foobar:9092': nodename nor servnam..
0i
-187i
"1/1 brokers are down"

cmccarthy1 added 5 commits December 8, 2019 14:04

Merge https://github.com/kxsystems/kafka

13034d4

Merge branch 'master' of https://github.com/cmccarthy1/kafka

b4e5b59

Merge branch 'master' of https://github.com/cmccarthy1/kafka

d2491ba

Merge https://github.com/kxsystems/kafka

5cde665

addition of callbacks for errors and throttle events, as outlined in K…

4db1749

…xSystems#33

cmccarthy1 requested a review from sshanks-kx June 10, 2020 10:02

sshanks-kx approved these changes Jun 10, 2020

View reviewed changes

cmccarthy1 merged commit 20c761c into KxSystems:master Jun 10, 2020

Provide feedback