showuon commented on pull request #9149:
URL: https://github.com/apache/kafka/pull/9149#issuecomment-708170048
@kkonstantine , could you check this PR again? Thanks.
This is an automated message from the Apache Git Service.
[
https://issues.apache.org/jira/browse/KAFKA-9587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis resolved KAFKA-9587.
---
Resolution: Fixed
> Producer configs are omitted in the documentation
>
kkonstantine commented on pull request #8150:
URL: https://github.com/apache/kafka/pull/8150#issuecomment-708166274
Merged to trunk and `2.7` given that this can be considered a doc bugfix.
This is an automated message from
kkonstantine merged pull request #8150:
URL: https://github.com/apache/kafka/pull/8150
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
abbccdda commented on a change in pull request #9103:
URL: https://github.com/apache/kafka/pull/9103#discussion_r504408633
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/ApiVersionsResponse.java
##
@@ -43,15 +43,43 @@
*/
public class
kkonstantine commented on a change in pull request #9407:
URL: https://github.com/apache/kafka/pull/9407#discussion_r504402600
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerTask.java
##
@@ -184,8 +184,7 @@ private void doRun() throws
[
https://issues.apache.org/jira/browse/KAFKA-10608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10608:
Labels: needs-kip (was: )
> Add support for rolling upgrade with topology changes
>
[
https://issues.apache.org/jira/browse/KAFKA-10608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17213608#comment-17213608
]
Matthias J. Sax commented on KAFKA-10608:
-
In general, this is a know issue, but it also depends
[
https://issues.apache.org/jira/browse/KAFKA-10608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10608:
Component/s: streams
> Add support for rolling upgrade with topology changes
>
[
https://issues.apache.org/jira/browse/KAFKA-10417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17213606#comment-17213606
]
Matthias J. Sax commented on KAFKA-10417:
-
Just want to point out, that we recently fixed
Ashish Surana created KAFKA-10608:
-
Summary: Add support for rolling upgrade with topology changes
Key: KAFKA-10608
URL: https://issues.apache.org/jira/browse/KAFKA-10608
Project: Kafka
kkonstantine commented on pull request #9211:
URL: https://github.com/apache/kafka/pull/9211#issuecomment-708140200
Yes, let's open a new one @xakassi
I haven't found an easy way to reconnect an old PR with the build job.
Please link to this PR for the comments from the new one.
dongjinleekr removed a comment on pull request #9413:
URL: https://github.com/apache/kafka/pull/9413#issuecomment-708126266
LGTM.
This is an automated message from the Apache Git Service.
To respond to the message, please
dongjinleekr commented on pull request #9413:
URL: https://github.com/apache/kafka/pull/9413#issuecomment-708126266
LGTM.
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/KAFKA-10417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17213535#comment-17213535
]
John Roesler commented on KAFKA-10417:
--
Hi [~duvholt] ,
Thanks for sharing that. It looks like
[
https://issues.apache.org/jira/browse/KAFKA-10417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10417:
-
Fix Version/s: (was: 2.7.1)
(was: 2.8.0)
2.7.0
>
mjsax commented on pull request #9368:
URL: https://github.com/apache/kafka/pull/9368#issuecomment-708101388
Updates this PR to add the missing test updates. Also rebased and squashed.
Call for review @vvcephei
This
hachikuji commented on a change in pull request #9382:
URL: https://github.com/apache/kafka/pull/9382#discussion_r504331562
##
File path: core/src/main/scala/kafka/server/AbstractFetcherThread.scala
##
@@ -813,8 +852,9 @@ case class OffsetTruncationState(offset: Long,
abbccdda commented on a change in pull request #9103:
URL: https://github.com/apache/kafka/pull/9103#discussion_r504345664
##
File path: clients/src/main/resources/common/message/EnvelopeRequest.json
##
@@ -0,0 +1,33 @@
+// Licensed to the Apache Software Foundation (ASF)
hachikuji commented on a change in pull request #9418:
URL: https://github.com/apache/kafka/pull/9418#discussion_r504344128
##
File path: raft/src/main/java/org/apache/kafka/raft/RaftClient.java
##
@@ -19,33 +19,51 @@
import org.apache.kafka.common.record.Records;
import
[
https://issues.apache.org/jira/browse/KAFKA-10521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-10521:
Affects Version/s: (was: 2.7.0)
> Remove ZK watch for completing partition
[
https://issues.apache.org/jira/browse/KAFKA-10521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson reassigned KAFKA-10521:
---
Assignee: Jason Gustafson (was: David Arthur)
> Remove ZK watch for completing
[
https://issues.apache.org/jira/browse/KAFKA-10521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-10521.
-
Fix Version/s: 2.7.0
Resolution: Fixed
> Remove ZK watch for completing
abbccdda commented on a change in pull request #9103:
URL: https://github.com/apache/kafka/pull/9103#discussion_r504341071
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsResponse.java
##
@@ -70,9 +70,12 @@ public int throttleTimeMs() {
Boyang Chen created KAFKA-10607:
---
Summary: Ensure the error counts contains the NONE
Key: KAFKA-10607
URL: https://issues.apache.org/jira/browse/KAFKA-10607
Project: Kafka
Issue Type:
hachikuji merged pull request #9353:
URL: https://github.com/apache/kafka/pull/9353
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
abbccdda commented on a change in pull request #9103:
URL: https://github.com/apache/kafka/pull/9103#discussion_r504327985
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsResponse.java
##
@@ -70,9 +70,12 @@ public int throttleTimeMs() {
hachikuji commented on a change in pull request #9428:
URL: https://github.com/apache/kafka/pull/9428#discussion_r504306422
##
File path:
clients/src/test/java/org/apache/kafka/common/utils/ImplicitLinkedHashCollectionTest.java
##
@@ -596,4 +598,25 @@ public void
kowshik commented on pull request #9409:
URL: https://github.com/apache/kafka/pull/9409#issuecomment-708070565
> one thing to point out is that we need to look at the KIP-584 definition
for the basic tool usage and make sure the API names are aligned.
This is done now. Please refer
[
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
[
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
[
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:
--
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:
--
Fix Version/s: 2.8.0
> Rename connect transform configs for KIP-629
>
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
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
[
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
>
[
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
>
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
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
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
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
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)
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
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
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
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
[
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
[
https://issues.apache.org/jira/browse/KAFKA-10582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17213427#comment-17213427
]
Robert Martin commented on KAFKA-10582:
---
So we have one instance replicating one direction. Then
[
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
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
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()
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.
[
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
>
[
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
>
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,
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
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
[
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
>
[
https://issues.apache.org/jira/browse/KAFKA-10582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17213332#comment-17213332
]
Oleg Osipov commented on KAFKA-10582:
-
Which cluster do you specify to run MM2? Is it different for
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
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
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
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
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
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
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
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
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
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
[
https://issues.apache.org/jira/browse/KAFKA-10472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17213308#comment-17213308
]
Matthias J. Sax commented on KAFKA-10472:
-
Sure. I added you to the list on contributors and
[
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-10604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17213303#comment-17213303
]
Matthias J. Sax commented on KAFKA-10604:
-
Not sure if we need a KIP. Our focus is on UNIX based
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?
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
- [ ]
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
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
[
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
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
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
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
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
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_r504138505
##
File path: core/src/test/scala/unit/kafka/admin/FeatureCommandTest.scala
##
@@ -0,0 +1,245 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF)
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)
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)
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.
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
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_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_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_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_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_r504113561
##
File path: core/src/main/scala/kafka/admin/FeatureCommand.scala
##
@@ -0,0 +1,350 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
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
[
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
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
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
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
[
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)
>
1 - 100 of 136 matches
Mail list logo
