Derek Troy-West

AdminClient/listConsumerGroups TimeoutException when Broker Configuration Set

6

Redpanda Version: v21.7.4 (current latest) Background: encountered when running [kPow](https://kpow.io) with a Redpanda cluster with modified broker configuration. --- **Report:** AdminClient/listConsumerGroup throws a TimeoutException ``` Error listing groups on localhost:9092...

fix bug with transfer-encoding: chunked

2

Doc for yada.interceptors/process-request-body says: "Therefore we process the request body if the request contains a Content-Length or Transfer-Encoding header, regardless of the method semantics." Current implementation does not process the...

Using gloss.io/contiguous with a single non-zero position ByteBuffer loses data.

1

When using gloss.io/contiguous as a convenience for rolling a sequence of ByteBuffer into a single buffer I've found that: - if my sequence contains only a single ByteBuffer - that...

Hi Zach, Currently compile-frame supports pre-encoder and post-decoder methods to manipulate the data-structure before/after use with a codec. I'm currently using a third scenario - a pre-decoder method which manipulates...

Hi Zach, I'm using Gloss to decode different types of repeated headers, often following the Internet Message (RFC-5322) style. Given the simple case of a repeated header in the style...

Most (all?) of the DSL macros follow a similar pattern: (defn clojure-filter* (defmacro clojure-filter (defmacro filter [& body] (defmacro deffilter where (deffilter opts {:prepare true} is a shortcut which to...

DSL, Serialization, and AOT

4

I'm using Storm 0.9.2-incubating and Kafka 0.8.1.1. I prefer not to AOT my topology if possible, but I have found that if: 1. The tp uses an IPartitionedTridentSpout (i.e. TransactionalTridentKafkaSpout);...

Resolve #2, Clojurescript support.

3

* bump the Clojure version to greater than 1.7.0 (for cljc) * add reader conditional to switch on clj / cljs * bump .gitignore for intellij collaboration

We can start a simple schedule anytime (e.g. every 60s) but we don't currently support starting a simple schedule with a delay. We do support starting at a specific point...

E.g. 1. Delete a job 2. Pause a job 3. All the other actions Java allows on the mutable schedule object..