onyx-platform/onyx-kafka

Issues

• :kafka/commit-interval deprecated in or before 0.14.5.0?

  #62 opened 5 years ago by Quezion
  0

• StringSerializer/StringDeserializer instead of ByteArraySerializer/ByteArrayDeserializer

  #60 opened 6 years ago by danieroux
  1

• Incompatible slf4j versions causes Datomic initialisation to fail

  #43 opened 7 years ago by cursive-ide
  2

• Make kafka/zookeeper optional

  #50 opened 7 years ago by lbradstreet
  0

• Troubleshooting simple job not writing to a topic

  #47 opened 7 years ago by twashing
  1

• NPE caused by missing either :onyx/n-peers or :onyx/max-peers

  #49 opened 7 years ago by kennyjwilli
  1

• Functionality that enables autoscaling

  #48 opened 7 years ago by eelkevanfoeken
  0

• Keyed messages support

  #3 opened 9 years ago by lgrapenthin
  13

• Missing dependency for Cheshire JSON encoder

  #36 opened 8 years ago by theblackbox2600
  1

• Add schema checks of task-maps

  #8 opened 8 years ago by lbradstreet
  3

• Kafka 0.9 consumer offset rename

  #33 opened 8 years ago by MichaelDrogalis
  1

• surprising replay in development

  #29 opened 8 years ago by mccraigmccraig
  4

• Add producer throughput test, including end to end latency test

  #32 opened 8 years ago by lbradstreet
  1

• Only restart jobs that are likely to succeed

  #28 opened 8 years ago by jcf
  4

• kafka send data with sync is very slow

  #25 opened 8 years ago by clojurians-org
  2

• Consider how to allow arbitrary config options to be passed to the producer / consumer

  #12 opened 8 years ago by lbradstreet
  5

• Exception thrown in commit loop will cause commits to stop

  #20 opened 8 years ago by lbradstreet
  1

• fixed-partition only supports setting max-peers, not n-peers

  #31 opened 8 years ago by aaron-daly
  2

• Need a throughput / latency test

  #30 opened 8 years ago by lbradstreet
  3

• :onyx/min-peers must equal :onyx/max-peers error when using :onyx/n-peers

  #24 opened 8 years ago by neverfox
  5

• Provide task bundles

  #18 opened 9 years ago by gardnervickers
  0

• typo in readme.md

  #21 opened 9 years ago
  1

• Add new test stopping broker mid job

  #15 opened 9 years ago by lbradstreet
  1

• Look into transient CI failure

  #14 opened 9 years ago by lbradstreet
  0

• Try/catch around serializer/deserializer fn resolution

  #11 opened 9 years ago by lbradstreet
  0

• Add support to write to a particular kafka partition

  #9 opened 9 years ago by lbradstreet
  1

• Document checkpointing method

  #6 opened 9 years ago by lbradstreet
  0

• Document embedded kafka server

  #4 opened 9 years ago by lbradstreet
  1