MORPH
SIGN IN SIGN UP
apache / kafka UNCLAIMED

Apache Kafka - A distributed event streaming platform

32228 0 0 Java

ACTIVITY

Commits Reviews
week month year
COMMITS
20
in the last week
CONTRIBUTORS
16
active
STARS
32228
total
FORKS
0
total
TOP CONTRIBUTORS
M
Murali Basani
3 commits
P
PoAn Yang
2 commits
M
Mickael Maison
2 commits
M
majialong
1 commit
A
Angelo R.
1 commit
A
Alieh Saeedi
1 commit
M
Matthias J. Sax
1 commit
A
Arpit Goyal
1 commit
Z
zoo-code
1 commit
C
ChickenchickenLove
1 commit
RECENT COMMITS
M
KAFKA-20347 Fix metric leak and JMX tag order in ShareCoordinatorMetrics (#21885)
majialong
b4d1ca7
M
KAFKA-20359 Update docker image with fully qualified name (#21877)
Murali Basani
5a2d79a
P
MINOR: Use getAbsolutePath in LocalLog#exception (#21891)
PoAn Yang
e4f75df
M
KAFKA-14487 Move LogManager to storage module (#21834)
Mickael Maison
29d0ec2
A
KAFKA-20310: Persist previousProducerId and nextProducerId in transaction log (#21828)
Angelo R.
eb111f6
P
KAFKA-20205: Use utils in TimestampedToHeadersWindowStoreAdapter (#21886)
PoAn Yang
20e681b
A
KAFKA-9195: Use Randomized State Directory Names in Streams System Tests (#21879)
Alieh Saeedi
6fe8415
M
MINOR: simplify window-byte-store-supplier (#21829)
Matthias J. Sax
6ebc93c
A
MINOR: Remove boilerplate code from header serializer test (#21837)
Arpit Goyal
b42acde
Z
KAFKA-20279: Refactor dslStoreFormat resolution into AbstractConfigurableStoreFactory (#21804)
zoo-code
5a94cd6
M
KAFKA-20287 : Fix CF handle leaks (#21751)
Murali Basani
5e509dc
C
KAFKA-20203: setFlushListener should pass record.headers() instead of empty headers (#21802)
ChickenchickenLove
3fd16d0
K
KAFKA-16600: Add unit test for idempotent PENDING_SHUTDOWN state transition (#21671)
Kirk True
73cb15e
K
KAFKA-15630: Improve documentation of offset.lag.max (#21357)
Kondrat Bertalan
1b69c09
M
MINOR: Various cleanups in raft module (#21883)
Mickael Maison
9d1c93b
L
KAFKA-20106 [2/2]: Ensure reconciled assignment updated within poll KS (#21813)
Lianet Magrans
69f7515
M
KAFKA-20267: Move LogCleanerParameterizedIntegrationTest to storage module (#21657)
Maros Orsak
de7e0eb
C
KAFKA-15853: [1/N] Move static methods, SocketServer and Log configs to AbstractKafkaConfig (#21548)
Christo Lolov
58b56c2
M
KAFKA-20360 Upgrade ducktape from 0.13 to 0.14 and requests from 2.32.2 to 2.32.4 (#21878)
Murali Basani
f93ffeb
J
KAFKA-19541; Allow configuration of kraft RPC max bytes (#21028)
Jonah Hooper
4d3c658