Kfk.sub

[chunaiarun]

Whether consumer can subscribe at topic level without specifying the partition? If so can you provide me an example

if partition should be always specified always , how should I specify

I was trying to specific subscriptions with callback function
.kfk.Subcribe[client;topic1;iderrleaderreplicasisrs!(0i;`Success;0i;0 1 2i;2 1 0i);callbck] here partition is dictionary. It is not working. Whether as my python code is working at topic level.

help needed

[sshanks-kx]

See
https://github.com/KxSystems/kafka/blob/master/examples/test_consumer.q
Thanks

[chunaiarun]

Thank you. When I use enlist .kfx.PARTITION_UA
I get return value as UNKNOWN topic or PARTITION

[chunaiarun]

If partition is 0 1 and 2 , how to specific it in .kfx.subscribe function

[sshanks-kx]

You use assign instead of subscribe if you dont want automatic assignment ,https://github.com/KxSystems/kafka/blob/master/docs/reference.md#assign
Please also ensure using latest release.

[sshanks-kx]

FYI: Ive noticed #105 which may (or may not) be related to what you saw originally.

[chunaiarun]

Working fine