wvanbergen/kafka

Issues

• Kafkaconsumer stops consuming after ZK connection lost/timeout

  #80 opened 9 years ago by josselin-c
  12

• Leader change during re-balance may cause partition not being consumed

  #125 opened 7 years ago by waterlx
  4

• Is there any way to get to the ConsumerGroup. Instance. ID？

  #130 opened 6 years ago by yjp211
  0

• which tag or version support kafka 0.8 ?

  #129 opened 6 years ago by inolddays
  0

• Version releases?

  #128 opened 7 years ago by natdm
  2

• ConsumerGroup.FlushOffsets()

  #127 opened 7 years ago by wangping886
  3

• Can't receive messages when i test the demo which the project gives.

  #126 opened 7 years ago by runnerliu
  4

• Kafka consumer not restarting after broker failure

  #124 opened 7 years ago by bidesh
  0

• Upgrading to kafka based offset storage

  #123 opened 7 years ago by sagard
  1

• Trouble reliably reusing consumer group names across topics

  #122 opened 7 years ago by mcandre
  1

• Some problems when I try to run my consumer in two node.

  #121 opened 7 years ago by HouLinwei
  3

• How to exit the program in kafka/examples/consumergroup/main.go gracefully?

  #114 opened 8 years ago by alexkkk
  1

• Consumer group not consuming from partitions -- Kafka v11

  #119 opened 7 years ago by arriqaaq
  0

• Bug? Consuming stops or hangs at certain time.

  #110 opened 8 years ago by windless0530
  0

• consumergroup not work in docker

  #117 opened 8 years ago by weisd
  1

• consumption message delay

  #116 opened 8 years ago by orange-jacky
  0

• Clarify Kafka version support

  #115 opened 8 years ago by mcandre
  3

• zk: node does not exist

  #107 opened 8 years ago by sparkthu
  1

• ConsumerGroup.Messages()

  #111 opened 8 years ago by orange-jacky
  3

• Lots of logs such as "abandoned subscription to xxx because consuming was taking too long"

  #109 opened 8 years ago by sparkthu
  1

• Is There Any Benchmark for the Consumer?

  #108 opened 8 years ago by sparkthu
  1

• The best practice of handling offsets of asynchronous consuming?

  #106 opened 8 years ago by asaarashi
  6

• does this client support batch consume?

  #89 opened 8 years ago by cch123
  4

• some partitions have no owner

  #102 opened 8 years ago by Huang-lin
  4

• how to disable rebalance?

  #100 opened 8 years ago by lovestorm88
  1

• Run into "index out of range" when launch multiple concurrent consumers "go routine" in a single go process

  #94 opened 9 years ago by mrcold
  1

• nil message received causing NPE

  #81 opened 9 years ago by rrh
  7

• panic: invalid memory address or nil pointer dereference

  #95 opened 9 years ago by jaredye
  2

• Error not handled with cg.instance.ReleasePartition()

  #91 opened 9 years ago by bhirbec
  5

• Group doesn't recover after internet connectivity issue

  #96 opened 9 years ago by bhirbec
  4

• can i use this package if my offset is stored in kafka not zk ?

  #90 opened 9 years ago by WanliTian
  2

• Consumergroup stops consuming after ZK connection lost/timeout

  #76 opened 9 years ago by nemosupremo
  7

• when cg close, it should commit the offset before quit

  #86 opened 9 years ago by lovestorm88
  1

• Panic on "CommitUpto" after rebalance

  #77 opened 9 years ago by nemosupremo
  1

• Partition rebalance has serious issues

  #51 opened 10 years ago by baconalot
  4

• consumergroup hangs after sometime

  #23 opened 9 years ago by lokeshintuit
  2

• Commit when CG closed

  #50 opened 9 years ago by baconalot
  2

• Partition re-balance issue : 'FAILED to claim the partition'

  #58 opened 9 years ago by fayizk1
  1

• Watch Zookeeper for partition changes

  #70 opened 9 years ago by wvanbergen
  1

• Panic Integer Divide by Zero when dividePartitionsBetweenConsumers

  #60 opened 9 years ago by nemosupremo
  3

• Race condition in partition rebalance.

  #62 opened 9 years ago by nemosupremo
  0

• Try to FixBug: Two consumers compete partitions on zkpath: $kafka_root/consumers/$group/owners/$topic/{$partid1; $partid2...}

  #65 opened 9 years ago by sirfangx
  2

• Failure to use select instead of range

  #73 opened 9 years ago by echupriyanov
  2

• Partitions are split evenly among consumers / some consumers left out

  #61 opened 9 years ago by nemosupremo
  2

• Expose a way to set offset manager config

  #64 opened 9 years ago by aaronkavlie-wf
  2

• Plans for this repository

  #47 opened 9 years ago by lukanus
  4

• JoinConsumerGroup silently fails if topics are not created

  #42 opened 10 years ago by bnekolny
  0

• Null pointer exception when starting another instance for the same consumer group

  #35 opened 10 years ago by bayan
  2

• Incompatible with latest Sarama Client

  #34 opened 10 years ago by marcusking01
  2

• "This is really shitty and needs reworking"

  #18 opened 10 years ago by jiminoc
  2