Danie Roux
Danie Roux
I have this function, I am not sure where in kafka.clj it should fit: ```clojure (defn wait-until-window-closes [^KTable builder] (.suppress builder (Suppressed/untilWindowCloses (Suppressed$BufferConfig/unbounded))))
In order to support `TimeWindows.grace`, would the below option be the one? ````clojure (window grouped-stream [5 :seconds] {::interval.type :hopping ::grace [1 :minutes] ;; Would this be the preferred option? ::advance-by...
Warn users that the REPL integration doesn't work on the latest lein
Because of two hard-coded `always-align` calls in `clojure-indent-function` it is not as simple as `(setq clojure-indent-style 'always-indent)` to get the desired effect. As undesirable as that effect may be for...
I'm hacking it with: (defalias 'cider--find-var 'cider-find-var)
```clojure (t/concur #:tick{:beginning #time/instant"2000-01-01T01:00:01.011Z", :end #time/instant"2000-01-01T02:00:01.011Z"} #:tick{:beginning #time/instant"2000-01-01T00:00:00.003Z", :end #time/instant"2000-01-01T01:00:00.003Z"} #:tick{:beginning #time/instant"2000-01-01T01:00:01.179Z", :end #time/instant"2000-01-01T02:00:01.179Z"}) ``` Fails with: ```No implementation of method: :< of protocol: #'tick.core/ITimeComparison found for class: nil``` Because:...
A start to https://github.com/onyx-platform/onyx/issues/820
This implements #60 I made the configs first-class keys, and not using kafka/consumer-opts. Consumer-opts feels more like "whatever this plugin did not consider".
I would really like `org.apache.kafka.common.serialization.StringDeserializer` for `key.deserializer` and `key.serializer`. My data is small