Dongjin Lee created KAFKA-10604:
---
Summary: The StreamsConfig.STATE_DIR_CONFIG's default value does
not reflect the JVM parameter or OS-specific settings
Key: KAFKA-10604
URL: https://issues.apache.org/jira/browse/KA
[
https://issues.apache.org/jira/browse/KAFKA-10604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17212913#comment-17212913
]
Dongjin Lee commented on KAFKA-10604:
-
[~mjsax] Perhaps we need a KIP discussion for
dongjinleekr opened a new pull request #9420:
URL: https://github.com/apache/kafka/pull/9420
Make the default state store directory location to follow OS-specific
temporary directory settings or `java.io.tmpdir` JVM parameter, with
`Utils#getTempDir`.
### Committer Checklist (exclud
[
https://issues.apache.org/jira/browse/KAFKA-10602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tom Bentley reassigned KAFKA-10602:
---
Assignee: Tom Bentley
> DLQ Reporter throws NPE when reporting from different thread
>
dongjinleekr opened a new pull request #9421:
URL: https://github.com/apache/kafka/pull/9421
... with fixing typo, removing redundant method parameters, unused
Throwables, and unused test methods.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and imple
xakassi commented on pull request #9211:
URL: https://github.com/apache/kafka/pull/9211#issuecomment-707596840
Hi @kkonstantine !
Any news about tests? Should I recreate a PR?
This is an automated message from the Apache G
tombentley opened a new pull request #9422:
URL: https://github.com/apache/kafka/pull/9422
ErrantRecordReporter uses a RetryWithToleranceOperator instance, which is
necessarily
stateful, having a ProcessingContext of which there's supposed to be one per
task. That ProcessingContext is
tombentley commented on pull request #9422:
URL: https://github.com/apache/kafka/pull/9422#issuecomment-707621004
@aakashnshah @rhauch @kkonstantine please could one of you review?
This is an automated message from the A
big-andy-coates commented on pull request #9415:
URL: https://github.com/apache/kafka/pull/9415#issuecomment-707622107
@mjsax now targeting trunk
This is an automated message from the Apache Git Service.
To respond to the mes
cadonna commented on a change in pull request #9416:
URL: https://github.com/apache/kafka/pull/9416#discussion_r503732448
##
File path: core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala
##
@@ -917,6 +918,7 @@ class GroupCoordinator(val brokerId: Int,
* @par
marekgregor commented on pull request #4719:
URL: https://github.com/apache/kafka/pull/4719#issuecomment-707766060
Hello @omkreddy issue reapears in the latest version 2.6.0:
javassist-3.22.0-CR2.jar and javassist-3.26.0-GA.jar
-
chia7712 opened a new pull request #9423:
URL: https://github.com/apache/kafka/pull/9423
The following actions results in this issue.
1. handle_1 gets the current log
2. ReplicaAlterLogDirsThread replaces current log by future log
3. handle_1 set the new hw to “current” log but
vvcephei commented on pull request #9270:
URL: https://github.com/apache/kafka/pull/9270#issuecomment-707819376
Hi @feyman2016 and @abbccdda ,
I hope you've both been well. I just wanted to check in on the status of
this PR, since we still have a flaky test failure related to it.
[
https://issues.apache.org/jira/browse/KAFKA-10472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17213182#comment-17213182
]
Huynh Quang Thao commented on KAFKA-10472:
--
Hi [~mjsax],
Thanks for this point
vvcephei commented on a change in pull request #9414:
URL: https://github.com/apache/kafka/pull/9414#discussion_r504054028
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateDirectoryTest.java
##
@@ -602,6 +606,11 @@ public void shouldLogStat
vvcephei commented on pull request #9222:
URL: https://github.com/apache/kafka/pull/9222#issuecomment-707836238
This was superceded by other PRs.
This is an automated message from the Apache Git Service.
To respond to the mes
vvcephei closed pull request #9222:
URL: https://github.com/apache/kafka/pull/9222
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 t
[
https://issues.apache.org/jira/browse/KAFKA-10533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-10533.
-
Resolution: Fixed
> Add log flush semantics to simulation test
> ---
hachikuji merged pull request #9352:
URL: https://github.com/apache/kafka/pull/9352
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
vvcephei commented on a change in pull request #9396:
URL: https://github.com/apache/kafka/pull/9396#discussion_r504073110
##
File path:
streams/test-utils/src/main/java/org/apache/kafka/streams/processor/api/MockProcessorContext.java
##
@@ -0,0 +1,494 @@
+/*
+ * Licensed to t
vvcephei commented on pull request #9396:
URL: https://github.com/apache/kafka/pull/9396#issuecomment-707844037
The test failure was unrelated:
`Build / JDK 11 /
kafka.api.PlaintextAdminIntegrationTest.testAlterReplicaLogDirs`
---
vvcephei merged pull request #9396:
URL: https://github.com/apache/kafka/pull/9396
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 t
lee9210 opened a new pull request #9424:
URL: https://github.com/apache/kafka/pull/9424
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of testing s
lee9210 closed pull request #9424:
URL: https://github.com/apache/kafka/pull/9424
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 th
[
https://issues.apache.org/jira/browse/KAFKA-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10437.
--
Resolution: Fixed
> KIP-478: Implement test-utils changes
> --
[
https://issues.apache.org/jira/browse/KAFKA-10562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10562:
-
Fix Version/s: 2.7.0
> KIP-478: Delegate the store wrappers to the new init method
> ---
[
https://issues.apache.org/jira/browse/KAFKA-10562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10562.
--
Resolution: Fixed
> KIP-478: Delegate the store wrappers to the new init method
>
John Roesler created KAFKA-10605:
Summary: KIP-478: deprecate the replaced Processor API members
Key: KAFKA-10605
URL: https://issues.apache.org/jira/browse/KAFKA-10605
Project: Kafka
Issue T
[
https://issues.apache.org/jira/browse/KAFKA-10605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10605:
-
Component/s: streams
> KIP-478: deprecate the replaced Processor API members
> -
[
https://issues.apache.org/jira/browse/KAFKA-10546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10546:
-
Summary: KIP-478: Deprecate the old PAPI interfaces (was: KIP-478:
Deprecate old PAPI)
> KIP-4
ableegoldman commented on a change in pull request #9383:
URL: https://github.com/apache/kafka/pull/9383#discussion_r504108760
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignorTest.java
##
@@ -483,7 +485,7 @@ public void
ableegoldman commented on a change in pull request #9383:
URL: https://github.com/apache/kafka/pull/9383#discussion_r504110656
##
File path:
streams/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java
##
@@ -158,7 +159,8 @@ public ByteBuffer subscriptionUserDa
vvcephei commented on pull request #9396:
URL: https://github.com/apache/kafka/pull/9396#issuecomment-707874181
Cherry-picked to 2.7 (cc @bbejeck )
This is an automated message from the Apache Git Service.
To respond to the m
[
https://issues.apache.org/jira/browse/KAFKA-10215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10215.
--
Resolution: Fixed
Fixed in the new processor API.
> MockProcessorContext doesn't work with Se
ableegoldman commented on a change in pull request #9383:
URL: https://github.com/apache/kafka/pull/9383#discussion_r504111457
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignorTest.java
##
@@ -483,7 +485,7 @@ public void
kowshik commented on a change in pull request #9409:
URL: https://github.com/apache/kafka/pull/9409#discussion_r504113561
##
File path: core/src/main/scala/kafka/admin/FeatureCommand.scala
##
@@ -0,0 +1,350 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
kowshik commented on a change in pull request #9409:
URL: https://github.com/apache/kafka/pull/9409#discussion_r504116128
##
File path: core/src/main/scala/kafka/admin/FeatureCommand.scala
##
@@ -0,0 +1,350 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
kowshik commented on a change in pull request #9409:
URL: https://github.com/apache/kafka/pull/9409#discussion_r504118029
##
File path: core/src/main/scala/kafka/admin/FeatureCommand.scala
##
@@ -0,0 +1,350 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
kowshik commented on a change in pull request #9409:
URL: https://github.com/apache/kafka/pull/9409#discussion_r504117818
##
File path: core/src/main/scala/kafka/admin/FeatureCommand.scala
##
@@ -0,0 +1,350 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
kowshik commented on a change in pull request #9409:
URL: https://github.com/apache/kafka/pull/9409#discussion_r504118379
##
File path: core/src/main/scala/kafka/admin/FeatureCommand.scala
##
@@ -0,0 +1,350 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
kowshik commented on a change in pull request #9409:
URL: https://github.com/apache/kafka/pull/9409#discussion_r504118829
##
File path: core/src/main/scala/kafka/admin/FeatureCommand.scala
##
@@ -0,0 +1,350 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
kowshik commented on a change in pull request #9409:
URL: https://github.com/apache/kafka/pull/9409#discussion_r504121355
##
File path: core/src/main/scala/kafka/admin/FeatureCommand.scala
##
@@ -0,0 +1,350 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
vvcephei commented on pull request #9338:
URL: https://github.com/apache/kafka/pull/9338#issuecomment-707890589
Thanks for the feedback, @thake . Your perspective makes perfect sense. It
would certainly simplify our internal code, and it would also help to organize
the API a little more. T
kowshik commented on a change in pull request #9409:
URL: https://github.com/apache/kafka/pull/9409#discussion_r504138505
##
File path: core/src/test/scala/unit/kafka/admin/FeatureCommandTest.scala
##
@@ -0,0 +1,245 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) u
kowshik commented on a change in pull request #9409:
URL: https://github.com/apache/kafka/pull/9409#discussion_r504138505
##
File path: core/src/test/scala/unit/kafka/admin/FeatureCommandTest.scala
##
@@ -0,0 +1,245 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) u
kowshik commented on a change in pull request #9409:
URL: https://github.com/apache/kafka/pull/9409#discussion_r504138505
##
File path: core/src/test/scala/unit/kafka/admin/FeatureCommandTest.scala
##
@@ -0,0 +1,245 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) u
kowshik commented on a change in pull request #9409:
URL: https://github.com/apache/kafka/pull/9409#discussion_r504118029
##
File path: core/src/main/scala/kafka/admin/FeatureCommand.scala
##
@@ -0,0 +1,350 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
vvcephei commented on a change in pull request #9384:
URL: https://github.com/apache/kafka/pull/9384#discussion_r504136735
##
File path: streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
##
@@ -900,9 +900,7 @@
// These are not settable in the main Str
thake commented on pull request #9338:
URL: https://github.com/apache/kafka/pull/9338#issuecomment-707906748
Thank you very much for taking so much time to discuss the API change! This
really shows a very good attitude towards new contributers and their feedback.
Your arguments make
thake commented on pull request #9338:
URL: https://github.com/apache/kafka/pull/9338#issuecomment-707907130
The code should now be ready for review.
This is an automated message from the Apache Git Service.
To respond to the
rhauch opened a new pull request #9425:
URL: https://github.com/apache/kafka/pull/9425
By default the `Connector.validate(...)` will only include configuration
values that are defined in the connector's `ConfigDef`, and validation is
handled via `ConfigDef.Validator` objects. However, a co
[
https://issues.apache.org/jira/browse/KAFKA-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-10600:
--
Affects Version/s: 0.11.0.0
1.0.0
1.1.0
abbccdda commented on a change in pull request #9409:
URL: https://github.com/apache/kafka/pull/9409#discussion_r504152360
##
File path: core/src/main/scala/kafka/admin/FeatureCommand.scala
##
@@ -0,0 +1,350 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
mjsax merged pull request #9415:
URL: https://github.com/apache/kafka/pull/9415
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
vvcephei opened a new pull request #9426:
URL: https://github.com/apache/kafka/pull/9426
Fix flaky test by making sure Streams is
running before making assertions about IQ.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Ve
vvcephei commented on pull request #9426:
URL: https://github.com/apache/kafka/pull/9426#issuecomment-707925313
Hey @guozhangwang , I've seen this test fail on a PR branch since we merged
the last change. Can you take a quick look at this?
-
[
https://issues.apache.org/jira/browse/KAFKA-10604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17213303#comment-17213303
]
Matthias J. Sax commented on KAFKA-10604:
-
Not sure if we need a KIP. Our focus
[
https://issues.apache.org/jira/browse/KAFKA-10472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-10472:
---
Assignee: Huynh Quang Thao (was: Kalpitha Karamadi)
> Consider migrating Topology
[
https://issues.apache.org/jira/browse/KAFKA-10472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17213308#comment-17213308
]
Matthias J. Sax commented on KAFKA-10472:
-
Sure. I added you to the list on cont
mjsax commented on pull request #9415:
URL: https://github.com/apache/kafka/pull/9415#issuecomment-707933791
Thanks for the fix @big-andy-coates!
Merged to `trunk` and cherry-picked to `2.7` branch.
This is an automate
mjsax commented on a change in pull request #9384:
URL: https://github.com/apache/kafka/pull/9384#discussion_r504183734
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
##
@@ -192,12 +191,11 @@ public String toStrin
lkokhreidze commented on pull request #9237:
URL: https://github.com/apache/kafka/pull/9237#issuecomment-707945635
Hi @bbejeck @vvcephei
Sorry for pinging again, but can this PR be merged?
Would love to get it live for next releases.
Thansks
--
lkokhreidze edited a comment on pull request #9237:
URL: https://github.com/apache/kafka/pull/9237#issuecomment-707945635
Hi @bbejeck @vvcephei
Sorry for pinging again, but can this PR be merged?
Would love to get it live for next releases.
Thanks
mjsax commented on a change in pull request #9384:
URL: https://github.com/apache/kafka/pull/9384#discussion_r504190638
##
File path: streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
##
@@ -900,9 +900,7 @@
// These are not settable in the main Stream
bbejeck commented on pull request #9237:
URL: https://github.com/apache/kafka/pull/9237#issuecomment-707950572
@lkokhreidze I appreciate your patience. We need to get a green build but
I'm confident we'll get this in.
This i
splett2 commented on a change in pull request #9386:
URL: https://github.com/apache/kafka/pull/9386#discussion_r503665368
##
File path:
core/src/test/scala/integration/kafka/network/DynamicConnectionQuotaTest.scala
##
@@ -240,6 +256,16 @@ class DynamicConnectionQuotaTest exten
gwenshap closed pull request #9367:
URL: https://github.com/apache/kafka/pull/9367
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 t
mjsax commented on pull request #9384:
URL: https://github.com/apache/kafka/pull/9384#issuecomment-707963598
@vvcephei Updated this PR (including PR description).
This is an automated message from the Apache Git Service.
To r
gwenshap closed pull request #9400:
URL: https://github.com/apache/kafka/pull/9400
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 t
[
https://issues.apache.org/jira/browse/KAFKA-10582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17213332#comment-17213332
]
Oleg Osipov commented on KAFKA-10582:
-
Which cluster do you specify to run MM2? Is i
[
https://issues.apache.org/jira/browse/KAFKA-10570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xavier Léauté resolved KAFKA-10570.
---
Fix Version/s: 2.7.0
Resolution: Fixed
> Rename JMXReporter configs for KIP-629
> ---
xvrl opened a new pull request #9427:
URL: https://github.com/apache/kafka/pull/9427
This change backports KAFKA-10571 (#9366) and #9398 to 2.7 for KIP-629
cc @gwenshap
This is an automated message from the Apache Git
xvrl commented on pull request #9403:
URL: https://github.com/apache/kafka/pull/9403#issuecomment-707972896
@rhauch rebased on latest trunk now that #9367 has been merged
This is an automated message from the Apache Git Servi
splett2 commented on a change in pull request #9386:
URL: https://github.com/apache/kafka/pull/9386#discussion_r504219669
##
File path: core/src/main/scala/kafka/network/SocketServer.scala
##
@@ -1371,6 +1492,45 @@ class ConnectionQuotas(config: KafkaConfig, time: Time,
metric
[
https://issues.apache.org/jira/browse/KAFKA-10571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xavier Léauté updated KAFKA-10571:
--
Fix Version/s: 2.7.0
> Replace occurrences of blackout with backoff for KIP-629
>
[
https://issues.apache.org/jira/browse/KAFKA-10201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xavier Léauté updated KAFKA-10201:
--
Fix Version/s: 2.8.0
> Update codebase to use more inclusive terms
> -
hachikuji commented on pull request #9353:
URL: https://github.com/apache/kafka/pull/9353#issuecomment-707980589
@junrao Great catch. I had just assumed the check existed. I updated the
code and added a partial upgrade integration test case.
---
abbccdda commented on a change in pull request #9311:
URL: https://github.com/apache/kafka/pull/9311#discussion_r504225780
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java
##
@@ -1198,18 +1209,22 @@ boolean canBumpEpoch()
junrao commented on a change in pull request #9353:
URL: https://github.com/apache/kafka/pull/9353#discussion_r504239853
##
File path:
core/src/test/scala/integration/kafka/admin/ReassignPartitionsIntegrationTest.scala
##
@@ -60,13 +57,53 @@ class ReassignPartitionsIntegration
[
https://issues.apache.org/jira/browse/KAFKA-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-9126:
---
Labels: needs-kip newbie newbie++ (was: needs-kip)
> Extend `StreamJoined` to allow
[
https://issues.apache.org/jira/browse/KAFKA-10582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17213427#comment-17213427
]
Robert Martin commented on KAFKA-10582:
---
So we have one instance replicating one d
[
https://issues.apache.org/jira/browse/KAFKA-10587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xavier Léauté reassigned KAFKA-10587:
-
Assignee: Xavier Léauté
> Rename kafka-mirror-maker CLI command line arguments for KIP-
vvcephei commented on a change in pull request #9338:
URL: https://github.com/apache/kafka/pull/9338#discussion_r504228659
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java
##
@@ -103,6 +104,13 @@ public void init(final StateS
cmccabe opened a new pull request #9428:
URL: https://github.com/apache/kafka/pull/9428
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
gwenshap closed pull request #9405:
URL: https://github.com/apache/kafka/pull/9405
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 t
Lincong Li created KAFKA-10606:
--
Summary: Auto create non-existent topics when fetching metadata
for all topics
Key: KAFKA-10606
URL: https://issues.apache.org/jira/browse/KAFKA-10606
Project: Kafka
kowshik commented on a change in pull request #9409:
URL: https://github.com/apache/kafka/pull/9409#discussion_r504138505
##
File path: core/src/test/scala/unit/kafka/admin/FeatureCommandTest.scala
##
@@ -0,0 +1,245 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) u
kowshik commented on a change in pull request #9409:
URL: https://github.com/apache/kafka/pull/9409#discussion_r504296681
##
File path: core/src/main/scala/kafka/admin/FeatureCommand.scala
##
@@ -0,0 +1,350 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
hachikuji commented on a change in pull request #9103:
URL: https://github.com/apache/kafka/pull/9103#discussion_r504286524
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/EnvelopeRequest.java
##
@@ -0,0 +1,103 @@
+/*
+ * Licensed to the Apache Software Fo
xvrl opened a new pull request #9429:
URL: https://github.com/apache/kafka/pull/9429
This change implements the KIP-629 changes for mirror maker configuration
with backwards compatibility.
cc @rhauch
This is an automated
hachikuji commented on a change in pull request #9103:
URL: https://github.com/apache/kafka/pull/9103#discussion_r504298663
##
File path:
clients/src/main/java/org/apache/kafka/common/security/auth/KafkaPrincipalSerde.java
##
@@ -0,0 +1,29 @@
+/*
+ * Licensed to the Apache Sof
[
https://issues.apache.org/jira/browse/KAFKA-10572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xavier Léauté reassigned KAFKA-10572:
-
Assignee: Xavier Léauté
> Rename MirrorMaker 2 blacklist configs for KIP-629
>
[
https://issues.apache.org/jira/browse/KAFKA-10201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xavier Léauté updated KAFKA-10201:
--
Fix Version/s: (was: 2.8.0)
> Update codebase to use more inclusive terms
> --
efeg commented on pull request #9397:
URL: https://github.com/apache/kafka/pull/9397#issuecomment-708055229
@tombentley thanks for the feedback!
> @efeg the javadoc for `KafkaAdminClient` says "Users should not refer to
this class directly", so just adding the thread-safety note to
rhauch merged pull request #9403:
URL: https://github.com/apache/kafka/pull/9403
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
[
https://issues.apache.org/jira/browse/KAFKA-10573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-10573:
--
Fix Version/s: 2.8.0
> Rename connect transform configs for KIP-629
>
[
https://issues.apache.org/jira/browse/KAFKA-10573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-10573:
--
Fix Version/s: 2.7.0
> Rename connect transform configs for KIP-629
>
[
https://issues.apache.org/jira/browse/KAFKA-10573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-10573:
--
Labels: needs-kip (was: )
> Rename connect transform configs for KIP-629
> --
[
https://issues.apache.org/jira/browse/KAFKA-10573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-10573:
--
Description: Part of the implementation for
[KIP-629|https://cwiki.apache.org/confluence/displ
[
https://issues.apache.org/jira/browse/KAFKA-10573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch resolved KAFKA-10573.
---
Fix Version/s: (was: 2.8.0)
Reviewer: Randall Hauch
Resolution: Fixed
Me
1 - 100 of 133 matches
Mail list logo
