urbandan closed pull request #8957:
URL: https://github.com/apache/kafka/pull/8957
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
urbandan opened a new pull request #9430:
URL: https://github.com/apache/kafka/pull/9430
Implements KIP-635
Changes:
Added kafka-get-offsets.sh script
Removed deprecated max-wait-ms and offsets arguments
Updated tool to query all topic-partitions by default
[
https://issues.apache.org/jira/browse/KAFKA-10597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sayed Mohammad Hossein Torabi resolved KAFKA-10597.
---
Resolution: Fixed
> Still dealing issue with KAFKA-9066
> --
splett2 commented on pull request #9386:
URL: https://github.com/apache/kafka/pull/9386#issuecomment-708179919
@dajac
I updated the PR to address some of your comments. Let me know what you
think, thanks!
This is an auto
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.
T
[
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 ApiVersionsRespons
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 Interr
[
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&focusedCommentId=17213608#comment-17213608
]
Matthias J. Sax commented on KAFKA-10608:
-
In general, this is a know issue, but
[
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&focusedCommentId=17213606#comment-17213606
]
Matthias J. Sax commented on KAFKA-10417:
-
Just want to point out, that we recen
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
Issue
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. Than
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 log
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 G
[
https://issues.apache.org/jira/browse/KAFKA-10417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17213535#comment-17213535
]
John Roesler commented on KAFKA-10417:
--
Hi [~duvholt] ,
Thanks for sharing that. I
[
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
> s
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 i
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,
truncati
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) under
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 ja
[
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 reassignmen
[
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 par
[
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 partition
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() {
@O
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: Improveme
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() {
@O
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 testMoveToEnd
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 t
[
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
[
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 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 the
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 Sof
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_r504286524
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/EnvelopeRequest.java
##
@@ -0,0 +1,103 @@
+/*
+ * Licensed to the Apache Software Fo
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) u
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 t
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
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
[
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-
[
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-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 ReassignPartitionsIntegration
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,
metric
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
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
[
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&focusedCommentId=17213332#comment-17213332
]
Oleg Osipov commented on KAFKA-10582:
-
Which cluster do you specify to run MM2? Is i
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
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 #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
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
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
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
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 toStrin
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
[
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
[
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&focusedCommentId=17213303#comment-17213303
]
Matthias J. Sax commented on KAFKA-10604:
-
Not sure if we need a KIP. Our focus
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
- [ ] Ve
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 one
[
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 co
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
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
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
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) 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
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_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 Se
1 - 100 of 133 matches
Mail list logo
