optiopay/kafka

Issues

• err: gzip: invalid header

  #116 opened 5 years ago by butnet
  3

• confluent-kafka-go - Got JoinGroup failed: Local: Required feature not supported by broker

  #123 opened 5 years ago by amgonencl
  5

• produce and consume function’s param partition

  #126 opened 5 years ago by ShmSeeker
  0

• Response for "Metadata" request is malformed

  #120 opened 5 years ago by nsubramanya-ns
  8

• Support Availablity

  #119 opened 5 years ago by pascaldekloe
  4

• Integration tests currently fail

  #60 opened 6 years ago by alexcesaro
  1

• Release 1.5.0 does not pass unit tests

  #90 opened 6 years ago by nim-nim
  3

• Fetching data with default MaxFetchSize produces an error

  #96 opened 7 years ago by andrewslotin
  1

• How to get offset of last consumed message?

  #83 opened 7 years ago by sunilmaiya
  0

• Error when run example in README.md

  #74 opened 8 years ago by supereagle
  0

• Deadlock where Broker.mu is never released

  #49 opened 8 years ago by DrTall
  7

• Using the example code help

  #65 opened 9 years ago by parth9615
  0

• Cannot dial a fresh instance of Kafka

  #58 opened 9 years ago by alexcesaro
  2

• Panic using random DistributingProducer with multiple producer threads

  #57 opened 9 years ago by alicia-c
  0

• optiopay/kafka to use exponential backoff on nodes that are down

  #55 opened 9 years ago by keep94
  1

• Using RequiredAcksNone causes panic when writing to kafka.

  #54 opened 9 years ago by keep94
  3

• TravisCI test runs unstable

  #38 opened 9 years ago by alpe
  1

• Get all messages returned by Kafka

  #50 opened 9 years ago by alexcesaro
  10

• Using proto.RequiredAcksNone causes panic

  #47 opened 9 years ago by keep94
  1

• Add more kafka error codes

  #42 opened 9 years ago by legionus
  0

• Tune performance in proto package

  #34 opened 9 years ago by husio
  2

• Document best practices for high level consumer functionality

  #39 opened 9 years ago by alpe
  1

• Distributed Consumer?

  #36 opened 9 years ago by sixtus
  6

• Cache connections used by producer

  #12 opened 9 years ago by husio
  6

• Consumer doesn't transparently fail over when the leader changes

  #27 opened 9 years ago by cespare
  2

• Abstract away connection error handling

  #26 opened 9 years ago by husio
  0

• Handle network errors in Produce and Consume

  #21 opened 10 years ago by legionus
  0

• Check CRC of fetched messages

  #19 opened 10 years ago by cespare
  2

• UknownTopic Or Partition

  #4 opened 10 years ago by PragmaticCypher
  1