tombentley commented on pull request #9593:
URL: https://github.com/apache/kafka/pull/9593#issuecomment-739139662
Thanks @rayokota, obvious in hindsight. I've opened
https://github.com/apache/kafka/pull/9701
This is an
tombentley commented on pull request #9701:
URL: https://github.com/apache/kafka/pull/9701#issuecomment-739139614
@mimaison @rayokota please take a look
This is an automated message from the Apache Git Service.
To respond to
tombentley opened a new pull request #9701:
URL: https://github.com/apache/kafka/pull/9701
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
[
https://issues.apache.org/jira/browse/KAFKA-10604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244416#comment-17244416
]
Dongjin Lee commented on KAFKA-10604:
-
ALL // Great. Let's continue the discussion on the PR! :D
>
dongjinleekr commented on pull request #8404:
URL: https://github.com/apache/kafka/pull/8404#issuecomment-739135617
@mjsax And here are some explanation of why I did not adopt any auto-import
reorganization or auto-formatting.
At first, I tried to add some configuration to
dongjinleekr commented on pull request #8404:
URL: https://github.com/apache/kafka/pull/8404#issuecomment-739135487
@mjsax Rebased onto the latest trunk. Since this PR touches so many files,
this PR will be broken every time the latest trunk updates. I will follow up on
the latest trunk
dongjinleekr commented on pull request #9414:
URL: https://github.com/apache/kafka/pull/9414#issuecomment-739132524
Rebased onto the latest trunk.
This is an automated message from the Apache Git Service.
To respond to the
dongjinleekr commented on pull request #7898:
URL: https://github.com/apache/kafka/pull/7898#issuecomment-739132477
Rebased onto the latest trunk.
This is an automated message from the Apache Git Service.
To respond to the
dengziming commented on pull request #9649:
URL: https://github.com/apache/kafka/pull/9649#issuecomment-739116990
@mumrah Hi, this class is created by you so I think you can have a look,
thank you.
This is an automated
ning2008wisc commented on pull request #9224:
URL: https://github.com/apache/kafka/pull/9224#issuecomment-739114982
@rhauch if your pr is merged first, I will be happy to rebase on
https://github.com/apache/kafka/pull/9698
dengziming closed pull request #9664:
URL: https://github.com/apache/kafka/pull/9664
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
chia7712 commented on pull request #9694:
URL: https://github.com/apache/kafka/pull/9694#issuecomment-739113376
@chris8099 Could you rebase code to include
https://github.com/apache/kafka/commit/b9640a71c42ad117ed418209f87dc2962173469d?
[
https://issues.apache.org/jira/browse/KAFKA-10790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244391#comment-17244391
]
Chia-Ping Tsai commented on KAFKA-10790:
[~Geordie] go for it
> Detect/Prevent Deadlock on
abbccdda opened a new pull request #9700:
URL: https://github.com/apache/kafka/pull/9700
We should catch InvalidProducerEpoch and rethrow as TaskMigrated, similar to
ProducerFenced.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
bertber commented on pull request #9699:
URL: https://github.com/apache/kafka/pull/9699#issuecomment-739097621
Hello! I have updated StreamsResetter of class.
I add a description for calling resetToDatetime's function to
resetByDuration and remove unnecessary loop code.
bertber opened a new pull request #9699:
URL: https://github.com/apache/kafka/pull/9699
…setByDuration
Add a request that it will call resetToDatetime of description to
resetByDuration of function.
*More detailed description of your change,
if necessary. The PR title and
[
https://issues.apache.org/jira/browse/KAFKA-10813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-10813:
---
Assignee: Boyang Chen
> StreamsProducer should catch InvalidProducerEpoch and throw
Boyang Chen created KAFKA-10813:
---
Summary: StreamsProducer should catch InvalidProducerEpoch and
throw TaskMigrated in all cases
Key: KAFKA-10813
URL: https://issues.apache.org/jira/browse/KAFKA-10813
wcarlson5 commented on a change in pull request #9697:
URL: https://github.com/apache/kafka/pull/9697#discussion_r536416836
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/StreamsUncaughtExceptionHandlerIntegrationTest.java
##
@@ -145,6 +148,26 @@
C0urante commented on pull request #9698:
URL: https://github.com/apache/kafka/pull/9698#issuecomment-739086987
@rhauch it's not so much about the stack traces in these tests as it is
about them presumably appearing when MM2 is run for real, and being caused by
unclean worker shutdown.
Chris Egerton created KAFKA-10812:
-
Summary: Unclean worker shutdown in MirrorConnectorsIntegrationTest
Key: KAFKA-10812
URL: https://issues.apache.org/jira/browse/KAFKA-10812
Project: Kafka
rhauch commented on pull request #9698:
URL: https://github.com/apache/kafka/pull/9698#issuecomment-739084805
@C0urante is there a KAFKA issue for those stack traces? If not, please
create one.
This is an automated message
C0urante commented on pull request #9698:
URL: https://github.com/apache/kafka/pull/9698#issuecomment-739083240
This is definitely an improvement not only to the flaky MM2 test but to the
integration testing framework in general. ✅
As a follow-up item, could we track the unclean
rhauch commented on pull request #9224:
URL: https://github.com/apache/kafka/pull/9224#issuecomment-739083056
@ning2008wisc, @mimaison: Please see
https://issues.apache.org/jira/browse/KAFKA-10811 and #9698 for a required fix
to the `MirrorConnectorsIntegrationTest` to prevent the
[
https://issues.apache.org/jira/browse/KAFKA-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244361#comment-17244361
]
Randall Hauch commented on KAFKA-9013:
--
See also KAFKA-10811 for when
rhauch commented on pull request #9698:
URL: https://github.com/apache/kafka/pull/9698#issuecomment-739081612
@C0urante as mentioned offline, here is my fix for the MM2 integration test
frequently exiting the builds.
This
rhauch opened a new pull request #9698:
URL: https://github.com/apache/kafka/pull/9698
Normally the `EmbeddedConnectCluster` class masks the `Exit` procedures
using within the Connect worker. This normally works great when a single
instance of the embedded cluster is used. However, the
rayokota edited a comment on pull request #9593:
URL: https://github.com/apache/kafka/pull/9593#issuecomment-739080185
This breaks existing client configurations that use
`bootstrap.servers=SASL_PLAINTEXT://localhost:49767` (due to the `_`)
Randall Hauch created KAFKA-10811:
-
Summary: System exit from
MirrorConnectorsIntegrationTest#testReplication
Key: KAFKA-10811
URL: https://issues.apache.org/jira/browse/KAFKA-10811
Project: Kafka
rayokota commented on pull request #9593:
URL: https://github.com/apache/kafka/pull/9593#issuecomment-739080185
This breaks existing client configurations that use
`bootstrap.brokers=SASL_PLAINTEXT://localhost:49767` (due to the `_`)
[
https://issues.apache.org/jira/browse/KAFKA-10792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-10792:
--
Description:
If a source task blocks during its {{stop}} method, the herder thread will also
[
https://issues.apache.org/jira/browse/KAFKA-10792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-10792:
--
Fix Version/s: 2.8.0
> Source tasks can block herder thread by hanging during stop
>
[
https://issues.apache.org/jira/browse/KAFKA-10792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-10792:
--
Description:
If a source task blocks during its {{stop}} method, the herder thread will also
[
https://issues.apache.org/jira/browse/KAFKA-10792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton resolved KAFKA-10792.
---
Fix Version/s: 2.7.1
Resolution: Fixed
> Source tasks can block herder thread by
[
https://issues.apache.org/jira/browse/KAFKA-7458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reassigned KAFKA-7458:
---
Assignee: John Roesler (was: Guozhang Wang)
> Avoid enforced processing during bootstrap
[
https://issues.apache.org/jira/browse/KAFKA-8478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reassigned KAFKA-8478:
---
Assignee: John Roesler
> Poll for more records before forced processing
>
[
https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244330#comment-17244330
]
John Roesler commented on KAFKA-8315:
-
Hello, all, I have just proposed KIP-695, which I think would
[
https://issues.apache.org/jira/browse/KAFKA-8478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244329#comment-17244329
]
John Roesler commented on KAFKA-8478:
-
Hello, all, I have just proposed KIP-695, which I think would
[
https://issues.apache.org/jira/browse/KAFKA-7458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244327#comment-17244327
]
John Roesler commented on KAFKA-7458:
-
Hello, all, I have just proposed KIP-695, which I think would
[
https://issues.apache.org/jira/browse/KAFKA-10091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244326#comment-17244326
]
John Roesler commented on KAFKA-10091:
--
Hello, all! I have just started the discussion in the
wcarlson5 commented on a change in pull request #9697:
URL: https://github.com/apache/kafka/pull/9697#discussion_r536416836
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/StreamsUncaughtExceptionHandlerIntegrationTest.java
##
@@ -145,6 +148,26 @@
wcarlson5 opened a new pull request #9697:
URL: https://github.com/apache/kafka/pull/9697
StreamThreads can now be replaced in the streams uncaught exception handler
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test
guozhangwang merged pull request #9667:
URL: https://github.com/apache/kafka/pull/9667
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
ableegoldman commented on a change in pull request #9688:
URL: https://github.com/apache/kafka/pull/9688#discussion_r536406055
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java
##
@@ -916,11 +917,12 @@ public void
vvcephei commented on a change in pull request #9616:
URL: https://github.com/apache/kafka/pull/9616#discussion_r536403001
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java
##
@@ -78,15 +89,147 @@ RecordQueue queue() {
splett2 commented on a change in pull request #9628:
URL: https://github.com/apache/kafka/pull/9628#discussion_r536391337
##
File path: core/src/main/scala/kafka/admin/ConfigCommand.scala
##
@@ -864,11 +885,21 @@ object ConfigCommand extends Config {
}
}
+
splett2 commented on a change in pull request #9628:
URL: https://github.com/apache/kafka/pull/9628#discussion_r536391337
##
File path: core/src/main/scala/kafka/admin/ConfigCommand.scala
##
@@ -864,11 +885,21 @@ object ConfigCommand extends Config {
}
}
+
splett2 commented on a change in pull request #9628:
URL: https://github.com/apache/kafka/pull/9628#discussion_r536391337
##
File path: core/src/main/scala/kafka/admin/ConfigCommand.scala
##
@@ -864,11 +885,21 @@ object ConfigCommand extends Config {
}
}
+
splett2 commented on a change in pull request #9628:
URL: https://github.com/apache/kafka/pull/9628#discussion_r536391337
##
File path: core/src/main/scala/kafka/admin/ConfigCommand.scala
##
@@ -864,11 +885,21 @@ object ConfigCommand extends Config {
}
}
+
splett2 commented on a change in pull request #9628:
URL: https://github.com/apache/kafka/pull/9628#discussion_r536241597
##
File path: core/src/test/scala/unit/kafka/server/ClientQuotasRequestTest.scala
##
@@ -236,13 +310,22 @@ class ClientQuotasRequestTest extends
splett2 commented on a change in pull request #9628:
URL: https://github.com/apache/kafka/pull/9628#discussion_r536241597
##
File path: core/src/test/scala/unit/kafka/server/ClientQuotasRequestTest.scala
##
@@ -236,13 +310,22 @@ class ClientQuotasRequestTest extends
lct45 opened a new pull request #9696:
URL: https://github.com/apache/kafka/pull/9696
Follow-up from https://github.com/apache/kafka/pull/9614, updates streams
metrics sensor logic
This is an automated message from the
lct45 commented on pull request #9696:
URL: https://github.com/apache/kafka/pull/9696#issuecomment-739012738
@cadonna @mjsax for review
This is an automated message from the Apache Git Service.
To respond to the message,
wcarlson5 commented on a change in pull request #9695:
URL: https://github.com/apache/kafka/pull/9695#discussion_r536354418
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -924,28 +924,69 @@ private StreamThread createStreamThread(final
wcarlson5 closed pull request #9647:
URL: https://github.com/apache/kafka/pull/9647
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
wcarlson5 commented on pull request #9647:
URL: https://github.com/apache/kafka/pull/9647#issuecomment-738992835
closed in favor of https://github.com/apache/kafka/pull/9695
This is an automated message from the Apache Git
wcarlson5 opened a new pull request #9695:
URL: https://github.com/apache/kafka/pull/9695
Add the ability to remove running threads
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
-
mjsax commented on pull request #9660:
URL: https://github.com/apache/kafka/pull/9660#issuecomment-738989889
Thanks for the KIP and PR @rohitrmd!
This is an automated message from the Apache Git Service.
To respond to the
mjsax commented on pull request #8965:
URL: https://github.com/apache/kafka/pull/8965#issuecomment-738989558
Thanks a lot for the PR @highluck!
This is an automated message from the Apache Git Service.
To respond to the
mjsax commented on pull request #8965:
URL: https://github.com/apache/kafka/pull/8965#issuecomment-738989301
Merged to `trunk` and cherry-picked to `2.7` and `2.6` branches.
This is an automated message from the Apache Git
mjsax merged pull request #8965:
URL: https://github.com/apache/kafka/pull/8965
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
mjsax commented on a change in pull request #9688:
URL: https://github.com/apache/kafka/pull/9688#discussion_r536339499
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java
##
@@ -916,11 +917,12 @@ public void close() {
mjsax commented on a change in pull request #9688:
URL: https://github.com/apache/kafka/pull/9688#discussion_r536338913
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java
##
@@ -792,24 +790,35 @@ public void
chris8099 commented on pull request #9694:
URL: https://github.com/apache/kafka/pull/9694#issuecomment-738978021
@chia7712 PTAL thanks
This is an automated message from the Apache Git Service.
To respond to the message,
chris8099 opened a new pull request #9694:
URL: https://github.com/apache/kafka/pull/9694
Modify DescribeAclsResponse, remove Collection and change to Iterable,
Modify KafkaApis, aclsResources method
This is an automated
ableegoldman commented on a change in pull request #9688:
URL: https://github.com/apache/kafka/pull/9688#discussion_r536321595
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java
##
@@ -916,11 +917,12 @@ public void
mjsax commented on a change in pull request #9606:
URL: https://github.com/apache/kafka/pull/9606#discussion_r536328242
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedStream.java
##
@@ -381,7 +381,8 @@
* {@link
[
https://issues.apache.org/jira/browse/KAFKA-10790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244252#comment-17244252
]
GeordieMai edited comment on KAFKA-10790 at 12/4/20, 7:23 PM:
--
[~chia7712]
[
https://issues.apache.org/jira/browse/KAFKA-10790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244252#comment-17244252
]
GeordieMai commented on KAFKA-10790:
[~chia7712] Can I take this issue?
when flush method is called
mjsax merged pull request #9615:
URL: https://github.com/apache/kafka/pull/9615
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
wcarlson5 commented on a change in pull request #9615:
URL: https://github.com/apache/kafka/pull/9615#discussion_r536318737
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -845,67 +856,118 @@ private KafkaStreams(final
Walker Carlson created KAFKA-10810:
--
Summary: Add a replace thread option to the streams uncaught
exception handler
Key: KAFKA-10810
URL: https://issues.apache.org/jira/browse/KAFKA-10810
Project:
mjsax commented on pull request #9691:
URL: https://github.com/apache/kafka/pull/9691#issuecomment-738957750
Thanks for the quick fix @chia7712!
This is an automated message from the Apache Git Service.
To respond to the
mjsax merged pull request #9691:
URL: https://github.com/apache/kafka/pull/9691
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
rohitrmd commented on a change in pull request #9660:
URL: https://github.com/apache/kafka/pull/9660#discussion_r533099003
##
File path:
streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java
##
@@ -254,6 +265,19 @@ public TopologyTestDriver(final
rohitrmd commented on a change in pull request #9660:
URL: https://github.com/apache/kafka/pull/9660#discussion_r532104028
##
File path:
streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java
##
@@ -298,8 +322,14 @@ private TopologyTestDriver(final
mjsax merged pull request #9660:
URL: https://github.com/apache/kafka/pull/9660
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
mumrah commented on a change in pull request #9693:
URL: https://github.com/apache/kafka/pull/9693#discussion_r536307517
##
File path: core/src/main/scala/kafka/server/ZkIsrManager.scala
##
@@ -0,0 +1,51 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or
mumrah opened a new pull request #9693:
URL: https://github.com/apache/kafka/pull/9693
In an effort to consolidate the ISR write paths, this PR adapts the ZK ISR
update into the new AlterIsrManager trait. This will allow us minimize
divergence in the ISR update code in Partition.scala.
d8tltanc commented on a change in pull request #9485:
URL: https://github.com/apache/kafka/pull/9485#discussion_r536305219
##
File path:
clients/src/main/java/org/apache/kafka/server/authorizer/Authorizer.java
##
@@ -139,4 +150,129 @@
* @return Iterator for ACL
[
https://issues.apache.org/jira/browse/KAFKA-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244226#comment-17244226
]
James Galasyn commented on KAFKA-2967:
--
Cool! I'll go ahead and stand up a sandboxed site, then we
[
https://issues.apache.org/jira/browse/KAFKA-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244218#comment-17244218
]
Tom Bentley commented on KAFKA-2967:
{quote}I just took a look at Tom Bentley's proposal, and it
mjsax commented on pull request #8404:
URL: https://github.com/apache/kafka/pull/8404#issuecomment-738948918
About https://github.com/apache/kafka/pull/8404#issuecomment-645357204
As "spotless" can reformat code, could we use it to re-order imports? This
might be the best solution.
[
https://issues.apache.org/jira/browse/KAFKA-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244200#comment-17244200
]
James Galasyn commented on KAFKA-2967:
--
[~vvcephei] Yes, at the very least we can manually author
d8tltanc commented on pull request #9485:
URL: https://github.com/apache/kafka/pull/9485#issuecomment-738942757
Make a new aggregated index called ResourceIndex, which is a combination of
ACE, ResourceType, and PatternType.
New benchmark looks much better:
mjsax commented on pull request #8404:
URL: https://github.com/apache/kafka/pull/8404#issuecomment-738941710
@dongjinleekr The PR shows merge conflict. Can you rebase it?
This is an automated message from the Apache Git
mjsax commented on a change in pull request #9615:
URL: https://github.com/apache/kafka/pull/9615#discussion_r536285505
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -845,67 +856,118 @@ private KafkaStreams(final InternalTopologyBuilder
[
https://issues.apache.org/jira/browse/KAFKA-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244180#comment-17244180
]
John Roesler commented on KAFKA-2967:
-
I just took a look at [~tombentley]'s proposal, and it seems
guozhangwang commented on a change in pull request #9667:
URL: https://github.com/apache/kafka/pull/9667#discussion_r536282550
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
##
@@ -465,7 +465,11 @@ boolean
guozhangwang commented on pull request #9667:
URL: https://github.com/apache/kafka/pull/9667#issuecomment-738931337
> Maybe add an explanation here for why to skip the member.id required
exception? (as it's transient)
Ack, will do.
tombentley commented on pull request #9441:
URL: https://github.com/apache/kafka/pull/9441#issuecomment-738925531
You're right @guozhangwang, `ScheduledFutureTask` contains a sequence number
to break ties, so the executor _is_ FIFO. So you're saying that the wrong
network thread handling
rhauch merged pull request #9669:
URL: https://github.com/apache/kafka/pull/9669
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-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244159#comment-17244159
]
James Galasyn edited comment on KAFKA-2967 at 12/4/20, 5:37 PM:
[
https://issues.apache.org/jira/browse/KAFKA-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244159#comment-17244159
]
James Galasyn commented on KAFKA-2967:
--
[~tombentley] I'm not sure that could generate links, but it
splett2 commented on a change in pull request #9628:
URL: https://github.com/apache/kafka/pull/9628#discussion_r536257595
##
File path: core/src/test/scala/unit/kafka/admin/ConfigCommandTest.scala
##
@@ -472,6 +512,134 @@ class ConfigCommandTest extends ZooKeeperTestHarness
mjsax commented on a change in pull request #9668:
URL: https://github.com/apache/kafka/pull/9668#discussion_r536256494
##
File path:
streams/src/test/java/org/apache/kafka/streams/StreamsBuilderTest.java
##
@@ -463,7 +463,36 @@ public void
splett2 commented on a change in pull request #9628:
URL: https://github.com/apache/kafka/pull/9628#discussion_r536250843
##
File path: core/src/main/scala/kafka/admin/ConfigCommand.scala
##
@@ -864,11 +885,21 @@ object ConfigCommand extends Config {
}
}
+
bertber closed pull request #9692:
URL: https://github.com/apache/kafka/pull/9692
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-10161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reassigned KAFKA-10161:
---
Assignee: David Jacot
> Update Documentation
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244118#comment-17244118
]
Tom Bentley commented on KAFKA-2967:
[~JimGalasyn] so it looks like we could do useful stuff with
1 - 100 of 186 matches
Mail list logo
