issues
search
linkedin
/
li-apache-kafka-clients
li-apache-kafka-clients is a wrapper library for the Apache Kafka vanilla clients. It provides additional features such as large message support and auditing to the Java producer and consumer in the open source Apache Kafka.
BSD 2-Clause "Simplified" License
131
stars
52
forks
source link
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
Add back LiKafkaProducer.partitionsFor() that takes a set of topics
#101
jonlee2
closed
5 years ago
0
Pull in Kafka 2.0 clients
#100
jonlee2
closed
5 years ago
2
Porting all fixes from linkinedin.
#99
navina
closed
5 years ago
2
sanitize configs before passing them to vanilla clients
#98
radai-rosenblatt
opened
5 years ago
0
Port changes to oss code
#97
radai-rosenblatt
closed
6 years ago
0
port internal changes to open source repository
#96
radai-rosenblatt
closed
6 years ago
0
Consumer can't retrieve large message from Kafka
#95
JsonFn
opened
6 years ago
0
Fix the calculation of remaining waiting time when closing producer
#94
lindong28
closed
6 years ago
4
Integration with Apache storm
#93
clement76
opened
6 years ago
1
Example with Akka stream Kafka for consumer
#92
mavencode01
opened
6 years ago
3
fix bug where committed offsets were not making progress when all msgs are too large
#91
radai-rosenblatt
closed
6 years ago
1
Handle invalid offsets in a uniform manner.
#90
smccauliff
closed
6 years ago
0
Always make progress on commits.
#89
smccauliff
closed
6 years ago
0
RecordProcessor state should be updated when resets offset.
#88
becketqin
closed
6 years ago
0
explicitely fail build on old gradle versions
#87
radai-rosenblatt
closed
6 years ago
0
Use kafka 0.11.0.2
#86
lindong28
closed
6 years ago
1
Add logging when reset offsets.
#85
becketqin
closed
6 years ago
0
Some clarification of README
#84
antoinetran
closed
6 years ago
1
Fix the case that position throws exception on a good partition due t…
#83
becketqin
closed
6 years ago
1
Fix the DeliveredMessageOffsetTracker.hasDeliveredMessages()
#82
becketqin
closed
6 years ago
0
timeout support for close and better logging of close
#81
radai-rosenblatt
closed
6 years ago
0
fix flaky tests around offset commits
#80
radai-rosenblatt
closed
6 years ago
0
split into multiple modules
#79
radai-rosenblatt
closed
6 years ago
4
Fix IndexOutputOfBoundsException when sending records with zero length values.
#78
smccauliff
closed
6 years ago
0
LiKafkaConsumerImpl.position() should honor the auto offset reset policy
#77
becketqin
closed
6 years ago
1
add zkConnect() method to test harness for compatibility
#76
radai-rosenblatt
closed
6 years ago
0
fix bug in timeout calculation for consumer auditor shutdown
#75
radai-rosenblatt
closed
6 years ago
0
fix bug in test harness - broker ids are always ints
#74
radai-rosenblatt
closed
6 years ago
0
update gradle and code inspection tools, groundwork for sonarcloud
#73
radai-rosenblatt
closed
6 years ago
0
fix generated pom
#72
radai-rosenblatt
closed
6 years ago
0
Remove testng dependency in the test harness
#71
becketqin
closed
6 years ago
0
broker ids are ints, also explose broker lifecycle methods
#70
radai-rosenblatt
closed
6 years ago
0
Make auditor start and shutdown multi-thread safe.
#69
becketqin
closed
6 years ago
0
Fix the issue that NPE is thrown when user sends null value.
#68
becketqin
closed
6 years ago
0
Improve the AbstracAuditor to allow implementation better handle the InterruptedException
#67
becketqin
closed
6 years ago
0
Add SSL support to integration tests
#66
jjkoshy
closed
6 years ago
2
abolish scala. make test harnesses java, avoid any link-time dependency on scala
#65
radai-rosenblatt
closed
6 years ago
0
bump kafka dep. to 10.0.2.1. also bump testng
#64
radai-rosenblatt
closed
6 years ago
0
fix circleci build to actually trigger on tags (hopefully...)
#63
radai-rosenblatt
closed
7 years ago
0
require release tags to be _exactly_ of the form X.Y.Z
#62
radai-rosenblatt
closed
7 years ago
0
bump version to 0.0.6
#61
radai-rosenblatt
closed
7 years ago
0
Add release on tag for circleci
#60
radai-rosenblatt
closed
7 years ago
2
Fix LargeMessageBufferPool when evicting the message whose segment is being added.
#59
becketqin
closed
7 years ago
1
Add constructor that allows injecting a Consumer
#58
ambroff
closed
5 years ago
2
RELEASE attempt
#57
radai-rosenblatt
closed
7 years ago
0
cache entire gradle folder, set root project name
#56
radai-rosenblatt
closed
7 years ago
0
cache entire gradle folder, set root project name
#55
radai-rosenblatt
closed
7 years ago
0
trigger a release
#54
radai-rosenblatt
closed
7 years ago
0
update to circleci 2.0
#53
radai-rosenblatt
closed
7 years ago
1
Auditor should only call join() if timeout > 0
#52
lindong28
closed
7 years ago
1
Previous
Next