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 autom
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 to
[
https://issues.apache.org/jira/browse/KAFKA-10604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244416#comment-17244416
]
Dongjin Lee commented on KAFKA-10604:
-
ALL // Great. Let's continue the discussion o
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 diff/spotl
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 pe
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 me
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 me
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 mess
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
T
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 to
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&focusedCommentId=17244391#comment-17244391
]
Chia-Ping Tsai commented on KAFKA-10790:
[~Geordie] go for it
> Detect/Prevent
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 PR
[
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 TaskMig
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
P
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 @@ publ
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. I'v
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 f
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 shut
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 `testRep
[
https://issues.apache.org/jira/browse/KAFKA-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244361#comment-17244361
]
Randall Hauch commented on KAFKA-9013:
--
See also KAFKA-10811 for when MirrorConnecto
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 i
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
`M
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 hang
[
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 ph
[
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&focusedCommentId=17244330#comment-17244330
]
John Roesler commented on KAFKA-8315:
-
Hello, all, I have just proposed KIP-695, whic
[
https://issues.apache.org/jira/browse/KAFKA-8478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244329#comment-17244329
]
John Roesler commented on KAFKA-8478:
-
Hello, all, I have just proposed KIP-695, whic
[
https://issues.apache.org/jira/browse/KAFKA-7458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244327#comment-17244327
]
John Roesler commented on KAFKA-7458:
-
Hello, all, I have just proposed KIP-695, whic
[
https://issues.apache.org/jira/browse/KAFKA-10091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244326#comment-17244326
]
John Roesler commented on KAFKA-10091:
--
Hello, all! I have just started the discuss
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 @@ publ
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 close
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 BaseRequest
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 BaseRequest
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 Apach
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, plea
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 long
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 Se
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 mes
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 messa
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 Se
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 shouldUpgrad
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, plea
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 m
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 close
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 StreamsConfig#COMMIT_INTERVAL_
[
https://issues.apache.org/jira/browse/KAFKA-10790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244252#comment-17244252
]
GeordieMai edited comment on KAFKA-10790 at 12/4/20, 7:23 PM:
[
https://issues.apache.org/jira/browse/KAFKA-10790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244252#comment-17244252
]
GeordieMai commented on KAFKA-10790:
[~chia7712] Can I take this issue?
when flush m
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 InternalTopologyBuilde
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 mess
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 To
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 I
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 bindings,
[
https://issues.apache.org/jira/browse/KAFKA-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244226#comment-17244226
]
James Galasyn commented on KAFKA-2967:
--
Cool! I'll go ahead and stand up a sandboxed
[
https://issues.apache.org/jira/browse/KAFKA-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244218#comment-17244218
]
Tom Bentley commented on KAFKA-2967:
{quote}I just took a look at Tom Bentley's propo
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&focusedCommentId=17244200#comment-17244200
]
James Galasyn commented on KAFKA-2967:
--
[~vvcephei] Yes, at the very least we can ma
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: https://paste.ubuntu.com/p
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 Servi
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
i
[
https://issues.apache.org/jira/browse/KAFKA-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244180#comment-17244180
]
John Roesler commented on KAFKA-2967:
-
I just took a look at [~tombentley]'s proposal
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 joinGroupIfNe
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 o
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 the
[
https://issues.apache.org/jira/browse/KAFKA-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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&focusedCommentId=17244159#comment-17244159
]
James Galasyn commented on KAFKA-2967:
--
[~tombentley] I'm not sure that could genera
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 wit
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
shouldReuseSourceTopicAsChangelogsW
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 th
[
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
>
>
> Key
[
https://issues.apache.org/jira/browse/KAFKA-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244118#comment-17244118
]
Tom Bentley commented on KAFKA-2967:
[~JimGalasyn] so it looks like we could do usefu
1 - 100 of 186 matches
Mail list logo