[
https://issues.apache.org/jira/browse/KAFKA-15160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Phuc Hong Tran reassigned KAFKA-15160:
--
Assignee: Phuc Hong Tran
> Message bytes duplication in Kafka headers when
Phuc-Hong-Tran closed pull request #14026: KAFKA-15152: Fix incorrect format
specifiers when formatting string
URL: https://github.com/apache/kafka/pull/14026
--
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
nizhikov commented on PR #13278:
URL: https://github.com/apache/kafka/pull/13278#issuecomment-1641386848
Tests failures unrelated.
--
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
nizhikov commented on PR #13247:
URL: https://github.com/apache/kafka/pull/13247#issuecomment-1641385324
Tests failures seems unrelated.
--
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
A. Sophie Blee-Goldman created KAFKA-15215:
--
Summary: The default.dsl.store config is not compatible with
custom state stores
Key: KAFKA-15215
URL: https://issues.apache.org/jira/browse/KAFKA-15215
[
https://issues.apache.org/jira/browse/KAFKA-15215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-15215:
---
Labels: needs-kip (was: )
> The default.dsl.store config is not compatible
jeffkbkim commented on PR #13870:
URL: https://github.com/apache/kafka/pull/13870#issuecomment-1641304041
the test failures are unrelated
--
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
jeffkbkim commented on code in PR #14017:
URL: https://github.com/apache/kafka/pull/14017#discussion_r1267462476
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -2643,9 +2652,175 @@ private CoordinatorResult
jeffkbkim commented on code in PR #14017:
URL: https://github.com/apache/kafka/pull/14017#discussion_r1267441961
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -2643,9 +2652,175 @@ private CoordinatorResult
gharris1727 commented on PR #14029:
URL: https://github.com/apache/kafka/pull/14029#issuecomment-1641250195
> Would it be too much to ask to run system tests?
I ran the connect system tests on a spare machine and got 181/181 passing.
--
This is an automated message from the Apache
jeffkbkim commented on code in PR #14017:
URL: https://github.com/apache/kafka/pull/14017#discussion_r1267427788
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -2643,9 +2652,175 @@ private CoordinatorResult
[
https://issues.apache.org/jira/browse/KAFKA-15194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17744384#comment-17744384
]
Lan Ding commented on KAFKA-15194:
--
[~divijvaidya] Sorry, just saw the message, [~owen-leung] has
ijuma commented on PR #13676:
URL: https://github.com/apache/kafka/pull/13676#issuecomment-1641123937
If I'm reading this right, it seems very restrictive. It's very common for
other companies to build AK for their own purposes. If they're not allowed to
use gradle enterprise, then it
[
https://issues.apache.org/jira/browse/KAFKA-15205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17744377#comment-17744377
]
Ismael Juma commented on KAFKA-15205:
-
Have you seen this behavior in practice? We should definitely
[
https://issues.apache.org/jira/browse/KAFKA-10775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sebb closed KAFKA-10775.
> DOAP has incorrect category
> ---
>
> Key: KAFKA-10775
>
[
https://issues.apache.org/jira/browse/KAFKA-15214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lixin Yao updated KAFKA-15214:
--
Parent: KAFKA-7739
Issue Type: Sub-task (was: Improvement)
> Add metrics for
[
https://issues.apache.org/jira/browse/KAFKA-15000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17744366#comment-17744366
]
Said BOUDJELDA commented on KAFKA-15000:
I can take this Jira
> High vulnerability
[
https://issues.apache.org/jira/browse/KAFKA-15000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Said BOUDJELDA reassigned KAFKA-15000:
--
Assignee: Said BOUDJELDA
> High vulnerability PRISMA-2023-0067 reported in
muralibasani commented on PR #13417:
URL: https://github.com/apache/kafka/pull/13417#issuecomment-1641043256
@fvaleri
Managed to remove the core dependency from tools.
If am in the right direction, will add tests, fix conflicts, and several
other minor things.
--
This is an
mjsax commented on PR #14031:
URL: https://github.com/apache/kafka/pull/14031#issuecomment-1641032657
Merged to `trunk` and cherry-picked to `3.5` branch. Will take care to get
the changes into `kafka-site`, too.
--
This is an automated message from the Apache Git Service.
To respond to
mjsax merged PR #14031:
URL: https://github.com/apache/kafka/pull/14031
--
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:
cmccabe commented on code in PR #14010:
URL: https://github.com/apache/kafka/pull/14010#discussion_r1267289475
##
metadata/src/main/java/org/apache/kafka/controller/metrics/QuorumControllerMetrics.java:
##
@@ -176,17 +210,53 @@ public long dualWriteOffset() {
}
[
https://issues.apache.org/jira/browse/KAFKA-15091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-15091:
--
Fix Version/s: 3.3.3
> Javadocs for SourceTask::commit are incorrect
>
cmccabe commented on code in PR #14010:
URL: https://github.com/apache/kafka/pull/14010#discussion_r1267289020
##
metadata/src/main/java/org/apache/kafka/controller/metrics/QuorumControllerMetrics.java:
##
@@ -113,7 +124,30 @@ public Long value() {
return
[
https://issues.apache.org/jira/browse/KAFKA-15091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-15091:
--
Fix Version/s: 3.4.2
> Javadocs for SourceTask::commit are incorrect
>
cmccabe commented on code in PR #14010:
URL: https://github.com/apache/kafka/pull/14010#discussion_r1267287803
##
metadata/src/main/java/org/apache/kafka/image/loader/MetadataLoader.java:
##
@@ -418,24 +415,30 @@ LogDeltaManifest loadLogDelta(
public void
[
https://issues.apache.org/jira/browse/KAFKA-15091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-15091:
--
Fix Version/s: 3.5.2
> Javadocs for SourceTask::commit are incorrect
>
C0urante merged PR #13948:
URL: https://github.com/apache/kafka/pull/13948
--
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:
C0urante commented on code in PR #13948:
URL: https://github.com/apache/kafka/pull/13948#discussion_r1267283474
##
connect/api/src/main/java/org/apache/kafka/connect/source/SourceTask.java:
##
@@ -105,9 +105,11 @@ public void initialize(SourceTaskContext context) {
public
C0urante commented on code in PR #13948:
URL: https://github.com/apache/kafka/pull/13948#discussion_r1267278752
##
connect/api/src/main/java/org/apache/kafka/connect/source/SourceTask.java:
##
@@ -105,9 +105,11 @@ public void initialize(SourceTaskContext context) {
public
[
https://issues.apache.org/jira/browse/KAFKA-12842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris reassigned KAFKA-12842:
---
Assignee: Greg Harris
> Failing test:
>
[
https://issues.apache.org/jira/browse/KAFKA-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris reassigned KAFKA-8690:
--
Assignee: Greg Harris
> Flakey test ConnectWorkerIntegrationTest#testAddAndRemoveWorke
>
[
https://issues.apache.org/jira/browse/KAFKA-10579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris reassigned KAFKA-10579:
---
Assignee: Greg Harris
> Flaky test
>
forlack commented on PR #14031:
URL: https://github.com/apache/kafka/pull/14031#issuecomment-1640948633
I updated the sentence suggested by @ijuma
--
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-15214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17744347#comment-17744347
]
Lixin Yao commented on KAFKA-15214:
---
Here is one of the example scenarios motivates me to create this
cmccabe commented on code in PR #14010:
URL: https://github.com/apache/kafka/pull/14010#discussion_r1267254133
##
metadata/src/main/java/org/apache/kafka/controller/metrics/QuorumControllerMetrics.java:
##
@@ -113,7 +124,30 @@ public Long value() {
return
cmccabe commented on code in PR #14010:
URL: https://github.com/apache/kafka/pull/14010#discussion_r1267253682
##
metadata/src/main/java/org/apache/kafka/controller/metrics/QuorumControllerMetrics.java:
##
@@ -113,7 +124,30 @@ public Long value() {
return
cmccabe commented on code in PR #14010:
URL: https://github.com/apache/kafka/pull/14010#discussion_r1267252934
##
core/src/main/scala/kafka/server/SharedServer.scala:
##
@@ -282,15 +294,15 @@ class SharedServer(
setDisabledReason(snapshotsDisabledReason).
cmccabe commented on code in PR #14010:
URL: https://github.com/apache/kafka/pull/14010#discussion_r1267251882
##
core/src/main/scala/kafka/server/SharedServer.scala:
##
@@ -282,15 +294,15 @@ class SharedServer(
setDisabledReason(snapshotsDisabledReason).
cmccabe commented on code in PR #14010:
URL: https://github.com/apache/kafka/pull/14010#discussion_r1267251209
##
core/src/main/scala/kafka/server/SharedServer.scala:
##
@@ -259,15 +262,24 @@ class SharedServer(
raftManager = _raftManager
cmccabe commented on code in PR #14010:
URL: https://github.com/apache/kafka/pull/14010#discussion_r1267248743
##
metadata/src/test/java/org/apache/kafka/controller/QuorumControllerTest.java:
##
@@ -782,7 +735,7 @@ public void testTimeouts() throws Throwable {
cmccabe commented on code in PR #14010:
URL: https://github.com/apache/kafka/pull/14010#discussion_r1267249264
##
metadata/src/test/java/org/apache/kafka/controller/QuorumControllerTest.java:
##
@@ -140,39 +142,6 @@ public class QuorumControllerTest {
static final
gharris1727 commented on code in PR #13971:
URL: https://github.com/apache/kafka/pull/13971#discussion_r1267248169
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginScanner.java:
##
@@ -118,35 +120,80 @@ private void loadJdbcDrivers(final
cmccabe commented on code in PR #14010:
URL: https://github.com/apache/kafka/pull/14010#discussion_r1267246622
##
metadata/src/test/java/org/apache/kafka/image/loader/metrics/MetadataLoaderMetricsTest.java:
##
@@ -0,0 +1,148 @@
+/*
+ * Licensed to the Apache Software Foundation
C0urante commented on code in PR #14024:
URL: https://github.com/apache/kafka/pull/14024#discussion_r1267245540
##
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java:
##
@@ -65,7 +180,8 @@ public SinkRecord newRecord(String topic, Integer
kafkaPartition,
C0urante commented on code in PR #13971:
URL: https://github.com/apache/kafka/pull/13971#discussion_r1267237169
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginScanner.java:
##
@@ -118,35 +120,80 @@ private void loadJdbcDrivers(final
C0urante commented on code in PR #13971:
URL: https://github.com/apache/kafka/pull/13971#discussion_r1267238592
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginScanner.java:
##
@@ -118,35 +120,80 @@ private void loadJdbcDrivers(final
C0urante commented on code in PR #13971:
URL: https://github.com/apache/kafka/pull/13971#discussion_r1267236920
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginScanner.java:
##
@@ -118,35 +120,80 @@ private void loadJdbcDrivers(final
[
https://issues.apache.org/jira/browse/KAFKA-14669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-14669:
--
Priority: Blocker (was: Major)
> Include MirrorMaker connector configurations in docs
>
[
https://issues.apache.org/jira/browse/KAFKA-14669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17744337#comment-17744337
]
Chris Egerton commented on KAFKA-14669:
---
Reopening and marking as a blocker with fix version 3.6.0
[
https://issues.apache.org/jira/browse/KAFKA-14669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton reopened KAFKA-14669:
---
> Include MirrorMaker connector configurations in docs
>
C0urante commented on PR #14041:
URL: https://github.com/apache/kafka/pull/14041#issuecomment-1640847533
CC @tinaselenge; sorry for missing this during review! Just wanted to give
you a heads-up in case you make or review docs changes in the future.
@gharris1727 @mimaison would
C0urante opened a new pull request, #14041:
URL: https://github.com/apache/kafka/pull/14041
Follow-up for https://github.com/apache/kafka/pull/13658, where we forgot to
update the table of contents to include the new 3.8 section for MirrorMaker 2.
### Committer Checklist (excluded
[
https://issues.apache.org/jira/browse/KAFKA-15214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17744334#comment-17744334
]
Divij Vaidya commented on KAFKA-15214:
--
Hi Lixin
Can you help us understand more about the
bmscomp commented on PR #14032:
URL: https://github.com/apache/kafka/pull/14032#issuecomment-1640794180
@divijvaidya It's a rebase issue, now that I am using the last version of
`.asf.yam` as an issue is fixed before the execution is going on
--
This is an automated message from
divijvaidya commented on PR #14032:
URL: https://github.com/apache/kafka/pull/14032#issuecomment-1640773987
Tests are failing with a related error.
```
* What went wrong:
Gradle could not start your build.
> Cannot create service of type BuildSessionActionExecutor using
stevenbooke commented on PR #13842:
URL: https://github.com/apache/kafka/pull/13842#issuecomment-1640762194
As you have recommended, the script will create a new branch for the
changes, commit the changes to the new branch, and open a pull request with the
updated `.asf.yaml` file. The
Staniel commented on code in PR #13944:
URL: https://github.com/apache/kafka/pull/13944#discussion_r1267173038
##
core/src/main/java/kafka/log/remote/RemoteLogReader.java:
##
@@ -54,10 +60,14 @@ public Void call() {
logger.debug("Reading records from remote storage
stevenbooke commented on code in PR #13842:
URL: https://github.com/apache/kafka/pull/13842#discussion_r1267168635
##
refresh-collaborators.py:
##
@@ -0,0 +1,67 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements. See the
[
https://issues.apache.org/jira/browse/KAFKA-15214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lixin Yao updated KAFKA-15214:
--
Description:
In the current metrics RemoteReadErrorsPerSec, the exception type
tanay27 opened a new pull request, #14040:
URL: https://github.com/apache/kafka/pull/14040
Deleted classgraph MIT result file.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ]
Lixin Yao created KAFKA-15214:
-
Summary: Add metrics for OffsetOutOfRangeException when tiered
storage is enabled
Key: KAFKA-15214
URL: https://issues.apache.org/jira/browse/KAFKA-15214
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-15212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tanay Karmarkar reassigned KAFKA-15212:
---
Assignee: Tanay Karmarkar
> Remove unneeded classgraph license file
>
bmscomp commented on code in PR #14032:
URL: https://github.com/apache/kafka/pull/14032#discussion_r1267159224
##
gradle/wrapper/gradle-wrapper.properties:
##
@@ -1,7 +1,7 @@
distributionBase=GRADLE_USER_HOME
distributionPath=wrapper/dists
[
https://issues.apache.org/jira/browse/KAFKA-15190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17744288#comment-17744288
]
Matthias J. Sax edited comment on KAFKA-15190 at 7/18/23 6:22 PM:
--
One
gharris1727 opened a new pull request, #14039:
URL: https://github.com/apache/kafka/pull/14039
This exception doesn't get thrown by the BouncyCastleProvider's
implementation of HmacSHA256, so simulate the error just in case BouncyCastle
is loaded before the test is run.
###
Staniel commented on code in PR #13944:
URL: https://github.com/apache/kafka/pull/13944#discussion_r1267143752
##
core/src/main/java/kafka/log/remote/RemoteLogReader.java:
##
@@ -54,10 +60,14 @@ public Void call() {
logger.debug("Reading records from remote storage
cmccabe commented on code in PR #13643:
URL: https://github.com/apache/kafka/pull/13643#discussion_r1267142346
##
raft/src/main/java/org/apache/kafka/raft/internals/BatchAccumulator.java:
##
@@ -89,52 +91,12 @@ public BatchAccumulator(
this.appendLock = new
cmccabe commented on code in PR #13643:
URL: https://github.com/apache/kafka/pull/13643#discussion_r1267137597
##
raft/src/main/java/org/apache/kafka/raft/RaftClient.java:
##
@@ -172,15 +176,17 @@ default void beginShutdown() {}
* uncommitted entries after observing an
cmccabe commented on code in PR #13643:
URL: https://github.com/apache/kafka/pull/13643#discussion_r1267130598
##
raft/src/main/java/org/apache/kafka/raft/RaftClient.java:
##
@@ -80,8 +81,11 @@ interface Listener {
* epoch.
*
* @param leader the
[
https://issues.apache.org/jira/browse/KAFKA-8466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-8466:
Labels: newbie (was: )
> Remove 'jackson-module-scala' dependency (and replace it with some code)
Colin McCabe created KAFKA-15213:
Summary: Provide the exact offset to QuorumController.replay
Key: KAFKA-15213
URL: https://issues.apache.org/jira/browse/KAFKA-15213
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-8466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17744315#comment-17744315
]
Divij Vaidya commented on KAFKA-8466:
-
Based on the comment above marking as Unassigned so that
[
https://issues.apache.org/jira/browse/KAFKA-8466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya reassigned KAFKA-8466:
---
Assignee: (was: Dejan Stojadinović)
> Remove 'jackson-module-scala' dependency (and
[
https://issues.apache.org/jira/browse/KAFKA-15000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-15000:
-
Affects Version/s: 3.5.1
> High vulnerability PRISMA-2023-0067 reported in jackson-core
>
[
https://issues.apache.org/jira/browse/KAFKA-15000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-15000:
-
Fix Version/s: 3.6.0
> High vulnerability PRISMA-2023-0067 reported in jackson-core
>
[
https://issues.apache.org/jira/browse/KAFKA-15212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-15212:
-
Summary: Remove unneeded classgraph license file (was: Remove classgraph
license)
> Remove
Divij Vaidya created KAFKA-15212:
Summary: Remove classgraph license
Key: KAFKA-15212
URL: https://issues.apache.org/jira/browse/KAFKA-15212
Project: Kafka
Issue Type: Bug
Greg Harris created KAFKA-15211:
---
Summary: DistributedConfigTest#shouldFailWithInvalidKeySize fails
when run after TestSslUtils#generate
Key: KAFKA-15211
URL: https://issues.apache.org/jira/browse/KAFKA-15211
[
https://issues.apache.org/jira/browse/KAFKA-15208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya reassigned KAFKA-15208:
Assignee: Said BOUDJELDA
> Upgrade Jackson dependencies to version 2.15.2
>
[
https://issues.apache.org/jira/browse/KAFKA-15208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-15208:
-
Fix Version/s: 3.6.0
> Upgrade Jackson dependencies to version 2.15.2
>
[
https://issues.apache.org/jira/browse/KAFKA-10775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison resolved KAFKA-10775.
Fix Version/s: 3.1.0
Assignee: Sebb
Resolution: Fixed
> DOAP has
mimaison commented on PR #11423:
URL: https://github.com/apache/kafka/pull/11423#issuecomment-1640685154
Right, I wasn't aware of the associated ticket. I closed it now. Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
divijvaidya commented on code in PR #14032:
URL: https://github.com/apache/kafka/pull/14032#discussion_r1267117269
##
gradle/wrapper/gradle-wrapper.properties:
##
@@ -1,7 +1,7 @@
distributionBase=GRADLE_USER_HOME
distributionPath=wrapper/dists
[
https://issues.apache.org/jira/browse/KAFKA-15205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tanay Karmarkar reassigned KAFKA-15205:
---
Assignee: (was: Tanay Karmarkar)
> Race condition in ShutdownableThread causes
[
https://issues.apache.org/jira/browse/KAFKA-15205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tanay Karmarkar reassigned KAFKA-15205:
---
Assignee: Tanay Karmarkar
> Race condition in ShutdownableThread causes
[
https://issues.apache.org/jira/browse/KAFKA-15199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tanay Karmarkar reassigned KAFKA-15199:
---
Assignee: Tanay Karmarkar
> remove leading and trailing spaces from user input in
nizhikov commented on PR #13278:
URL: https://github.com/apache/kafka/pull/13278#issuecomment-164085
@mimaison Thanks for the review. It seems I addressed all your comments.
Please, take a look one more time.
--
This is an automated message from the Apache Git Service.
To respond to
gharris1727 commented on code in PR #13971:
URL: https://github.com/apache/kafka/pull/13971#discussion_r1267103768
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginScanner.java:
##
@@ -118,35 +120,80 @@ private void loadJdbcDrivers(final
nizhikov commented on code in PR #13278:
URL: https://github.com/apache/kafka/pull/13278#discussion_r1267096601
##
server-common/src/main/java/org/apache/kafka/server/util/CoreUtils.java:
##
@@ -0,0 +1,48 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
[
https://issues.apache.org/jira/browse/KAFKA-10775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17744305#comment-17744305
]
Piotr Zygielo commented on KAFKA-10775:
---
May I ask to have it closed, please?
I can only clone
gharris1727 commented on code in PR #13971:
URL: https://github.com/apache/kafka/pull/13971#discussion_r1267094589
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginScanner.java:
##
@@ -118,35 +120,80 @@ private void loadJdbcDrivers(final
nizhikov commented on code in PR #13278:
URL: https://github.com/apache/kafka/pull/13278#discussion_r1267093982
##
server-common/src/main/java/org/apache/kafka/server/util/CoreUtils.java:
##
@@ -0,0 +1,48 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
nizhikov commented on code in PR #13278:
URL: https://github.com/apache/kafka/pull/13278#discussion_r1267084525
##
tools/src/main/java/org/apache/kafka/tools/DeleteRecordsCommand.java:
##
@@ -0,0 +1,220 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
gharris1727 commented on code in PR #13971:
URL: https://github.com/apache/kafka/pull/13971#discussion_r1267082036
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginScanner.java:
##
@@ -118,35 +120,80 @@ private void loadJdbcDrivers(final
[
https://issues.apache.org/jira/browse/KAFKA-15207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17744300#comment-17744300
]
Justine Olshan commented on KAFKA-15207:
It's a bit tricky to know when we are receiving a newer
tanay27 commented on code in PR #14035:
URL: https://github.com/apache/kafka/pull/14035#discussion_r1267071244
##
release.py:
##
@@ -692,7 +700,7 @@ def select_gpg_key():
fail("Ok, giving up")
if not user_ok("Ok to push RC tag %s (y/n)?: " % rc_tag):
fail("Ok, giving
jeffkbkim commented on code in PR #13870:
URL: https://github.com/apache/kafka/pull/13870#discussion_r1267070768
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -1245,4 +1422,1304 @@ public static String
Divij Vaidya created KAFKA-15210:
Summary: Mention vote should be open for at atleast 72 hours
Key: KAFKA-15210
URL: https://issues.apache.org/jira/browse/KAFKA-15210
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-15190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17744288#comment-17744288
]
Matthias J. Sax commented on KAFKA-15190:
-
One more thing: the `process.id` is actually only
1 - 100 of 231 matches
Mail list logo
