skroutz/rafka

Issues

• Handle all errors

  #21 opened 5 years ago by agis
  0

• Newly-spawned consumers lagging shutdown

  #73 opened 5 years ago by agis
  1

• producer: Make Flush timeout configurable

  #35 opened 7 years ago by agis
  0

• Increased memory usage with many short-lived producers

  #39 opened 7 years ago by agis
  2

• Expose librdkafka stats to clients

  #28 opened 7 years ago by agis
  1

• debian: running -version doesn't contain the sha1

  #78 opened 5 years ago by agis
  0

• Shutdown server after e2e tests are finished

  #71 opened 6 years ago by agis
  0

• Configurable producer flush timeout setting

  #70 opened 6 years ago by agis
  1

• Allow clients to set custom producer IDs

  #46 opened 7 years ago by agis
  0

• Investigate transient Travis CI failures

  #65 opened 6 years ago by agis
  0

• Integrate with Travis CI

  #54 opened 6 years ago by agis
  0

• Close() may hung indefinitely

  #59 opened 6 years ago by agis
  0

• Allow clients to fully control their configuration

  #19 opened 6 years ago by agis
  0

• Get vgo-ready

  #62 opened 6 years ago by agis
  0

• consumer: Use OffsetsStore() API

  #32 opened 6 years ago by agis
  0

• Segmentation fault on rafka container

  #11 opened 6 years ago by agis
  3

• Specify starting offset (and consuming count) for consumer

  #56 opened 7 years ago by papanikge
  0

• consumer: First message is lost if `auto.offset.reset = latest`

  #52 opened 7 years ago by agis
  1

• Drop x/sync package dep. and rely on Go 1.9

  #42 opened 7 years ago by agis
  0

• Use uint for stats counters

  #45 opened 7 years ago by agis
  0

• Implement a reset command for stats

  #47 opened 7 years ago by agis
  0

• Collect stats about connections, consumers, producers

  #48 opened 7 years ago by ctrochalakis
  0

• producer: Allow clients to control their configuration

  #40 opened 7 years ago by agis
  1

• Revamp logging

  #3 opened 7 years ago by agis
  1

• producer: Data race on configuration

  #34 opened 7 years ago by agis
  0

• producer: Outstanding events even if message if flushed

  #33 opened 7 years ago by agis
  0

• Test binary can't run with custom flags

  #41 opened 7 years ago by agis
  0

• Client.Close() should also close its connection

  #36 opened 7 years ago by agis
  0

• Test with librdkafka 0.11

  #17 opened 7 years ago by agis
  1

• Conform to Kafka id naming rules

  #23 opened 7 years ago by agis
  1

• Set client.id

  #24 opened 7 years ago by agis
  0

• Provide sane defaults

  #1 opened 7 years ago by agis
  1

• Switch license to GPL

  #27 opened 7 years ago by agis
  1

• Add unit tests

  #13 opened 7 years ago by agis
  0

• test: Early exit if Rafka server is not up

  #25 opened 7 years ago by agis
  0

• Memory leak in consumer

  #22 opened 7 years ago by agis
  0

• Unclosed consumers

  #5 opened 7 years ago by agis
  1

• docker: No complete logs when shutting down

  #18 opened 7 years ago by agis
  0

• Test consumer group reconnect scenario

  #14 opened 7 years ago by agis
  1

• consumer: Expose explicit topic assign command

  #15 opened 7 years ago by agis
  0

• Polish README

  #9 opened 7 years ago by agis
  0

• Add a Makefile

  #10 opened 7 years ago by agis
  0

• End-to-end tests

  #7 opened 7 years ago by agis
  0

• Consumer manager stuck on cleanup

  #2 opened 7 years ago by agis
  0

• Print librdkafka version on boot

  #6 opened 7 years ago by agis
  0