FundingCircle/jackdaw
A Clojure library for the Apache Kafka distributed streaming platform.
ClojureBSD-3-Clause
Issues
- 0
- 3
Sliding window-by-time?
#373 opened by sorumehta - 0
Seek to timestamp possibly off by one
#371 opened by djeis97 - 0
jackdaw.admin#retry-exists? error 'call to static method sleep on java.lang.Thread can't be resolved'
#369 opened by tailxcoder - 1
support foreign key joins
#364 opened by raymcdermott - 3
- 1
Versions 0.9.x are broken
#338 opened by ignorabilis - 0
Update versions to 7.x and 3.x
#352 opened by vincentjames501 - 0
Run consumer in thread throw error KafkaConsumer is not safe for multi-threaded access
#350 opened by khmelevskii - 0
Avro schemas with union types with int declared before float encode all floats to ints
#349 opened by kevinmershon - 0
confluent and kafka version mismatch
#336 opened by darin-reify - 0
- 2
upgrading to 2.5.0
#254 opened by zcaudate - 0
lots of reflection warnings
#322 opened by nivekuil - 2
Using Schema Registry with basic auth
#171 opened by lurodrigo - 0
- 2
0.9.0 release did not work
#306 opened by kidpollo - 1
- 1
- 3
Update Jackdaw to work with newer versions of kafka-streams / kafka-streams-test-utils
#290 opened by LouiseKlodt - 1
Transient integration test error.
#243 opened by noisesmith - 2
Update aleph
#281 opened by elzibubble - 0
Type checks in jackdaw.client namespace should check for the interface and not the concrete classes
#280 opened by dfbernal - 3
Can't install dependencies
#276 opened by khmelevskii - 0
- 1
Deserializer-properties are not propagated in delegating calls for serde creation
#269 opened by DarrenBishop - 2
- 0
Topology needs to be configured with string keys, which is different from other entities
#268 opened by madstap - 2
Add divert? functions
#238 opened by bn-darindouglass-zz - 1
Add divert? functions
#237 opened by bn-darindouglass-zz - 0
Omitting topic name from aggregation topic configs constructs Materialized incorrectly
#262 opened by dacreify - 0
bump clj-uuid version to get rid of shadowing warning for `#'unsigned-bit-shift-right`
#256 opened by j-po - 0
- 0
How to send and consume headers in Kstream?
#255 opened by zcaudate - 4
Removing nil values after deserializing avro
#251 opened by mt3593 - 1
Supporting version 5.5.0 of schema registry
#252 opened by mt3593 - 2
Support for multiple schema on a topic
#250 opened by mt3593 - 0
- 0
Add `.createPartitions` support
#234 opened by bn-darindouglass-zz - 2
Add jackdaw.streams/split?
#232 opened by AlexVPopov - 0
regression in pipe example commented code
#222 opened by noisesmith - 0
- 0
Unexpected semantics of seek-to-timestamp
#195 opened by jgracin - 2
- 0
Wrapper around .commitAsync/.commitSync
#196 opened by vincentjames501 - 0
Function topics-ready? seems broken
#192 opened by jgracin - 3
- 1
Windowed KStream missing some reduce
#170 opened by deoqc - 5
Exception while trying to use avro serdes: "No implementation of method: :clj->avro of protocol:"
#169 opened by lurodrigo - 0