Yash Mayya created KAFKA-15216:
--
Summary: InternalSinkRecord::newRecord method ignores the headers
argument
Key: KAFKA-15216
URL: https://issues.apache.org/jira/browse/KAFKA-15216
Project: Kafka
DL1231 commented on PR #14042:
URL: https://github.com/apache/kafka/pull/14042#issuecomment-1641493151
@divijvaidya I apologize for the interruption, but I tried to write unit
tests to cover this scenario, but it failed. Do you have any suggestions?
--
This is an automated message from th
hudeqi opened a new pull request, #14043:
URL: https://github.com/apache/kafka/pull/14043
This pr is used to remove the metrics in network package(`SocketServer`,
`RequestChannel`, `Acceptor`) when broker shutdown.
This pr has passed the corresponding unit test, and it is part of
[KAFKA-
DL1231 opened a new pull request, #14042:
URL: https://github.com/apache/kafka/pull/14042
https://issues.apache.org/jira/browse/KAFKA-15205
Catch InterruptedException when calling ShutDownableThread#awaitShutdown()
### Committer Checklist (excluded from commit message)
- [ ] Veri
[
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 compressio
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 com
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 specif
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 speci
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
updateStaticMem
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
updateStaticMem
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 G
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
updateStaticMem
[
https://issues.apache.org/jira/browse/KAFKA-15194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17744384#comment-17744384
]
Lan Ding commented on KAFKA-15194:
--
[~divijvaidya] Sorry, just saw the message, [~owen-
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 shoul
[
https://issues.apache.org/jira/browse/KAFKA-15205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17744377#comment-17744377
]
Ismael Juma commented on KAFKA-15205:
-
Have you seen this behavior in practice? We s
[
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
> URL
[
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 OffsetOutOfRange
[
https://issues.apache.org/jira/browse/KAFKA-15000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17744366#comment-17744366
]
Said BOUDJELDA commented on KAFKA-15000:
I can take this Jira
> High vulnerab
[
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 jackson-co
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 autom
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 t
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: jira-unsubscr...@kafka.apache.or
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() {
}
publi
[
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 time.m
[
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 handleLoadSnapshot
[
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: jira-unsubscr...@kafka.apache
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 a
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 a
[
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:
> org.apache.kafka.connect.integration.ConnectWorker
[
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
> connect.integration.InternalTopicsIntegrationTest.tes
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 to
[
https://issues.apache.org/jira/browse/KAFKA-15214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17744347#comment-17744347
]
Lixin Yao commented on KAFKA-15214:
---
Here is one of the example scenarios motivates me
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 time.m
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 time.m
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).
s
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).
s
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
_raftManager.startup()
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 {
b
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 Bootstrap
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 ClassLoa
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, Sc
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 ClassLoader
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 ClassLoader
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 ClassLoader
[
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&focusedCommentId=17744337#comment-17744337
]
Chris Egerton commented on KAFKA-14669:
---
Reopening and marking as a blocker with f
[
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 apprec
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 fr
[
https://issues.apache.org/jira/browse/KAFKA-15214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17744334#comment-17744334
]
Divij Vaidya commented on KAFKA-15214:
--
Hi Lixin
Can you help us understand more ab
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 the
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 me
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 upda
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 N
[
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
OffsetOutOfRangeExcept
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
- [ ] Ve
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
-distributionSha256Sum=5625a0ae20fe00
[
https://issues.apache.org/jira/browse/KAFKA-15190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17744288#comment-17744288
]
Matthias J. Sax edited comment on KAFKA-15190 at 7/18/23 6:22 PM:
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.
### Committer
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 ReentrantLoc
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 epo
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 cur
[
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 Typ
[
https://issues.apache.org/jira/browse/KAFKA-8466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17744315#comment-17744315
]
Divij Vaidya commented on KAFKA-8466:
-
Based on the comment above marking as Unassign
[
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 repl
[
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 unn
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
Reporte
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 incorrect
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
-distributionSha256Sum=5625a0ae20
[
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 Interrupted
[
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 r
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 t
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 ClassLoa
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 m
[
https://issues.apache.org/jira/browse/KAFKA-10775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17744305#comment-17744305
]
Piotr Zygielo commented on KAFKA-10775:
---
May I ask to have it closed, please?
I c
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 ClassLoa
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 m
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 mor
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 ClassLoa
[
https://issues.apache.org/jira/browse/KAFKA-15207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17744300#comment-17744300
]
Justine Olshan commented on KAFKA-15207:
It's a bit tricky to know when we are r
1 - 100 of 227 matches
Mail list logo
