Anyone have an idea as to why adding these dependencies:

[com.fzakaria/slf4j-timbre "0.3.7"]
[org.slf4j/slf4j-api "1.7.14"]

17-11-16 01:30:48 kenny-ubuntu INFO [org.apache.zookeeper.server.PrepRequestProcessor:648] - Got user-level KeeperException when processing sessionid:0x15fc272ddec0001 type:create cxid:0x122 zxid:0x8f txntype:-1 reqpath:n/a Error Path:/onyx/1/checkpoint/f96426ca-8e43-9268-e699-08d2d8893f92/11-9 Error:KeeperErrorCode = NoNode for /onyx/1/checkpoint/f96426ca-8e43-9268-e699-08d2d8893f92/11-9

... the project has these Onyx deps:

[org.onyxplatform/onyx "0.11.1" :exclusions [org.slf4j/slf4j-nop]]
[org.onyxplatform/lib-onyx "0.11.1.0"]

@kenny It flipped on ZooKeeper's logging to INFO. ZK and Kafka have insanely chatty logs.

Hi, can I put byte arrays in segments? If yes, are there size restrictions?

Is there any reason why the core.async plugin uses random-uuid for :core.async/id rather than just taking the task name? Or to put it another way, if I hacked it ti use the task-name, would it break something?

@akiel If Nippy can compress it, yes, but I really wouldn't recommend it.

@dave.dixon Sorry, where is that?

@akiel Seems possible: https://github.com/ptaoussanis/nippy#deserializing

@michaeldrogalis https://github.com/onyx-platform/onyx/blob/7903b6dd459c4b0a45b97ca1705fed06ebd07e4d/src/onyx/tasks/core_async.clj#L22

Oh, this is 0.9

I set it up this way a long time ago to avoid conflicts across tasks and channels - you can use the task name. I guess that never occurred to me

There's really no magic going on here other than using the UUID to look itself up in the map and give itself isolation from other channels

@michaeldrogalis thanks, I’ll try it

@michaeldrogalis Great, thanks, makes it easy to remove duplicate entries.

@dave.dixon Cool - yes I see no problems with doing that. 🙂

@nha that function indicates that no retry is necessary by returning nil 🙂