pingles clj-kafka issues

pingles / clj-kafka

Wrapper to the Java API for interacting with Kafka

Eclipse Public License 1.0

211 stars 77 forks source link

issues

Newest

Newest Most commented Recently updated Oldest Least commented Least recently updated

how to handle zk disconnect

#88 clojurians-org opened 7 years ago
0
Upgrade for newer Kafka Versions

#87 raunakb94 opened 8 years ago
1
Admin: implement add-partitions and topic-metadata

#86 csakoda closed 5 years ago
1
Kafka-0.9 branch into Master

#85 Poogles closed 8 years ago
1
[doc] Request for a CHANGELOG

#84 vedang opened 8 years ago
0
Fix reflection warnings

#83 divs1210 closed 8 years ago
3
Does this breaks with clojure 1.8?

#82 chhatanidinesh closed 8 years ago
4
[docs]: fixing a link to offset sources

#81 tolitius opened 8 years ago
0
[readme]: adding zk require for brokers

#80 tolitius opened 8 years ago
0
Any reason for an old Clojure dep?

#79 tolitius opened 8 years ago
0
Initial addition of new Kafka consumer

#78 DayoOliyide opened 8 years ago
0
New major version based on new Kafka Java clients

#77 ragnard opened 8 years ago
0
new producer send callback not invoked

#76 manuzhang closed 8 years ago
2
fetch-consumer-offsets returning error

#75 rakeshp opened 8 years ago
3
I cannot get messages using clj-kafka.consumer.zk

#74 ogis-hashi closed 8 years ago
2
Include :broker-id in each broker map returned by clj-kafka.zk/brokers

#73 DerGuteMoritz opened 8 years ago
1
Update to Kafka 0.9

#72 pingles opened 8 years ago
11
Include next-offset in KafkaMessage

#71 DerGuteMoritz closed 8 years ago
2
Allow to specify minimum bytes and maximum wait for simple consumer API

#70 vincentbernat closed 8 years ago
2
Add more options to `messages` method for simple consumer

#69 vincentbernat opened 8 years ago
4
Implement new KafkaConsumer

#68 vincentbernat opened 8 years ago
0
Convert Kafka byte-array to String\json

#67 panda87 closed 8 years ago
3
Make broker id available in brokers function

#66 benedekfazekas opened 8 years ago
0
Offset management

#65 cddr opened 8 years ago
6
Added feature to access Kafka's built-in consumer offset management

#64 ooasis closed 8 years ago
7
Readme port numbers.

#63 noisesmith opened 9 years ago
0
Make test helpers available

#62 jeffh opened 9 years ago
1
Expose with-test-broker?

#61 cddr closed 9 years ago
1
release 0.3.2

#60 devn closed 9 years ago
1
Fix typo for :offset key returned by new.producer/send

#59 ottbot closed 9 years ago
0
fix new producer example

#58 benedekfazekas closed 9 years ago
1
clj-kafka.new.producer/producer code error

#57 pho-coder closed 9 years ago
1
README.md New Producer example error

#56 pho-coder closed 9 years ago
0
Add a function to close the producer

#55 msprunck opened 9 years ago
2
Fix function name in example

#54 devn closed 9 years ago
1
Typo fix

#53 devn closed 9 years ago
1
data.json vs cheshire

#52 devn closed 4 years ago
1
Interface to new producer API.

#51 ragnard closed 9 years ago
0
Dependency cleanup

#50 ragnard closed 9 years ago
0
Add support for administration operations.

#49 ragnard closed 9 years ago
0
expose all configured kafka streams

#48 sgerguri closed 9 years ago
2
expose all configured kafka streams

#47 sgerguri closed 9 years ago
2
Confusing dependency on org.apache.zookeeper/zookeeper

#46 cch1 closed 9 years ago
1
Use the new java producer api

#45 wotbrew closed 9 years ago
3
Allow supplying key and value decoders when creating message streams

#44 ragnard closed 9 years ago
0
Update URL references to kafka incubator to use the 'real' kafka.

#43 kelveden closed 9 years ago
0
Adds message-streams to high level consumer

#42 sheelc closed 9 years ago
4
Method in high level consumer to get all message streams

#41 sheelc closed 9 years ago
8
Extend ToClojure protocol to nil

#40 DayoOliyide closed 9 years ago
0
Use iterator-seq over a custom lazy iterator

#39 AeroNotix closed 9 years ago
1