Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
60 commits
Select commit Hold shift + click to select a range
cfb6006
MINOR: Fix null exception in coordinator log (#10250)
dengziming Mar 3, 2021
b77deec
KAFKA-12400: Upgrade jetty to fix CVE-2020-27223
dongjinleekr Mar 3, 2021
0d9a95a
KAFKA-9548 Added SPIs and public classes/interfaces introduced in KIP…
satishd Mar 3, 2021
f692963
KAFKA-12284: Wait for mirrored topics to be created (#10185)
showuon Mar 3, 2021
f40a82e
KAFKA-10759 Add ARM build stage (#9992)
mumrah Mar 3, 2021
f06a47a
KAFKA-12170: Fix for Connect Cast SMT to correctly transform a Byte a…
sknop Mar 3, 2021
3ef39e1
MINOR; Clean up LeaderAndIsrResponse construction in `ReplicaManager#…
dajac Mar 4, 2021
8205051
MINOR: remove FetchResponse.AbortedTransaction and redundant construc…
chia7712 Mar 4, 2021
ea005cc
KAFKA-12407: Document Controller Health Metrics (#10257)
dongjinleekr Mar 4, 2021
1fd75bf
KAFKA-12393: Document multi-tenancy considerations (#334) (#10263)
miguno Mar 4, 2021
be14768
MINOR: make sure all generated data tests cover all versions (#10078)
chia7712 Mar 4, 2021
96a2b7a
KAFKA-12376: Apply atomic append to the log (#10253)
jsancio Mar 4, 2021
7a3ebbe
KAFKA-12415 Prepare for Gradle 7.0 and restrict transitive scope for …
ijuma Mar 4, 2021
eebc6f2
MINOR: Enable topic deletion in the KIP-500 controller (#10184)
cmccabe Mar 4, 2021
60a097a
HOTFIX: Controller topic deletion should be atomic (#10264)
hachikuji Mar 4, 2021
83c6839
Remove ReassigningPartitions metric when shutting down ReplicaManager…
dongjinleekr Mar 4, 2021
0685b9d
MINOR: Raft max batch size needs to propagate to log config (#10256)
hachikuji Mar 4, 2021
5c22e03
MINOR: add missing docs for record-e2e-latency metrics (#10251)
ableegoldman Mar 4, 2021
728be21
MINOR: Update log level in SaslServerAuthenticator (#10270)
omkreddy Mar 5, 2021
207bb08
KAFKA-12347: updating TaskMetadata (#10211)
wcarlson5 Mar 5, 2021
17851da
KAFKA-12381: remove live broker checks for forwarding topic creation …
Mar 5, 2021
cf329cb
MINOR: add missing space to errro message when setting uint16 (#10274)
chia7712 Mar 8, 2021
31a121c
KAFKA-12403; Ensure local state deleted on `RemoveTopicRecord` receiv…
hachikuji Mar 8, 2021
6b432e4
MINOR: Refer users to `kafka-storage.sh` if `meta.properties` is miss…
hachikuji Mar 8, 2021
a1fb80f
MINOR: Add missing log argument (#10262)
tombentley Mar 9, 2021
1c3a139
MINOR: Include number of members in group coordinator messages (#10273)
ijuma Mar 9, 2021
0e8a84e
MINOR: Various javadoc fixes (#10272)
ijuma Mar 9, 2021
8d6ae33
KAFKA-10192: Increase max time to wait for worker to start in some in…
showuon Mar 9, 2021
0fc5365
MINOR: fix failing system test delegation_token_test (#10237)
rondagostino Mar 9, 2021
b92d606
MINOR: disable round_trip_fault_test system tests for Raft quorums (#…
rondagostino Mar 9, 2021
e6f8f5d
MINOR: Remove unused variables, methods, parameters, unthrown excepti…
dongjinleekr Mar 10, 2021
8c9bc9c
MINOR: Add entityType for metadata record definitions (#10116)
dengziming Mar 10, 2021
029f5a1
KAFKA-10062: Add a methods to retrieve the current timestamps as know…
rohitrmd Mar 10, 2021
50518fa
KAFKA-12441: remove deprecated method StreamsBuilder#addGlobalStore (…
mjsax Mar 11, 2021
c534bf4
KAFKA-12287: Add WARN logging on consumer-groups when reset-offsets b…
jeqo Mar 11, 2021
800d9b5
KAFKA-10357: Add validation method for internal topics (#10266)
cadonna Mar 11, 2021
0e5591b
KAFKA-12205; Delete snapshots less than the snapshot at the log start…
dengziming Mar 11, 2021
15620ae
MINOR: socket setup max should be 30 seconds #10306 (#10306)
cmccabe Mar 11, 2021
1f9c9f8
KAFKA-12442: Upgrade ZSTD JNI from 1.4.8-4 to 1.4.9-1 (#10285)
dongjoon-hyun Mar 12, 2021
0dbafce
MINOR: Add missing unit tests for Mirror Connect (#10192)
bmaidics Mar 12, 2021
4e60ad7
MINOR: Improve error message in MirrorConnectorsIntegrationBaseTest (…
showuon Mar 12, 2021
b519117
KAFKA-10357: Add missing repartition topic validation (#10305)
cadonna Mar 12, 2021
19e5918
MINOR: Log project, gradle, java and scala versions at the start of t…
ijuma Mar 12, 2021
c6a0f76
KAFKA-12460; Do not allow raft truncation below high watermark (#10310)
hachikuji Mar 13, 2021
4fe4cdc
KAFKA-12462: proceed with task revocation in case of thread in PENDIN…
ableegoldman Mar 13, 2021
2114eb7
MINOR: Remove redundant inheritance from FilteringJmxReporter #onMetr…
UnityLung Mar 13, 2021
9edc828
KAFKA-12398: Fix flaky test `ConsumerBounceTest.testClose` (#10243)
dengziming Mar 13, 2021
08a4ce4
MINOR: Update year in NOTICE (#10308)
mimaison Mar 15, 2021
802ee10
KAFKA-10348: Share client channel between forwarding and auto creatio…
Mar 15, 2021
2387d19
KAFKA-12352: Make sure all rejoin group and reset state has a reason …
guozhangwang Mar 15, 2021
8da6593
revert stream logging level back to ERROR (#10320)
Mar 15, 2021
336d26a
HOTFIX: timeout issue in removeStreamThread() (#10321)
wcarlson5 Mar 16, 2021
eee0045
MINOR; Various code cleanups (#10319)
dajac Mar 16, 2021
bf63990
KAFKA-12427: Don't update connection idle time for muted connections …
splett2 Mar 16, 2021
d80a87f
KAFKA-12330; FetchSessionCache may cause starvation for partitions wh…
dajac Mar 16, 2021
36c5ad4
MINOR: Add toString to various Kafka Metrics classes (#10330)
ijuma Mar 16, 2021
b96fc78
KAFKA-12455: Fix OffsetValidationTest.test_broker_rolling_bounce fail…
rondagostino Mar 16, 2021
0fb0440
MINOR: remove some specifying types in tool command (#10329)
wenbingshen Mar 17, 2021
28ee656
MINOR: Remove redundant allows in import-control.xml (#10339)
dongjinleekr Mar 17, 2021
bea34ef
CONFLUENT: Sync from apache/kafka/trunk (17 March 2021)
ijuma Mar 17, 2021
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion Jenkinsfile
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,7 @@ def job = {


stage("Compile and validate") {
sh "./gradlew clean assemble install spotlessScalaCheck checkstyleMain checkstyleTest spotbugsMain " +
sh "./gradlew clean assemble publishToMavenLocal spotlessScalaCheck checkstyleMain checkstyleTest spotbugsMain " +
"--no-daemon --stacktrace -PxmlSpotBugsReport=true"
}

Expand Down
2 changes: 1 addition & 1 deletion NOTICE
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
Apache Kafka
Copyright 2020 The Apache Software Foundation.
Copyright 2021 The Apache Software Foundation.

This product includes software developed at
The Apache Software Foundation (https://www.apache.org/).
Expand Down
16 changes: 12 additions & 4 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -69,10 +69,6 @@ Generate coverage for a single module, i.e.:
### Building a binary release gzipped tar ball ###
./gradlew clean releaseTarGz

The above command will fail if you haven't set up the signing key. To bypass signing the artifact, you can run:

./gradlew clean releaseTarGz -x signArchives

The release file can be found inside `./core/build/distributions/`.

### Building auto generated messages ###
Expand Down Expand Up @@ -125,6 +121,12 @@ build directory (`${project_dir}/bin`) clashes with Kafka's scripts directory an
to avoid known issues with this configuration.

### Publishing the jar for all version of Scala and for all projects to maven ###
The recommended command is:

./gradlewAll publish

For backwards compatibility, the following also works:

./gradlewAll uploadArchives

Please note for this to work you should create/update `${GRADLE_USER_HOME}/gradle.properties` (typically, `~/.gradle/gradle.properties`) and assign the following variables
Expand Down Expand Up @@ -167,6 +169,12 @@ Please note for this to work you should create/update user maven settings (typic


### Installing the jars to the local Maven repository ###
The recommended command is:

./gradlewAll publishToMavenLocal

For backwards compatibility, the following also works:

./gradlewAll install

### Building the test jar ###
Expand Down
Loading