Data

Tools

Indexes

Applications

Experiments

Issues

An open API service for providing issue and pull request metadata for open source projects.

GitHub / dibbhatt/kafka-spark-consumer issues and pull requests

#72 - Can a higher version of Spark be supported? Spark 3.2.0 for example.

Issue - State: closed - Opened by joao-parana over 3 years ago - 1 comment

#71 - Can a higher version of kafka be supported

Issue - State: closed - Opened by jasonhuxinlei over 4 years ago - 2 comments

#70 - Bump junit from 4.11 to 4.13.1

Pull Request - State: open - Opened by dependabot[bot] almost 5 years ago
Labels: dependencies

#69 - Trying to fetch Multi topic In Local , But It is showing warning like this

Issue - State: closed - Opened by parthasarathy93 almost 5 years ago - 2 comments

#68 - example doesn't build

Issue - State: closed - Opened by IRobL over 5 years ago - 1 comment

#67 - Bump spark.version from 2.2.0 to 2.4.4

Pull Request - State: closed - Opened by dependabot[bot] almost 6 years ago
Labels: dependencies

#66 - Manipulation of offsetRanges in each batch

Issue - State: open - Opened by Bonnie16 almost 6 years ago

#65 - add persistsPartition to support offset update within foreachRDD

Pull Request - State: closed - Opened by doddys almost 6 years ago - 1 comment

#64 - Offset is still updated when exception occurs during processing

Issue - State: closed - Opened by doddys almost 6 years ago - 28 comments

#63 - java.lang.NoClassDefFoundError: kafka/api/OffsetRequest

Issue - State: closed - Opened by alonshoshani about 6 years ago - 22 comments

#62 - Does this support spark structured streaming

Issue - State: closed - Opened by puneetloya over 6 years ago - 1 comment

#60 - The Spark Streaming can not read kafka message

Issue - State: closed - Opened by wowojyc over 6 years ago - 8 comments

#58 - Fix indention

Pull Request - State: closed - Opened by spring1843 almost 7 years ago - 1 comment

#55 - Kafka Headers Support

Issue - State: closed - Opened by agolomoodysaada over 7 years ago - 7 comments

#54 - Hello, Compilation failed after changing Kafka version 0.10.0.0

Issue - State: closed - Opened by iduanyingjie over 7 years ago - 5 comments

#53 - Exception: Could not compute split, block not found

Issue - State: closed - Opened by MLNW over 7 years ago - 6 comments

#52 - AbstractMethodError with Spark 1.6.0 and Kafka 0.10.2

Issue - State: closed - Opened by MLNW over 7 years ago - 9 comments

#51 - How to use in kerberized context ?

Issue - State: closed - Opened by StudioEtrange over 7 years ago - 3 comments

#50 - Not working with Spark 2.2.0

Issue - State: closed - Opened by swrholdj about 8 years ago - 11 comments

#49 - Why appear this exception information?

Issue - State: closed - Opened by ghost about 8 years ago - 8 comments

#48 - update kafka.input.topic ---> kafka.topic

Pull Request - State: closed - Opened by ghost about 8 years ago - 2 comments

#47 - Consumer not able to read kafka topic and write to HDFS

Issue - State: closed - Opened by sbellary300s about 8 years ago - 7 comments

#46 - The log of application contain too many the messages of LOG.info

Issue - State: closed - Opened by zlkkuu about 8 years ago - 2 comments

#44 - java.lang.ClassNotFoundException: kafka.api.OffsetRequest

Issue - State: closed - Opened by Hungsiro506 over 8 years ago - 2 comments

#43 - ReceiverLauncher.launch can not get data

Issue - State: closed - Opened by zlkkuu over 8 years ago - 5 comments

#42 - Fix issue 41 - fail to commit when consume one record.

Pull Request - State: closed - Opened by saturday-shi over 8 years ago - 3 comments

#40 - How to use the application to handle multi topic

Issue - State: closed - Opened by zdxMike over 8 years ago - 11 comments

#39 - app client consumer doesn´t consume offsets from kafka topic

Issue - State: closed - Opened by jorgeakanieves over 8 years ago - 43 comments

#38 - java.lang.ClassNotFoundException: consumer.kafka.client.KafkaReceiver

Issue - State: closed - Opened by vroy007 over 8 years ago - 12 comments

#37 - mvn repository you provided is not working

Issue - State: closed - Opened by zacker330 over 8 years ago - 3 comments

#36 - Python api?

Issue - State: closed - Opened by manugarri over 8 years ago - 2 comments

#33 - Consumer commit not proceeding the offset anymore

Issue - State: closed - Opened by krantig almost 9 years ago - 16 comments

#32 - Compilation fix for spark 2.0.0 and Scala 2.11

Pull Request - State: closed - Opened by LukaszZu almost 9 years ago

#31 - Released latest version 1.0.8 of the Receiver

Issue - State: closed - Opened by dibbhatt almost 9 years ago

#30 - failure occurred when set spark.streaming.concurrentJobs from 1 to 2

Issue - State: closed - Opened by AndyRao about 9 years ago - 5 comments

#29 - exception on simple example

Issue - State: closed - Opened by fabiofumarola over 9 years ago - 7 comments

#28 - Static zookeeper hosts configuration

Issue - State: closed - Opened by muuki88 over 9 years ago - 2 comments

#26 - Some jobs remain in processing state forever

Issue - State: closed - Opened by sorabh89 almost 10 years ago - 3 comments

#25 - Unable to receive data

Issue - State: closed - Opened by sorabh89 almost 10 years ago - 21 comments

#24 - How to decode byte messages from Kafka

Issue - State: closed - Opened by fzschornack almost 10 years ago - 6 comments

#23 - After some hours not processing because of executor fail error

Issue - State: closed - Opened by sorabh89 almost 10 years ago - 7 comments

#21 - getting GC : outofmemory exception

Issue - State: closed - Opened by sorabh89 about 10 years ago - 22 comments

#20 - want to create more than 1 application but want single Kafka stream

Issue - State: closed - Opened by sorabh89 about 10 years ago - 10 comments

#19 - Kafka apache spark Streaming recive 0

Issue - State: closed - Opened by sidahmedbenkhaoua about 10 years ago - 2 comments

#18 - Not able to get streaming data

Issue - State: closed - Opened by sorabh89 about 10 years ago - 4 comments

#17 - MEMORY_ONLY, MEMORY_ONLY_* storage levels

Issue - State: closed - Opened by jedisct1 about 10 years ago - 6 comments

#15 - Missing explanation why it has better kafka offsets/error handling

Issue - State: closed - Opened by cleaton over 10 years ago - 8 comments

#14 - High CPU usage

Issue - State: closed - Opened by jedisct1 over 10 years ago - 15 comments

#13 - No Data reciver Apache kafka apache spark

Issue - State: closed - Opened by sidahmedbenkhaoua over 10 years ago - 3 comments

#12 - Update README.md

Pull Request - State: closed - Opened by akhld over 10 years ago - 1 comment

#11 - Single message to kafka not processed in some cases

Issue - State: closed - Opened by neeleshs over 10 years ago - 3 comments

#10 - Release on Spark Packages Repo

Issue - State: closed - Opened by brkyvz over 10 years ago - 4 comments

#9 - Add an optional property to specify the number of partitions

Pull Request - State: closed - Opened by jedisct1 over 10 years ago - 2 comments

#8 - How many KafkaReceiver do I need?

Issue - State: closed - Opened by jedisct1 over 10 years ago - 9 comments

#7 - How is it different from KafkaUtils.createStream of spark-streaming-kafka_2.10?

Issue - State: closed - Opened by bzz over 10 years ago - 2 comments

#6 - Unable to pull Batch info metrics using StreamingListener Interface

Issue - State: closed - Opened by akhld over 10 years ago - 14 comments

#5 - Build Failure

Issue - State: closed - Opened by akhld over 10 years ago - 3 comments

#4 - Added Scala Example

Pull Request - State: closed - Opened by akhld over 10 years ago

#3 - Doesn't seems to be working

Issue - State: closed - Opened by akhld over 10 years ago - 37 comments

#2 - Licensing concerns with current kafka-spark-consumer source code

Issue - State: closed - Opened by miguno almost 11 years ago - 8 comments

#1 - pom.xml update (java compile -source)

Pull Request - State: closed - Opened by c-dante almost 11 years ago - 1 comment