Commits

Commits on Oct 28, 2021

MINOR: Fix partition state change error msg (apache#11427 )
JoeCqupt
committedOct 28, 2021
HOTFIX: remove unused import for RequestHeaderTest
cmccabe
committedOct 28, 2021

Commits on Oct 27, 2021

KAFKA-13385: In the KRPC request header, translate null clientID to empty (apache#11385 )
cmccabe
committedOct 27, 2021
KAFKA-12648: fill in javadocs for the StreamsException class with new guarantees (apache#11436 )
A. Sophie Blee-Goldman
committedOct 27, 2021
MINOR: Fix GroupCoordinator.onGroupLoaded log (apache#11434 )
dajac
committedOct 27, 2021
MINOR: Fix category in doap_Kafka.rdf (apache#11423 )
sebbASF
committedOct 27, 2021

Commits on Oct 26, 2021

Commits on Oct 25, 2021

KAFKA-13391: don't fsync directory on Windows OS (apache#11426 )
showuon
committedOct 25, 2021

Commits on Oct 22, 2021

KAFKA-12697: Add FencedBrokerCount and ActiveBrokerCount metrics to the QuorumController (apache#10772 )
dielhennr
committedOct 22, 2021

Commits on Oct 21, 2021

kafka-12994: Migrated SlidingWindowsTest to new API (apache#11379 )
officialpatterson
committedOct 21, 2021
KAFKA-12648: Wrap all exceptions thrown to handler as StreamsException & add TaskId field (apache#11405 )
A. Sophie Blee-Goldman
committedOct 21, 2021
MINOR: Renamed a few record definition files with the existing convention. (apache#11414 )
satishd
committedOct 21, 2021
MINOR: Fixed "snasphot" naming issue (apache#11203 )
socutes
committedOct 21, 2021

Commits on Oct 20, 2021

MINOR: Javadoc formatting for MetricsContext (apache#11419 )
tombentley
committedOct 20, 2021
MINOR: Add a replication system test which simulates a slow replica (apache#11395 )
dajac
committedOct 20, 2021

Commits on Oct 19, 2021

MINOR: Make TestUtils usable for KRaft mode (apache#11410 )
cmccabe
committedOct 19, 2021

Commits on Oct 18, 2021

KAFKA-10539: Convert KStreamImpl joins to new PAPI (apache#11356 )
jeqo
committedOct 18, 2021
MINOR: "partition" typos and method doc arg fix (apache#11298 )
lbradstreet
committedOct 18, 2021
MINOR: Fix redundant static modifier for enum (apache#11282 )

il-kyun
and
ik.lim
committedOct 18, 2021
MINOR: Fix typo in README.md (apache#11407 )
fishmandev
committedOct 18, 2021
KAFKA-13284: Use sftp to upload artifacts in release.py (apache#11394 )
mimaison
committedOct 18, 2021

Commits on Oct 15, 2021

Commits on Oct 13, 2021

MINOR: The message of BufferExhaustedException should include pool status (apache#11378 )
chia7712
committedOct 13, 2021
MINOR: Fix highest offset when loading KRaft metadata snapshots (apache#11386 )
jsancio
committedOct 13, 2021

Commits on Oct 12, 2021

Commits on Oct 11, 2021

KAFKA-12802 Added a file based cache for consumed remote log metadata for each partition to avoid consuming again incase of broker restarts. (apache#11058 )
satishd
committedOct 11, 2021