pingles/clj-kafka

Issues

• data.json vs cheshire

  #52 opened 4 years ago by devn
  1

• fetch-consumer-offsets returning error

  #75 opened 9 years ago by rakeshp
  3

• how to handle zk disconnect

  #88 opened 7 years ago by clojurians-org
  0

• Upgrade for newer Kafka Versions

  #87 opened 8 years ago by raunakb94
  1

• [doc] Request for a CHANGELOG

  #84 opened 9 years ago by vedang
  0

• Update to Kafka 0.9

  #72 opened 9 years ago by pingles
  11

• Does this breaks with clojure 1.8?

  #82 opened 9 years ago by chhatanidinesh
  4

• Any reason for an old Clojure dep?

  #79 opened 9 years ago by tolitius
  0

• I cannot get messages using clj-kafka.consumer.zk

  #74 opened 9 years ago by ogis-hashi
  2

• new producer send callback not invoked

  #76 opened 9 years ago by manuzhang
  2

• Make test helpers available

  #62 opened 9 years ago by jeffh
  1

• Add more options to `messages` method for simple consumer

  #69 opened 9 years ago by vincentbernat
  4

• Offset management

  #65 opened 9 years ago by cddr
  6

• Implement new KafkaConsumer

  #68 opened 9 years ago by vincentbernat
  0

• Convert Kafka byte-array to String\json

  #67 opened 9 years ago by panda87
  3

• Readme port numbers.

  #63 opened 9 years ago by noisesmith
  0

• Expose with-test-broker?

  #61 opened 9 years ago by cddr
  1

• release 0.3.2

  #60 opened 9 years ago by devn
  1

• clj-kafka.new.producer/producer code error

  #57 opened 9 years ago by pho-coder
  1

• README.md New Producer example error

  #56 opened 9 years ago by pho-coder
  0

• Confusing dependency on org.apache.zookeeper/zookeeper

  #46 opened 10 years ago by cch1
  1

• Use the new java producer api

  #45 opened 10 years ago by wotbrew
  3

• Method in high level consumer to get all message streams

  #41 opened 10 years ago by sheelc
  8

• 0.8.1 migration

  #23 opened 10 years ago by prepor
  8

• Multiple Topic Consumption

  #2 opened 13 years ago by pingles
  2

• CompilerException java.lang.NoClassDefFoundError

  #35 opened 10 years ago by hwasungmars
  1

• Add possibility to use embedded Kafka broker / producer / simple consumer

  #27 opened 11 years ago by vbauer
  2

• Kafka 0.8.0 has been released (no more beta)

  #20 opened 11 years ago by aew
  2

• Runtime Dependencies

  #19 opened 11 years ago by kaiserprogrammer
  2

• Multi-Message Sending Not Supported

  #18 opened 11 years ago by drbobbeaty
  8

• Set :topic for KafkaMessage with SimpleConsumer

  #16 opened 12 years ago by pingles
  0

• Using scala library 2.8.0

  #5 opened 12 years ago by ryanmmmmm
  9

• Update README and examples

  #12 opened 12 years ago by pingles
  0

• How to create custom encoders?

  #3 opened 12 years ago by hussein
  2

• Reduce logging level

  #15 opened 12 years ago by pingles
  1

• Refactor tests

  #14 opened 12 years ago by pingles
  1

• Zookeeper Consumer can't map to KafkaMessage records

  #11 opened 12 years ago by pingles
  0

• Officially published 0.8 Kafka Jar

  #10 opened 12 years ago by pingles
  0

• Ensure 0.8 compliance

  #13 opened 12 years ago by pingles
  0

• Upgrading to Kafka 0.8?

  #9 opened 12 years ago
  6

• Does the simple consumer keep track of it's offset?

  #4 opened 12 years ago by Sedward
  1