dibbhatt/kafka-spark-consumer

Issues

• Can a higher version of Spark be supported? Spark 3.2.0 for example.

  #72 opened 3 years ago by joao-parana
  1

• Can a higher version of kafka be supported

  #71 opened 3 years ago by jasonhuxinlei
  2

• example doesn't build

  #68 opened 4 years ago by IRobL
  1

• Trying to fetch Multi topic In Local , But It is showing warning like this

  #69 opened 4 years ago by parthasarathy93
  2

• Manipulation of offsetRanges in each batch

  #66 opened 5 years ago by Bonnie16
  0

• How to use the application to handle multi topic

  #40 opened 5 years ago by zdxMike
  11

• Offset is still updated when exception occurs during processing

  #64 opened 5 years ago by doddys
  28

• java.lang.NoClassDefFoundError: kafka/api/OffsetRequest

  #63 opened 5 years ago by alonshoshani
  22

• Does this support spark structured streaming

  #62 opened 6 years ago by puneetloya
  1

• It works well in local model,but when I submit it in cluster model,the fixed rate is too small

  #61 opened 6 years ago by yangcong3643
  5

• AbstractMethodError with Spark 1.6.0 and Kafka 0.10.2

  #52 opened 7 years ago by MLNW
  9

• The Spark Streaming can not read kafka message

  #60 opened 6 years ago by wowojyc
  8

• May I have a Scala sample of messageHandler to filter out some playload which includes some strings?

  #59 opened 6 years ago by yufuxin
  20

• Why appear this exception information?

  #49 opened 7 years ago
  8

• How to use in kerberized context ?

  #51 opened 7 years ago by StudioEtrange
  3

• Consumer commit not proceeding the offset anymore

  #33 opened 8 years ago by krantig
  16

• java.lang.ClassNotFoundException: consumer.kafka.client.KafkaReceiver

  #38 opened 8 years ago by vroy007
  12

• Not working with Spark 2.2.0

  #50 opened 7 years ago by swrholdj
  11

• How to recover the failed receiver on a partition which has exception of " Offsets out of range with no configured reset policy for partitions:"

  #57 opened 6 years ago by yufuxin
  18

• Hello, Compilation failed after changing Kafka version 0.10.0.0

  #54 opened 7 years ago by iduanyingjie
  5

• After long time running, the processing time of "ProcessedOffsetManager.persists(partitonOffset_stream, props)" incresing.

  #56 opened 6 years ago by yufuxin
  13

• Kafka Headers Support

  #55 opened 7 years ago by agolomoodysaada
  7

• Exception: Could not compute split, block not found

  #53 opened 7 years ago by MLNW
  6

• error: object ProcessedOffsetManager is not a member of package consumer.kafka

  #45 opened 7 years ago by Srinivasan-pp
  1

• The log of application contain too many the messages of LOG.info

  #46 opened 7 years ago by zlkkuu
  2

• Consumer not able to read kafka topic and write to HDFS

  #47 opened 7 years ago by sbellary300s
  7

• app client consumer doesn´t consume offsets from kafka topic

  #39 opened 8 years ago by jorgeakanieves
  43

• ReceiverLauncher.launch can not get data

  #43 opened 8 years ago by zlkkuu
  5

• java.lang.ClassNotFoundException: kafka.api.OffsetRequest

  #44 opened 8 years ago by Hungsiro506
  2

• Consumer how to use Kafka utilities like ConsumerOffsetChecker and get to show on Kafka Tool

  #34 opened 8 years ago by krantig
  2

• PartitionManager not writing Offset to Zookeeper if a record fetched from Kafka only contain one line.

  #41 opened 8 years ago by ChorPangChan
  9

• Contributing Receiver based Low Level Kafka Consumer from Spark-Packages to Apache Spark Project

  #27 opened 8 years ago by dibbhatt
  2

• Released latest version 1.0.8 of the Receiver

  #31 opened 8 years ago by dibbhatt
  0

• mvn repository you provided is not working

  #37 opened 8 years ago by zacker330
  3

• Python api?

  #36 opened 8 years ago by manugarri
  2

• work fine few days, then can't commit offerset, no error log, and no info log about PartitionManager

  #35 opened 8 years ago by cyinll
  2

• org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /brokers/topics/load/partitions

  #16 opened 10 years ago by justinjoseph89
  10

• Some jobs remain in processing state forever

  #26 opened 8 years ago by sorabh89
  3

• failure occurred when set spark.streaming.concurrentJobs from 1 to 2

  #30 opened 8 years ago by AndyRao
  5

• exception on simple example

  #29 opened 9 years ago by fabiofumarola
  7

• Static zookeeper hosts configuration

  #28 opened 9 years ago by muuki88
  2

• How to decode byte messages from Kafka

  #24 opened 9 years ago by fzschornack
  6

• Running application on 3 node cluster, 3 instances of the same application are shown with different user

  #22 opened 9 years ago by sorabh89
  5

• Unable to receive data

  #25 opened 9 years ago by sorabh89
  21

• After some hours not processing because of executor fail error

  #23 opened 9 years ago by sorabh89
  7

• getting GC : outofmemory exception

  #21 opened 9 years ago by sorabh89
  22

• want to create more than 1 application but want single Kafka stream

  #20 opened 9 years ago by sorabh89
  10

• Kafka apache spark Streaming recive 0

  #19 opened 9 years ago by sidahmedbenkhaoua
  2

• Not able to get streaming data

  #18 opened 10 years ago by sorabh89
  4

• MEMORY_ONLY, MEMORY_ONLY_* storage levels

  #17 opened 10 years ago by jedisct1
  6