pingles/clj-kafka issues and pull requests

#88 - how to handle zk disconnect

Issue - State: open - Opened by clojurians-org over 7 years ago

#87 - Upgrade for newer Kafka Versions

Issue - State: open - Opened by raunakb94 over 8 years ago - 1 comment

#86 - Admin: implement add-partitions and topic-metadata

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

#85 - Kafka-0.9 branch into Master

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

#84 - [doc] Request for a CHANGELOG

Issue - State: open - Opened by vedang over 8 years ago

#83 - Fix reflection warnings

Pull Request - State: closed - Opened by divs1210 over 8 years ago - 3 comments

#82 - Does this breaks with clojure 1.8?

Issue - State: closed - Opened by chhatanidinesh over 8 years ago - 4 comments

#81 - [docs]: fixing a link to offset sources

Pull Request - State: open - Opened by tolitius over 8 years ago

#80 - [readme]: adding zk require for brokers

Pull Request - State: open - Opened by tolitius over 8 years ago

#79 - Any reason for an old Clojure dep?

Issue - State: open - Opened by tolitius over 8 years ago

#78 - Initial addition of new Kafka consumer

Pull Request - State: open - Opened by DayoOliyide over 8 years ago

#77 - New major version based on new Kafka Java clients

Pull Request - State: open - Opened by ragnard almost 9 years ago

#76 - new producer send callback not invoked

Issue - State: closed - Opened by manuzhang almost 9 years ago - 2 comments

#75 - fetch-consumer-offsets returning error

Issue - State: open - Opened by rakeshp almost 9 years ago - 3 comments

#74 - I cannot get messages using clj-kafka.consumer.zk

Issue - State: closed - Opened by ogis-hashi almost 9 years ago - 2 comments

#73 - Include :broker-id in each broker map returned by clj-kafka.zk/brokers

Pull Request - State: open - Opened by DerGuteMoritz almost 9 years ago - 1 comment

#72 - Update to Kafka 0.9

Issue - State: open - Opened by pingles almost 9 years ago - 11 comments

#71 - Include next-offset in KafkaMessage

Pull Request - State: closed - Opened by DerGuteMoritz almost 9 years ago - 2 comments

#70 - Allow to specify minimum bytes and maximum wait for simple consumer API

Pull Request - State: closed - Opened by vincentbernat about 9 years ago - 2 comments

#69 - Add more options to `messages` method for simple consumer

Issue - State: open - Opened by vincentbernat about 9 years ago - 4 comments

#68 - Implement new KafkaConsumer

Issue - State: open - Opened by vincentbernat about 9 years ago

#67 - Convert Kafka byte-array to String\json

Issue - State: closed - Opened by panda87 about 9 years ago - 3 comments

#66 - Make broker id available in brokers function

Pull Request - State: open - Opened by benedekfazekas about 9 years ago

#65 - Offset management

Issue - State: open - Opened by cddr about 9 years ago - 6 comments

#64 - Added feature to access Kafka's built-in consumer offset management

Pull Request - State: closed - Opened by ooasis about 9 years ago - 7 comments

#63 - Readme port numbers.

Issue - State: open - Opened by noisesmith over 9 years ago

#62 - Make test helpers available

Issue - State: open - Opened by jeffh over 9 years ago - 1 comment

#61 - Expose with-test-broker?

Issue - State: closed - Opened by cddr over 9 years ago - 1 comment

#60 - release 0.3.2

Issue - State: closed - Opened by devn over 9 years ago - 1 comment

#59 - Fix typo for :offset key returned by new.producer/send

Pull Request - State: closed - Opened by ottbot over 9 years ago

#58 - fix new producer example

Pull Request - State: closed - Opened by benedekfazekas over 9 years ago - 1 comment

#57 - clj-kafka.new.producer/producer code error

Issue - State: closed - Opened by pho-coder over 9 years ago - 1 comment

#56 - README.md New Producer example error

Issue - State: closed - Opened by pho-coder over 9 years ago

#55 - Add a function to close the producer

Pull Request - State: open - Opened by msprunck over 9 years ago - 2 comments

#54 - Fix function name in example

Pull Request - State: closed - Opened by devn over 9 years ago - 1 comment

#53 - Typo fix

Pull Request - State: closed - Opened by devn over 9 years ago - 1 comment

#52 - data.json vs cheshire

Issue - State: closed - Opened by devn over 9 years ago - 1 comment

#51 - Interface to new producer API.

Pull Request - State: closed - Opened by ragnard over 9 years ago

#50 - Dependency cleanup

Pull Request - State: closed - Opened by ragnard over 9 years ago

#49 - Add support for administration operations.

Pull Request - State: closed - Opened by ragnard over 9 years ago

#48 - expose all configured kafka streams

Pull Request - State: closed - Opened by sgerguri over 9 years ago - 2 comments

#47 - expose all configured kafka streams

Pull Request - State: closed - Opened by sgerguri over 9 years ago - 2 comments

#46 - Confusing dependency on org.apache.zookeeper/zookeeper

Issue - State: closed - Opened by cch1 over 9 years ago - 1 comment

#45 - Use the new java producer api

Issue - State: closed - Opened by wotbrew over 9 years ago - 3 comments

#44 - Allow supplying key and value decoders when creating message streams

Pull Request - State: closed - Opened by ragnard over 9 years ago

#43 - Update URL references to kafka incubator to use the 'real' kafka.

Pull Request - State: closed - Opened by kelveden over 9 years ago

#42 - Adds message-streams to high level consumer

Pull Request - State: closed - Opened by sheelc almost 10 years ago - 4 comments

#41 - Method in high level consumer to get all message streams

Issue - State: closed - Opened by sheelc almost 10 years ago - 8 comments

#40 - Extend ToClojure protocol to nil

Pull Request - State: closed - Opened by DayoOliyide almost 10 years ago

#39 - Use iterator-seq over a custom lazy iterator

Pull Request - State: closed - Opened by AeroNotix almost 10 years ago - 1 comment

#38 - Changes to high level consumer

Pull Request - State: closed - Opened by shmish111 almost 10 years ago - 14 comments

#37 - Upgraded kafka to 0.8.1.1 and zkclient to 0.4

Pull Request - State: closed - Opened by fatlazycat almost 10 years ago - 2 comments

#36 - Add EPL License file.

Pull Request - State: closed - Opened by sw1nn about 10 years ago

#35 - CompilerException java.lang.NoClassDefFoundError

Issue - State: closed - Opened by hwasungmars about 10 years ago - 1 comment

#34 - Kafka stream iterator

Pull Request - State: closed - Opened by ersantana about 10 years ago - 2 comments

#33 - utilities namespace

Pull Request - State: closed - Opened by konr over 10 years ago - 2 comments

#32 - Creating topics

Pull Request - State: closed - Opened by konr over 10 years ago

#31 - adding `create-topic` to an `utils` namespace

Pull Request - State: closed - Opened by konr over 10 years ago - 2 comments

#30 - added messages-filtered function

Pull Request - State: closed - Opened by agarman over 10 years ago

#29 - topic function

Pull Request - State: closed - Opened by agarman over 10 years ago - 3 comments

#28 - Updating README.md

Pull Request - State: closed - Opened by l1x over 10 years ago

#27 - Add possibility to use embedded Kafka broker / producer / simple consumer

Issue - State: closed - Opened by vbauer over 10 years ago - 2 comments

#26 - add oldest-topic-offset to simple consumer

Pull Request - State: open - Opened by aeneaswiener over 10 years ago

#25 - Do not use iterator-seq with KafkaStream

Pull Request - State: closed - Opened by prepor over 10 years ago - 6 comments

#24 - migrate to Kafka version 0.8.1. Fix changes in api. Tests pass

Pull Request - State: closed - Opened by christianblunden over 10 years ago - 1 comment

#23 - 0.8.1 migration

Issue - State: closed - Opened by prepor over 10 years ago - 8 comments

#22 - Unqueued zk consumer

Pull Request - State: closed - Opened by rsslldnphy over 10 years ago

#21 - Fix producer example and lein version string

Pull Request - State: closed - Opened by jpfuentes2 almost 11 years ago - 2 comments

#20 - Kafka 0.8.0 has been released (no more beta)

Issue - State: closed - Opened by aew almost 11 years ago - 2 comments

#19 - Runtime Dependencies

Issue - State: closed - Opened by kaiserprogrammer about 11 years ago - 2 comments

#18 - Multi-Message Sending Not Supported

Issue - State: closed - Opened by drbobbeaty about 11 years ago - 8 comments

#17 - fixed typo

Pull Request - State: closed - Opened by rwat over 11 years ago - 1 comment

#16 - Set :topic for KafkaMessage with SimpleConsumer

Issue - State: open - Opened by pingles over 11 years ago
Labels: 0.8

#15 - Reduce logging level

Issue - State: closed - Opened by pingles over 11 years ago - 1 comment
Labels: 0.8

#14 - Refactor tests

Issue - State: closed - Opened by pingles over 11 years ago - 1 comment
Labels: 0.8

#13 - Ensure 0.8 compliance

Issue - State: open - Opened by pingles over 11 years ago
Labels: 0.8

#12 - Update README and examples

Issue - State: closed - Opened by pingles over 11 years ago
Labels: 0.8

#11 - Zookeeper Consumer can't map to KafkaMessage records

Issue - State: closed - Opened by pingles over 11 years ago
Labels: 0.8

#10 - Officially published 0.8 Kafka Jar

Issue - State: open - Opened by pingles over 11 years ago
Labels: 0.8

#9 - Upgrading to Kafka 0.8?

Issue - State: closed - Opened by bluemont over 11 years ago - 6 comments

#8 - Increase a little the speed avoid java reflections

Pull Request - State: closed - Opened by DAddYE over 11 years ago - 3 comments

#7 - Prevent Out of Memory with large streams

Pull Request - State: closed - Opened by DAddYE over 11 years ago - 1 comment

#6 - Add type annotations to producer

Pull Request - State: closed - Opened by dinedal over 11 years ago - 3 comments

GitHub / pingles/clj-kafka issues and pull requests