RTBHOUSE/kafka-workers issues and pull requests

#46 - fix NPE when partitions are unregistered

Pull Request - State: closed - Opened by hejcz almost 3 years ago

#45 - Add worker thread assignor

Pull Request - State: closed - Opened by hejcz almost 3 years ago - 1 comment
Labels: enhancement

#44 - Add record timestamp metric

Pull Request - State: closed - Opened by wojtek-rybak almost 3 years ago

#43 - Compute offsets-state metrics in a separate thread

Pull Request - State: closed - Opened by tulinski about 3 years ago

#42 - Consumer thread waits for worker threads to stop.

Pull Request - State: closed - Opened by tulinski about 3 years ago

#41 - Bump guava from 27.0.1-jre to 29.0-jre

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

#40 - Fix deadlock when shutdown-thread hangs on CLOSING state

Pull Request - State: closed - Opened by tulinski over 3 years ago

#39 - Fix deadlock when shutdown-thread dies

Pull Request - State: closed - Opened by tulinski almost 4 years ago

#38 - Fix deadlock when shutdown-thread dies

Pull Request - State: closed - Opened by tulinski almost 4 years ago

#37 - Update kafka.version to 2.4.1

Pull Request - State: closed - Opened by tulinski almost 4 years ago

#36 - Bump junit from 4.12 to 4.13.1

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

#35 - Update kafka client to 2.4.0

Issue - State: closed - Opened by tulinski almost 4 years ago

#34 - Fix deadlock on Kafka rebalance (when some worker threads are blocked)

Pull Request - State: closed - Opened by tulinski about 4 years ago

#33 - Split record.weigher into record.key.weigher and record.value.weigher

Pull Request - State: closed - Opened by tulinski about 4 years ago

#32 - QueuesManager sets queue sizes based on the heap size

Pull Request - State: closed - Opened by tulinski over 4 years ago - 1 comment

#31 - Update kafka-clients to 2.3.0

Pull Request - State: closed - Opened by tulinski over 4 years ago

#30 - Make an HDFS connector publicly available

Issue - State: open - Opened by tulinski over 4 years ago

#29 - Closing an app even when worker threads cannot be stopped

Pull Request - State: closed - Opened by tulinski over 4 years ago

#28 - Task processing and/or app shutdown should be timeouted

Issue - State: closed - Opened by barteklos over 4 years ago - 1 comment

#27 - OffsetsState.getOffsetsToCommit methods return maps based on topic partitions registered inside

Pull Request - State: closed - Opened by tulinski almost 5 years ago

#26 - Add tests for ProcessingTimeoutException

Pull Request - State: closed - Opened by tulinski almost 5 years ago

#25 - Fix global TopicPartition and WorkerSubpartition caches

Pull Request - State: closed - Opened by tulinski almost 5 years ago

#24 - Features nice to have

Issue - State: open - Opened by bdamian almost 5 years ago - 2 comments

#23 - Pass global monitoring properties to consumer config

Pull Request - State: closed - Opened by tulinski almost 5 years ago

#22 - Improved memory utilization in OffsetsState default implementation

Pull Request - State: closed - Opened by tulinski about 5 years ago

#21 - [#20] Optimize memory footprint of RecordStatusObserverImpl

Pull Request - State: closed - Opened by tulinski about 5 years ago

#20 - Memory heavy RecordStatusObserverImpl

Issue - State: closed - Opened by tulinski about 5 years ago - 3 comments

#19 - repeated consumption

Issue - State: closed - Opened by cshuig about 5 years ago - 3 comments

#18 - unified record & batch status observers

Pull Request - State: closed - Opened by barteklos over 5 years ago - 1 comment

#17 - Inherit with spring

Issue - State: closed - Opened by cshuig over 5 years ago - 4 comments

#16 - Introduced eager initialization of a task during it's creation.

Pull Request - State: open - Opened by bdamian over 5 years ago

#15 - queue.resume.ratio added with 0.9 default value

Pull Request - State: closed - Opened by barteklos over 5 years ago

#14 - AbstractWorkersThread's resource cleanup to be invoked sequentially.

Pull Request - State: closed - Opened by flowenol over 5 years ago

#13 - punctuate() method added to WorkerTask API

Pull Request - State: closed - Opened by barteklos over 5 years ago

#12 - removed unneeded RecordProcessingActionException

Pull Request - State: closed - Opened by flowenol over 5 years ago

#11 - WorkerException thrown from task is handled in RecordStatusObserver

Pull Request - State: closed - Opened by flowenol over 5 years ago

#10 - processing guarantees instead of workers actions

Pull Request - State: closed - Opened by flowenol over 5 years ago - 1 comment

#9 - RecordObserverImpl doesn't hold WorkerRecord by default but depending…

Pull Request - State: closed - Opened by flowenol over 5 years ago

#8 - WorkerThread.getTasksToProcess concurrency fix

Pull Request - State: closed - Opened by barteklos over 5 years ago

#7 - Add consumer commit retries + minor consumer fixes

Pull Request - State: closed - Opened by barteklos over 5 years ago

#6 - Consumer commit retries

Pull Request - State: closed - Opened by barteklos over 5 years ago

#5 - add tests-jar artifact

Pull Request - State: closed - Opened by flowenol over 5 years ago

#4 - Add actions called on record processing failure

Pull Request - State: closed - Opened by barteklos over 5 years ago

#3 - Unlimited queue.total.max.size.bytes

Pull Request - State: closed - Opened by barteklos almost 6 years ago

#2 - Add worker-threads metric group

Pull Request - State: closed - Opened by tulinski almost 6 years ago

#1 - Add generic HashFunctionPartitioner

Pull Request - State: closed - Opened by tulinski almost 6 years ago

GitHub / RTBHOUSE/kafka-workers issues and pull requests