pyr/kinsky issues and pull requests

#63 - Bump kafka dependency to 2.7.x

Pull Request - State: closed - Opened by wdullaer over 2 years ago

#62 - Fixes reflection issues

Pull Request - State: closed - Opened by jeremyvdw almost 3 years ago

#61 - Documentation link updates, linting.

Pull Request - State: closed - Opened by jeremyvdw almost 3 years ago - 1 comment

#60 - Fix typo in json-serializer docstring

Pull Request - State: closed - Opened by rborer over 3 years ago - 1 comment

#59 - client: typo in listener docstring

Pull Request - State: closed - Opened by brutasse about 4 years ago

#58 - client: add value-xform

Pull Request - State: closed - Opened by pyr about 4 years ago - 1 comment

#57 - Improvements to support separate async facade

Pull Request - State: open - Opened by fmjrey almost 5 years ago - 1 comment

#56 - Why do partition and timestamp default to 0 and 11 in producer record?

Issue - State: closed - Opened by fmjrey almost 5 years ago - 2 comments

#55 - Use SVG CI status badge

Pull Request - State: closed - Opened by v-kolesnikov about 5 years ago - 1 comment

#54 - Feature/improve consumer

Pull Request - State: closed - Opened by mpenet about 5 years ago

#53 - Added support for Kafka message headers which were added in v0.11.0.0.

Pull Request - State: closed - Opened by fhitchen about 5 years ago - 1 comment

#52 - Improve consumer res

Pull Request - State: closed - Opened by mpenet over 5 years ago - 1 comment

#51 - Add embedded kafka impl for testing

Pull Request - State: closed - Opened by mpenet over 5 years ago

#50 - Bump kafka-clients

Issue - State: closed - Opened by vemv over 5 years ago - 1 comment

#49 - Support Kafka Headers

Issue - State: closed - Opened by Dangercoder over 5 years ago - 4 comments

#48 - Zombie consumer

Issue - State: closed - Opened by valerauko over 5 years ago - 2 comments

#47 - Feature/lac deserializer for JSON events

Pull Request - State: closed - Opened by fhitchen over 5 years ago - 2 comments

#46 - Seek operation in async client

Issue - State: closed - Opened by The-Q over 5 years ago - 2 comments

#45 - Are deserialization exception handlers supported

Issue - State: closed - Opened by fhitchen over 5 years ago - 1 comment

#44 - Update docs

Pull Request - State: closed - Opened by djtango over 5 years ago - 1 comment

#43 - Subscribing by regex pattern fails with an exception

Issue - State: closed - Opened by igrishaev almost 6 years ago - 4 comments

#42 - Producer errors when using async facade

Issue - State: closed - Opened by MafcoCinco almost 6 years ago - 6 comments

#41 - Add support for producer's transactional functions

Pull Request - State: closed - Opened by iku000888 almost 6 years ago - 2 comments

#40 - Support `.offsetsForTimes` of the consumer API

Issue - State: open - Opened by raycheung almost 6 years ago

#39 - Fix async consumer ConcurrentModificationException

Pull Request - State: closed - Opened by fmjrey about 6 years ago - 2 comments

#38 - Async consumer & manual offset control

Issue - State: closed - Opened by vielmath about 6 years ago - 5 comments

#37 - sasl_plaintext auth failed

Issue - State: closed - Opened by robertzhouxh over 6 years ago

#36 - Examples does not work

Issue - State: closed - Opened by kronos over 6 years ago - 4 comments

#35 - extract timestamp from each record

Pull Request - State: closed - Opened by vielmath over 6 years ago - 1 comment

#34 - Use the clojure.core.async by the namespace a

Pull Request - State: closed - Opened by codingkarthik over 6 years ago - 1 comment

#33 - Fix comment about :duplex? consumer config

Pull Request - State: closed - Opened by raycheung over 6 years ago - 1 comment

#32 - Support producer transaction api

Issue - State: closed - Opened by eoliphan over 6 years ago - 1 comment

#31 - Allow reader options for edn-deserializer

Pull Request - State: closed - Opened by esorey over 6 years ago

#30 - Initial ideas for an `AdminClient` wrapper

Pull Request - State: closed - Opened by truemped over 6 years ago - 2 comments

#29 - Kafka AdminClient Wrapper?

Issue - State: closed - Opened by truemped over 6 years ago - 2 comments

#28 - async: ensure we wake up before perfoming admin tasks

Pull Request - State: closed - Opened by pyr almost 7 years ago - 1 comment

#27 - Duplex chan

Pull Request - State: closed - Opened by pyr almost 7 years ago

#26 - use duplex channel to gather in & out channel

Pull Request - State: closed - Opened by pyr almost 7 years ago - 1 comment

#25 - fix reflection warnings

Pull Request - State: closed - Opened by vise890-ovo about 7 years ago - 2 comments

#24 - Extend consumer protocol + allow to set a topic when bootstrapping as…

Pull Request - State: closed - Opened by luhhujbb about 7 years ago - 1 comment

#23 - How to get an error if Kafka is down?

Issue - State: closed - Opened by krisleech over 7 years ago - 1 comment

#22 - use duplex channel to gather in & out channel

Pull Request - State: closed - Opened by gfZeng over 7 years ago - 1 comment

#21 - kafka-consumer-loop thread should be a daemon thread.

Pull Request - State: closed - Opened by carlduevel over 7 years ago - 1 comment

#20 - Missing `async` in readme

Pull Request - State: closed - Opened by truemped over 7 years ago - 1 comment

#19 - The async consumer facade looks broken post 0.10.1.0

Issue - State: closed - Opened by sundbp over 7 years ago - 2 comments

#18 - Add missing license file

Pull Request - State: closed - Opened by agarman over 7 years ago - 1 comment

#17 - Verify against Kafka test client?

Issue - State: closed - Opened by danielcompton over 7 years ago - 1 comment
Labels: enhancement

#16 - Fix apache kafka link typo in readme

Pull Request - State: closed - Opened by pkova over 7 years ago - 1 comment

#15 - Fix issue #10, single arity 'stop!' not implemented.

Pull Request - State: closed - Opened by henriklundahl almost 8 years ago - 2 comments

#14 - Fix issue #12, support collection of keyword topics.

Pull Request - State: closed - Opened by henriklundahl almost 8 years ago - 2 comments

#13 - Fix #11, bug in 'flush!'.

Pull Request - State: closed - Opened by henriklundahl almost 8 years ago - 1 comment

#12 - Support collection of keyword topics

Issue - State: closed - Opened by henriklundahl almost 8 years ago - 1 comment

#11 - Bug in flush! in producer->driver

Issue - State: closed - Opened by henriklundahl almost 8 years ago

#10 - Single arity variant of stop! in ConsumerDriver not implemented

Issue - State: closed - Opened by henriklundahl almost 8 years ago - 1 comment

#9 - Pause and resume don't work with kafka-clients 0.10.x

Issue - State: closed - Opened by jmglov about 8 years ago - 2 comments

#8 - Fix for pause and resume in 0.10.x KafkaConsumer

Pull Request - State: closed - Opened by jmglov about 8 years ago - 2 comments

#7 - Dont use put! to consume payload - fixes #5

Pull Request - State: closed - Opened by scott-abernethy about 8 years ago - 3 comments
Labels: bug

#6 - Async consumer commit operation is susceptible to WakeupException

Issue - State: closed - Opened by scott-abernethy about 8 years ago - 8 comments
Labels: bug

#5 - Slow consumer with large backlog of records causes "No more than 1024 pending puts"

Issue - State: closed - Opened by scott-abernethy about 8 years ago - 2 comments
Labels: bug

#4 - producer: match new consumer approach

Pull Request - State: closed - Opened by pyr over 8 years ago

#3 - async: more featured async consumer

Pull Request - State: closed - Opened by pyr over 8 years ago

#2 - Fix typos

Pull Request - State: closed - Opened by malesch over 8 years ago - 1 comment

#1 - Fix typo in documenation

Pull Request - State: closed - Opened by jstokes almost 9 years ago - 1 comment

GitHub / pyr/kinsky issues and pull requests