Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
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
128 changes: 127 additions & 1 deletion build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -775,6 +775,7 @@ project(':core') {

implementation project(':metadata')
implementation project(':raft')
implementation project(':storage')

implementation libs.argparse4j
implementation libs.jacksonDatabind
Expand Down Expand Up @@ -992,6 +993,10 @@ project(':core') {
from(project(':connect:mirror').configurations.runtimeClasspath) { into("libs/") }
from(project(':connect:mirror-client').jar) { into("libs/") }
from(project(':connect:mirror-client').configurations.runtimeClasspath) { into("libs/") }
from(project(':storage').jar) { into("libs/") }
from(project(':storage').configurations.runtimeClasspath) { into("libs/") }
from(project(':storage:api').jar) { into("libs/") }
from(project(':storage:api').configurations.runtimeClasspath) { into("libs/") }
from(project(':streams').jar) { into("libs/") }
from(project(':streams').configurations.runtimeClasspath) { into("libs/") }
from(project(':streams:streams-scala').jar) { into("libs/") }
Expand Down Expand Up @@ -1245,7 +1250,6 @@ project(':clients') {
include "**/org/apache/kafka/server/authorizer/*"
include "**/org/apache/kafka/server/policy/*"
include "**/org/apache/kafka/server/quota/*"
include "**/org/apache/kafka/server/log/remote/storage/*"
}
}

Expand Down Expand Up @@ -1331,6 +1335,128 @@ project(':raft') {
}
}

project(':storage:api') {
archivesBaseName = "kafka-storage-api"

dependencies {
implementation project(':clients')
implementation libs.slf4jApi

testImplementation project(':clients')
testImplementation project(':clients').sourceSets.test.output
testImplementation libs.junitJupiter
testImplementation libs.mockitoCore

testRuntime libs.slf4jlog4j
}

task createVersionFile(dependsOn: determineCommitId) {
ext.receiptFile = file("$buildDir/kafka/$buildVersionFileName")
outputs.file receiptFile
outputs.upToDateWhen { false }
doLast {
def data = [
commitId: commitId,
version: version,
]

receiptFile.parentFile.mkdirs()
def content = data.entrySet().collect { "$it.key=$it.value" }.sort().join("\n")
receiptFile.setText(content, "ISO-8859-1")
}
}

sourceSets {
main {
java {
srcDirs = ["src/main/java"]
}
}
test {
java {
srcDirs = ["src/test/java"]
}
}
}

jar {
dependsOn createVersionFile
from("$buildDir") {
include "kafka/$buildVersionFileName"
}
}

clean.doFirst {
delete "$buildDir/kafka/"
}

javadoc {
include "**/org/apache/kafka/server/log/remote/storage/*"
}
}

project(':storage') {
archivesBaseName = "kafka-storage"

dependencies {
implementation project(':storage:api')
implementation project(':clients')
implementation libs.slf4jApi
implementation libs.jacksonDatabind

testImplementation project(':clients')
testImplementation project(':clients').sourceSets.test.output
testImplementation libs.junitJupiter
testImplementation libs.mockitoCore

testRuntime libs.slf4jlog4j
}

task createVersionFile(dependsOn: determineCommitId) {
ext.receiptFile = file("$buildDir/kafka/$buildVersionFileName")
outputs.file receiptFile
outputs.upToDateWhen { false }
doLast {
def data = [
commitId: commitId,
version: version,
]

receiptFile.parentFile.mkdirs()
def content = data.entrySet().collect { "$it.key=$it.value" }.sort().join("\n")
receiptFile.setText(content, "ISO-8859-1")
}
}

sourceSets {
main {
java {
srcDirs = ["src/main/java"]
}
}
test {
java {
srcDirs = ["src/test/java"]
}
}
}

jar {
dependsOn createVersionFile
from("$buildDir") {
include "kafka/$buildVersionFileName"
}
}

clean.doFirst {
delete "$buildDir/kafka/"
}

javadoc {
enabled = false
}
}

project(':tools') {
archivesBaseName = "kafka-tools"

Expand Down
2 changes: 2 additions & 0 deletions settings.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,8 @@ include 'clients',
'metadata',
'raft',
'shell',
'storage',
'storage:api',
'streams',
'streams:examples',
'streams:streams-scala',
Expand Down