ijuma opened a new pull request, #13007:
URL: https://github.com/apache/kafka/pull/13007
Follows #12996 and hence draft until that is merged.
For broader context on this change, please check:
* KAFKA-14470: Move log layer to storage module
### Committer Checklist (exclude
satishd commented on PR #11390:
URL: https://github.com/apache/kafka/pull/11390#issuecomment-1356256797
Thanks @junrao for the review, addressed it with the latest commit.
There are a few tests that are failed but they does not seem to be related
to this PR.
--
This is an automat
dajac commented on PR #12065:
URL: https://github.com/apache/kafka/pull/12065#issuecomment-1356293104
@dengziming Are you interested in doing a KIP for this?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
Waleed Fateem created KAFKA-14520:
-
Summary: TimeoutException Raised by KafkaConsumer Leads to: User
provided listener
org.apache.kafka.connect.runtime.WorkerSinkTask$HandleRebalance failed on
invocation of onPartitionsAssigned
[
https://issues.apache.org/jira/browse/KAFKA-14520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Waleed Fateem updated KAFKA-14520:
--
Description:
I'm on the fence on whether or not this should actually be considered a bug,
but
junrao merged PR #11390:
URL: https://github.com/apache/kafka/pull/11390
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.o
[
https://issues.apache.org/jira/browse/KAFKA-13369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-13369.
-
Fix Version/s: 3.5.0
Resolution: Fixed
merged the PR to trunk.
> Follower fetch protocol enhance
ijuma commented on code in PR #12993:
URL: https://github.com/apache/kafka/pull/12993#discussion_r1051437482
##
storage/src/main/java/org/apache/kafka/server/log/internals/IndexEntry.java:
##
@@ -14,7 +14,9 @@
* See the License for the specific language governing permissions a
ijuma commented on code in PR #12993:
URL: https://github.com/apache/kafka/pull/12993#discussion_r1051437571
##
storage/src/main/java/org/apache/kafka/server/log/internals/OffsetPosition.java:
##
@@ -0,0 +1,70 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
ijuma commented on PR #12993:
URL: https://github.com/apache/kafka/pull/12993#issuecomment-1356357601
JDK 8 build passed while there was 1 unrelated failure for the each of the
other JDKs:
> Build / JDK 11 and Scala 2.13 /
testBumpTransactionalEpoch(String).quorum=kraft – kafka.api.T
ijuma merged PR #12993:
URL: https://github.com/apache/kafka/pull/12993
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.or
[
https://issues.apache.org/jira/browse/KAFKA-14471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-14471:
Reviewer: Deng Ziming
> Move IndexEntry and related to storage module
> --
ijuma opened a new pull request, #13008:
URL: https://github.com/apache/kafka/pull/13008
and that resulted in compiler errors that weren't present when each change
was on top of trunk.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
ijuma merged PR #13006:
URL: https://github.com/apache/kafka/pull/13006
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.or
ijuma commented on code in PR #11390:
URL: https://github.com/apache/kafka/pull/11390#discussion_r1051439769
##
clients/src/main/java/org/apache/kafka/common/utils/ChildFirstClassLoader.java:
##
@@ -0,0 +1,131 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
ijuma commented on PR #12996:
URL: https://github.com/apache/kafka/pull/12996#issuecomment-1356377352
@junrao Would you be able to review this PR?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to
[
https://issues.apache.org/jira/browse/KAFKA-14473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-14473:
Fix Version/s: 3.5.0
> Move AbstractIndex to storage module
>
[
https://issues.apache.org/jira/browse/KAFKA-14474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-14474:
Fix Version/s: 3.5.0
> Move OffsetIndex to storage module
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-14477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-14477:
Fix Version/s: 3.5.0
> Move LogValidator to storage module
> ---
>
[
https://issues.apache.org/jira/browse/KAFKA-14475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-14475:
Fix Version/s: 3.5.0
> Move TimestampIndex/LazyIndex to storage module
> -
[
https://issues.apache.org/jira/browse/KAFKA-14472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-14472:
Fix Version/s: 3.5.0
> Move TransactionIndex and related to storage module
> -
ijuma opened a new pull request, #13009:
URL: https://github.com/apache/kafka/pull/13009
Follows #13007 and hence why it's still a draft.
For broader context on this change, please check:
* KAFKA-14470: Move log layer to storage module
### Committer Checklist (excluded fr
[
https://issues.apache.org/jira/browse/KAFKA-14475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-14475:
Summary: Move TimeIndex/LazyIndex to storage module (was: Move
TimestampIndex/LazyIndex to storag
ijuma opened a new pull request, #13010:
URL: https://github.com/apache/kafka/pull/13010
Follows #13009 and hence why it's still a draft.
For broader context on this change, please check:
* KAFKA-14470: Move log layer to storage module
### Committer Checklist (exclude
ijuma commented on PR #11390:
URL: https://github.com/apache/kafka/pull/11390#issuecomment-1356390240
Hey @satishd, I wanted to let you know about KAFKA-14470 as I think it
affects some of the future KIP-405 PRs. Can we align these efforts so that we
can get to the desired end state faster?
Ismael Juma created KAFKA-14521:
---
Summary: Replace BrokerCompressionCodec with BrokerCompressionType
Key: KAFKA-14521
URL: https://issues.apache.org/jira/browse/KAFKA-14521
Project: Kafka
Issue
Ismael Juma created KAFKA-14522:
---
Summary: Move RemoteIndexCache and
ClassLoaderAwareRemoteStorageManager to the storage module
Key: KAFKA-14522
URL: https://issues.apache.org/jira/browse/KAFKA-14522
Pr
Ismael Juma created KAFKA-14523:
---
Summary: Move RemoteLogManager to the storage module
Key: KAFKA-14523
URL: https://issues.apache.org/jira/browse/KAFKA-14523
Project: Kafka
Issue Type: Sub-tas
[
https://issues.apache.org/jira/browse/KAFKA-14522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-14522:
Summary: Move RemoteIndexCache/ClassLoaderAwareRemoteStorageManager to the
storage module (was: M
[
https://issues.apache.org/jira/browse/KAFKA-14521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-14521:
Fix Version/s: 3.5.0
> Replace BrokerCompressionCodec with BrokerCompressionType
> ---
ijuma opened a new pull request, #13011:
URL: https://github.com/apache/kafka/pull/13011
This is a requirement for:
* KAFKA-14477: Move LogValidator to storage module.
For broader context on this change, please check:
* KAFKA-14470: Move log layer to storage module
###
ijuma commented on code in PR #13011:
URL: https://github.com/apache/kafka/pull/13011#discussion_r1051444671
##
core/src/main/scala/kafka/utils/VerifiableProperties.scala:
##
@@ -204,24 +203,6 @@ class VerifiableProperties(val props: Properties) extends
Logging {
}
}
ijuma commented on code in PR #13011:
URL: https://github.com/apache/kafka/pull/13011#discussion_r1051444671
##
core/src/main/scala/kafka/utils/VerifiableProperties.scala:
##
@@ -204,24 +203,6 @@ class VerifiableProperties(val props: Properties) extends
Logging {
}
}
ijuma commented on PR #13011:
URL: https://github.com/apache/kafka/pull/13011#issuecomment-1356397544
Another one for your queue if you have the cycles.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to
mimaison merged PR #13008:
URL: https://github.com/apache/kafka/pull/13008
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache
ijuma commented on PR #13008:
URL: https://github.com/apache/kafka/pull/13008#issuecomment-1356439592
Thanks for the quick review.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific com
[
https://issues.apache.org/jira/browse/KAFKA-14477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-14477:
Summary: Move LogValidator and related to storage module (was: Move
LogValidator to storage modul
ijuma opened a new pull request, #13012:
URL: https://github.com/apache/kafka/pull/13012
Follows #13010 and hence why it's still a draft.
For broader context on this change, please check:
* KAFKA-14470: Move log layer to storage module
### Committer Checklist (excluded fr
Ismael Juma created KAFKA-14524:
---
Summary: Modularize `core` monolith
Key: KAFKA-14524
URL: https://issues.apache.org/jira/browse/KAFKA-14524
Project: Kafka
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/KAFKA-14524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-14524:
Description:
The `core` module has grown too large and it's time to split it into multiple
module
Ismael Juma created KAFKA-14525:
---
Summary: Move CLI tools from `core` to `tools` module
Key: KAFKA-14525
URL: https://issues.apache.org/jira/browse/KAFKA-14525
Project: Kafka
Issue Type: Improv
[
https://issues.apache.org/jira/browse/KAFKA-14524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-14524:
Description:
The `core` module has grown too large and it's time to split it into multiple
module
ijuma commented on PR #12951:
URL: https://github.com/apache/kafka/pull/12951#issuecomment-1356479283
By the way, I filed https://issues.apache.org/jira/browse/KAFKA-14525 for
moving other cli tools to the `tools` module.
--
This is an automated message from the Apache Git Service.
To res
Ismael Juma created KAFKA-14526:
---
Summary: Move `kafka.network` from `core` to separate module
Key: KAFKA-14526
URL: https://issues.apache.org/jira/browse/KAFKA-14526
Project: Kafka
Issue Type:
Ismael Juma created KAFKA-14527:
---
Summary: Move `kafka.security` to separate module
Key: KAFKA-14527
URL: https://issues.apache.org/jira/browse/KAFKA-14527
Project: Kafka
Issue Type: Improvemen
[
https://issues.apache.org/jira/browse/KAFKA-14527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-14527:
Summary: Move `kafka.security` from `core` to separate module (was: Move
`kafka.security` to sepa
[
https://issues.apache.org/jira/browse/KAFKA-14527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-14527:
Description:
A possible module name would be `server-security`.
See KAFKA-14524 for more context.
Ismael Juma created KAFKA-14528:
---
Summary: Move replication code from `core` to separate module
Key: KAFKA-14528
URL: https://issues.apache.org/jira/browse/KAFKA-14528
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-14524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-14524:
Description:
The `core` module has grown too large and it's time to split it into multiple
module
ijuma commented on code in PR #13011:
URL: https://github.com/apache/kafka/pull/13011#discussion_r1051500260
##
core/src/main/scala/kafka/server/KafkaConfig.scala:
##
@@ -2138,8 +2138,6 @@ class KafkaConfig private(doLog: Boolean, val props:
java.util.Map[_, _], dynami
"
[
https://issues.apache.org/jira/browse/KAFKA-14523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana reassigned KAFKA-14523:
--
Assignee: Satish Duggana
> Move RemoteLogManager to the storage module
>
[
https://issues.apache.org/jira/browse/KAFKA-14522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana reassigned KAFKA-14522:
--
Assignee: Satish Duggana
> Move RemoteIndexCache/ClassLoaderAwareRemoteStorageManager
[
https://issues.apache.org/jira/browse/KAFKA-14522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-14522:
---
Summary: Move RemoteIndexCache to the storage module (was: Move
RemoteIndexCache/ClassLoade
[
https://issues.apache.org/jira/browse/KAFKA-14522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17648954#comment-17648954
]
Satish Duggana commented on KAFKA-14522:
https://issues.apache.org/jira/browse/K
satishd opened a new pull request, #13013:
URL: https://github.com/apache/kafka/pull/13013
*KAFKA-14466 Move `ClassloaderAwareRemoteStorageManager` to storage module
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test c
satishd commented on PR #13013:
URL: https://github.com/apache/kafka/pull/13013#issuecomment-1356626291
@junrao Please review when you get a chance.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
[
https://issues.apache.org/jira/browse/KAFKA-14480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana reassigned KAFKA-14480:
--
Assignee: Satish Duggana
> Move ProducerStateManager to storage module
>
[
https://issues.apache.org/jira/browse/KAFKA-14481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana reassigned KAFKA-14481:
--
Assignee: Satish Duggana
> Move LogSegment/LogSegments to storage module
> --
ijuma commented on code in PR #13013:
URL: https://github.com/apache/kafka/pull/13013#discussion_r1051520754
##
storage/src/main/java/org/apache/kafka/server/log/remote/storage/ClassLoaderAwareRemoteStorageManager.java:
##
@@ -0,0 +1,104 @@
+/*
+ * Licensed to the Apache Softwar
ijuma commented on code in PR #13013:
URL: https://github.com/apache/kafka/pull/13013#discussion_r1051520754
##
storage/src/main/java/org/apache/kafka/server/log/remote/storage/ClassLoaderAwareRemoteStorageManager.java:
##
@@ -0,0 +1,104 @@
+/*
+ * Licensed to the Apache Softwar
ijuma commented on code in PR #13013:
URL: https://github.com/apache/kafka/pull/13013#discussion_r1051520754
##
storage/src/main/java/org/apache/kafka/server/log/remote/storage/ClassLoaderAwareRemoteStorageManager.java:
##
@@ -0,0 +1,104 @@
+/*
+ * Licensed to the Apache Softwar
61 matches
Mail list logo
