hzh0425 opened a new pull request, #13133:
URL: https://github.com/apache/kafka/pull/13133
Fix some typos in storage module / remote.metadata.storage
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI b
[
https://issues.apache.org/jira/browse/KAFKA-14367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-14367.
-
Fix Version/s: 3.5.0
Resolution: Fixed
> Introduce `GroupCoordinator` interface
> ---
dajac merged PR #13112:
URL: https://github.com/apache/kafka/pull/13112
--
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 specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.or
[
https://issues.apache.org/jira/browse/KAFKA-14642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hzh0425 updated KAFKA-14642:
Priority: Blocker (was: Major)
> TopicBased RemoteLogMetadataManager can't support reassign user-partitio
showuon commented on code in PR #13099:
URL: https://github.com/apache/kafka/pull/13099#discussion_r1082162567
##
clients/src/main/java/org/apache/kafka/common/utils/Utils.java:
##
@@ -1496,4 +1496,32 @@ public static String replaceSuffix(String str, String
oldSuffix, String ne
hzh0425 created KAFKA-14643:
---
Summary: TopicBased RemoteLogMetadataManager can't support
reassign user-partitions
Key: KAFKA-14643
URL: https://issues.apache.org/jira/browse/KAFKA-14643
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-14642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17679014#comment-17679014
]
hzh0425 commented on KAFKA-14642:
-
Hi, [~satishd] [~junrao] [~Hangleton] , Could you pls
hzh0425 created KAFKA-14642:
---
Summary: TopicBased RemoteLogMetadataManager can't support
reassign user-partitions
Key: KAFKA-14642
URL: https://issues.apache.org/jira/browse/KAFKA-14642
Project: Kafka
yufeiyan1220 commented on PR #13125:
URL: https://github.com/apache/kafka/pull/13125#issuecomment-1397979098
> Seems like we aren't particularly consistent at removing these metrics and
sensors, fetcher would be another example. Mind making the clean up more
comprehensive?
Never mind
philipnee commented on PR #13125:
URL: https://github.com/apache/kafka/pull/13125#issuecomment-1397952270
Seems like we aren't particularly consistent at removing these metrics and
sensors, fetcher would be another example. Mind making the clean up more
comprehensive?
--
This is an auto
[
https://issues.apache.org/jira/browse/KAFKA-14639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17678981#comment-17678981
]
A. Sophie Blee-Goldman commented on KAFKA-14639:
There's definitely some
ableegoldman opened a new pull request, #13132:
URL: https://github.com/apache/kafka/pull/13132
While working on the 3.4 release I noticed we've built up an embarrassingly
long list of warnings within the Streams javadocs. It's unavoidable for some
links to break as the source code changes,
[
https://issues.apache.org/jira/browse/KAFKA-14638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-14638.
-
Fix Version/s: 3.5.0
Resolution: Fixed
> Documentation for transaction.timeout.ms
mjsax merged PR #13129:
URL: https://github.com/apache/kafka/pull/13129
--
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 specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.or
yufeiyan1220 commented on PR #13125:
URL: https://github.com/apache/kafka/pull/13125#issuecomment-1397837046
> Thanks for the PR and the issue @yufeiyan1220 - I wonder if the clean up
is necessary, as the metrics will be closed upon the client closing. Willing to
hear what others say.
Ge commented on PR #13129:
URL: https://github.com/apache/kafka/pull/13129#issuecomment-1397815859
@hachikuji @jolshan I don't have Kafka committer privileges. Can you please
commit?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
[
https://issues.apache.org/jira/browse/KAFKA-7744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17678943#comment-17678943
]
Yaroslav commented on KAFKA-7744:
-
Hi,
This was already fixed by KAFKA-6157 for 1.0.1 ve
Guozhang Wang created KAFKA-14641:
-
Summary: Cleanup CommitNeeded after EOS-V1 is removed
Key: KAFKA-14641
URL: https://issues.apache.org/jira/browse/KAFKA-14641
Project: Kafka
Issue Type: Im
[
https://issues.apache.org/jira/browse/KAFKA-14641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-14641:
--
Component/s: streams
> Cleanup CommitNeeded after EOS-V1 is removed
>
Justine Olshan created KAFKA-14640:
--
Summary: Update AddPartitionsToTxn protocol to batch and handle
verifyOnly requests
Key: KAFKA-14640
URL: https://issues.apache.org/jira/browse/KAFKA-14640
Projec
[
https://issues.apache.org/jira/browse/KAFKA-14640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan reassigned KAFKA-14640:
--
Assignee: Justine Olshan
> Update AddPartitionsToTxn protocol to batch and handle ver
Ge commented on code in PR #13129:
URL: https://github.com/apache/kafka/pull/13129#discussion_r1081881848
##
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java:
##
@@ -318,7 +318,8 @@ public class ProducerConfig extends AbstractConfig {
/** t
[
https://issues.apache.org/jira/browse/KAFKA-10586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton reassigned KAFKA-10586:
-
Assignee: Chris Egerton (was: Viktor Somogyi-Vass)
> Full support for distributed mode
hachikuji commented on code in PR #13129:
URL: https://github.com/apache/kafka/pull/13129#discussion_r1081878202
##
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java:
##
@@ -318,7 +318,8 @@ public class ProducerConfig extends AbstractConfig {
/**
Ge commented on code in PR #13129:
URL: https://github.com/apache/kafka/pull/13129#discussion_r1081848092
##
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java:
##
@@ -319,6 +319,7 @@ public class ProducerConfig extends AbstractConfig {
/** tra
dajac commented on code in PR #13112:
URL: https://github.com/apache/kafka/pull/13112#discussion_r1081788435
##
core/src/main/scala/kafka/coordinator/group/GroupCoordinatorAdapter.scala:
##
@@ -557,25 +557,25 @@ private[group] class GroupCoordinatorAdapter(
}
override de
jolshan commented on code in PR #13112:
URL: https://github.com/apache/kafka/pull/13112#discussion_r1081688123
##
core/src/main/scala/kafka/coordinator/group/GroupCoordinatorAdapter.scala:
##
@@ -557,25 +557,25 @@ private[group] class GroupCoordinatorAdapter(
}
override
jolshan commented on code in PR #13112:
URL: https://github.com/apache/kafka/pull/13112#discussion_r1081688123
##
core/src/main/scala/kafka/coordinator/group/GroupCoordinatorAdapter.scala:
##
@@ -557,25 +557,25 @@ private[group] class GroupCoordinatorAdapter(
}
override
jolshan commented on code in PR #13129:
URL: https://github.com/apache/kafka/pull/13129#discussion_r1081661935
##
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java:
##
@@ -319,6 +319,7 @@ public class ProducerConfig extends AbstractConfig {
/** tr
[ https://issues.apache.org/jira/browse/KAFKA-14638 ]
Justine Olshan deleted comment on KAFKA-14638:
was (Author: jolshan):
This is a bit tricky – the timer updates when the producer contacts the
transaction coordinator for the transaction.
jeffkbkim commented on code in PR #12972:
URL: https://github.com/apache/kafka/pull/12972#discussion_r1081656322
##
clients/src/main/resources/common/message/ConsumerGroupHeartbeatResponse.json:
##
@@ -0,0 +1,70 @@
+// Licensed to the Apache Software Foundation (ASF) under one o
jeffkbkim commented on code in PR #12972:
URL: https://github.com/apache/kafka/pull/12972#discussion_r1081655338
##
clients/src/main/resources/common/message/ConsumerGroupHeartbeatResponse.json:
##
@@ -0,0 +1,70 @@
+// Licensed to the Apache Software Foundation (ASF) under one o
[
https://issues.apache.org/jira/browse/KAFKA-14637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Akhilesh Chaganti resolved KAFKA-14637.
---
Fix Version/s: 3.4.0
Resolution: Fixed
> Upgrade to 3.4 from old versions (<
[
https://issues.apache.org/jira/browse/KAFKA-14638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17678840#comment-17678840
]
Justine Olshan commented on KAFKA-14638:
This is a bit tricky – the timer update
hachikuji commented on code in PR #13129:
URL: https://github.com/apache/kafka/pull/13129#discussion_r1081629522
##
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java:
##
@@ -319,6 +319,7 @@ public class ProducerConfig extends AbstractConfig {
/**
hachikuji commented on code in PR #13129:
URL: https://github.com/apache/kafka/pull/13129#discussion_r1081629522
##
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java:
##
@@ -319,6 +319,7 @@ public class ProducerConfig extends AbstractConfig {
/**
[
https://issues.apache.org/jira/browse/KAFKA-14638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-14638:
Issue Type: Improvement (was: Bug)
> Documentation for transaction.timeout.ms should be m
[
https://issues.apache.org/jira/browse/KAFKA-14638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-14638:
Component/s: docs
> Documentation for transaction.timeout.ms should be more precise
>
cadonna merged PR #12821:
URL: https://github.com/apache/kafka/pull/12821
--
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 specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.
cadonna commented on PR #12821:
URL: https://github.com/apache/kafka/pull/12821#issuecomment-1397370205
Build failures are unrelated:
```
Build / JDK 11 and Scala 2.13 /
org.apache.kafka.clients.consumer.KafkaConsumerTest.testReturnRecordsDuringRebalance()
Build / JDK 11 and Scala 2
kirktrue commented on code in PR #13119:
URL: https://github.com/apache/kafka/pull/13119#discussion_r1081589480
##
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/HttpAccessTokenRetriever.java:
##
@@ -240,6 +240,9 @@ static String handleOutpu
dajac commented on PR #13112:
URL: https://github.com/apache/kafka/pull/13112#issuecomment-1397338100
@jolshan Updated the PR.
--
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 specific comment
dajac commented on code in PR #13112:
URL: https://github.com/apache/kafka/pull/13112#discussion_r1081583343
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinator.java:
##
@@ -215,4 +223,86 @@ CompletableFuture deleteOffsets(
OffsetDelet
kirktrue commented on code in PR #13119:
URL: https://github.com/apache/kafka/pull/13119#discussion_r1081575409
##
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/HttpAccessTokenRetriever.java:
##
@@ -240,6 +240,9 @@ static String handleOutpu
kirktrue commented on code in PR #13119:
URL: https://github.com/apache/kafka/pull/13119#discussion_r1081575409
##
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/HttpAccessTokenRetriever.java:
##
@@ -240,6 +240,9 @@ static String handleOutpu
dajac commented on code in PR #13112:
URL: https://github.com/apache/kafka/pull/13112#discussion_r1081571516
##
core/src/test/scala/unit/kafka/server/KafkaApisTest.scala:
##
@@ -3448,7 +3445,7 @@ class KafkaApisTest {
val expectedJoinGroupResponse = new JoinGroupResponseDat
dajac commented on code in PR #13112:
URL: https://github.com/apache/kafka/pull/13112#discussion_r1081571061
##
core/src/main/scala/kafka/coordinator/group/GroupCoordinatorAdapter.scala:
##
@@ -511,4 +532,53 @@ class GroupCoordinatorAdapter(
future
}
+
+ override def
fvaleri commented on PR #13131:
URL: https://github.com/apache/kafka/pull/13131#issuecomment-1397311675
Take a look at `DumpLogSegments` to see how `CommandDefaultOptions` is used.
It is much better than building the option list at the start of the
`main/execute` method.
--
This is an au
[
https://issues.apache.org/jira/browse/KAFKA-14565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17678799#comment-17678799
]
Terry Beard commented on KAFKA-14565:
-
[~ChrisEgerton] I've updated the ticket to i
[
https://issues.apache.org/jira/browse/KAFKA-14565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Terry Beard updated KAFKA-14565:
Description:
The Consumer and Producer interceptor interfaces and their corresponding Kafka
Consu
bbejeck commented on PR #8431:
URL: https://github.com/apache/kafka/pull/8431#issuecomment-1397212359
cherry-picked to 3.4
--
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 specific comment.
T
[
https://issues.apache.org/jira/browse/KAFKA-14636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17678790#comment-17678790
]
Ismael Juma commented on KAFKA-14636:
-
KAFKA-7632 and KAFKA-13361 are somewhat relat
mumrah merged PR #13130:
URL: https://github.com/apache/kafka/pull/13130
--
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 specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.o
bbejeck commented on PR #8431:
URL: https://github.com/apache/kafka/pull/8431#issuecomment-1397198456
Hi @maseiler, can you do the same PR for the [3.3 version of the streams
developer
guide](https://github.com/apache/kafka-site/blob/asf-site/33/streams/developer-guide/dsl-api.html)?
bbejeck commented on PR #8431:
URL: https://github.com/apache/kafka/pull/8431#issuecomment-1397167523
Thanks for the contribution @maseiler !
--
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 s
bbejeck commented on PR #8431:
URL: https://github.com/apache/kafka/pull/8431#issuecomment-1397166959
Merged #8431 into trunk
--
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 specific comment.
bbejeck merged PR #8431:
URL: https://github.com/apache/kafka/pull/8431
--
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 specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.or
maseiler commented on PR #8431:
URL: https://github.com/apache/kafka/pull/8431#issuecomment-1397133912
@mjsax, I solved the merge conflict and rebased it on the latest version
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
[
https://issues.apache.org/jira/browse/KAFKA-14636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christo Lolov reassigned KAFKA-14636:
-
Assignee: Christo Lolov
> Compression optimization: Use zstd dictionary based (de)compr
[
https://issues.apache.org/jira/browse/KAFKA-14565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Terry Beard updated KAFKA-14565:
Description:
The Consumer and Producer interceptor interfaces and their corresponding Kafka
Consu
[
https://issues.apache.org/jira/browse/KAFKA-14565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Terry Beard updated KAFKA-14565:
Description:
The Consumer and Producer interceptor interfaces and their corresponding Kafka
Consu
clolov commented on code in PR #12821:
URL: https://github.com/apache/kafka/pull/12821#discussion_r1081305288
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateManagerUtilTest.java:
##
@@ -187,151 +137,107 @@ public void
testCloseStateManagerThrowsExcep
[
https://issues.apache.org/jira/browse/KAFKA-14565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Terry Beard updated KAFKA-14565:
Description:
The Consumer and Producer interceptor interfaces and their corresponding Kafka
Consu
[
https://issues.apache.org/jira/browse/KAFKA-14565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Terry Beard updated KAFKA-14565:
Description:
The Consumer and Producer interceptor interfaces and their corresponding Kafka
Consu
cadonna merged PR #12818:
URL: https://github.com/apache/kafka/pull/12818
--
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 specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.
cadonna commented on PR #12818:
URL: https://github.com/apache/kafka/pull/12818#issuecomment-1397015212
Build failures are unrelated:
```
Build / JDK 11 and Scala 2.13 /
kafka.controller.ControllerIntegrationTest.testPartitionReassignmentToBrokerWithOfflineLogDir()
Build / JDK 8 and
[
https://issues.apache.org/jira/browse/KAFKA-14582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Federico Valeri reassigned KAFKA-14582:
---
Assignee: Federico Valeri
> Move JmxTool to tools
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-14577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Federico Valeri reassigned KAFKA-14577:
---
Assignee: (was: Federico Valeri)
> Move ConsoleProducer to tools
>
[
https://issues.apache.org/jira/browse/KAFKA-14577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Federico Valeri reassigned KAFKA-14577:
---
Assignee: Federico Valeri
> Move ConsoleProducer to tools
> ---
fvaleri commented on code in PR #13127:
URL: https://github.com/apache/kafka/pull/13127#discussion_r1081230571
##
build.gradle:
##
@@ -1757,6 +1757,7 @@ project(':tools') {
archivesBaseName = "kafka-tools"
dependencies {
+implementation project(':core')
Review Comme
fvaleri commented on PR #13131:
URL: https://github.com/apache/kafka/pull/13131#issuecomment-1396923697
@clolov @vamossagar12 @tinaselenge
--
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 spe
fvaleri commented on PR #13131:
URL: https://github.com/apache/kafka/pull/13131#issuecomment-1396922639
@mimaison @ijuma
--
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 specific comment.
To
fvaleri opened a new pull request, #13131:
URL: https://github.com/apache/kafka/pull/13131
These classes are required by most commands, so they must be migrated first.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
cadonna commented on code in PR #12821:
URL: https://github.com/apache/kafka/pull/12821#discussion_r1081170724
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateManagerUtilTest.java:
##
@@ -187,151 +137,107 @@ public void
testCloseStateManagerThrowsExce
[
https://issues.apache.org/jira/browse/KAFKA-14639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bojan Blagojevic updated KAFKA-14639:
-
Description:
I have an application that runs 6 consumers in parallel. I am getting some
Bojan Blagojevic created KAFKA-14639:
Summary: Kafka CooperativeStickyAssignor revokes/assigns partition
in one rebalance cycle
Key: KAFKA-14639
URL: https://issues.apache.org/jira/browse/KAFKA-14639
yashmayya commented on code in PR #12984:
URL: https://github.com/apache/kafka/pull/12984#discussion_r1081145849
##
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaConfigBackingStore.java:
##
@@ -712,8 +733,16 @@ KafkaBasedLog
setupAndCreateKafkaBasedLog(Str
clolov commented on code in PR #12821:
URL: https://github.com/apache/kafka/pull/12821#discussion_r1081139070
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateManagerUtilTest.java:
##
@@ -187,151 +137,107 @@ public void
testCloseStateManagerThrowsExcep
fvaleri commented on code in PR #13127:
URL: https://github.com/apache/kafka/pull/13127#discussion_r1081057443
##
build.gradle:
##
@@ -1757,6 +1757,7 @@ project(':tools') {
archivesBaseName = "kafka-tools"
dependencies {
+implementation project(':core')
Review Comme
vamossagar12 commented on code in PR #13127:
URL: https://github.com/apache/kafka/pull/13127#discussion_r1081021244
##
build.gradle:
##
@@ -1757,6 +1757,7 @@ project(':tools') {
archivesBaseName = "kafka-tools"
dependencies {
+implementation project(':core')
Review
cadonna commented on code in PR #13127:
URL: https://github.com/apache/kafka/pull/13127#discussion_r1081015656
##
build.gradle:
##
@@ -1757,6 +1757,7 @@ project(':tools') {
archivesBaseName = "kafka-tools"
dependencies {
+implementation project(':core')
Review Comme
vamossagar12 commented on code in PR #13127:
URL: https://github.com/apache/kafka/pull/13127#discussion_r1081010418
##
build.gradle:
##
@@ -1757,6 +1757,7 @@ project(':tools') {
archivesBaseName = "kafka-tools"
dependencies {
+implementation project(':core')
Review
vamossagar12 commented on code in PR #13127:
URL: https://github.com/apache/kafka/pull/13127#discussion_r1081009344
##
build.gradle:
##
@@ -1757,6 +1757,7 @@ project(':tools') {
archivesBaseName = "kafka-tools"
dependencies {
+implementation project(':core')
Review
clolov commented on code in PR #13127:
URL: https://github.com/apache/kafka/pull/13127#discussion_r1081007952
##
build.gradle:
##
@@ -1757,6 +1757,7 @@ project(':tools') {
archivesBaseName = "kafka-tools"
dependencies {
+implementation project(':core')
Review Commen
cadonna commented on code in PR #13127:
URL: https://github.com/apache/kafka/pull/13127#discussion_r1081000404
##
build.gradle:
##
@@ -1757,6 +1757,7 @@ project(':tools') {
archivesBaseName = "kafka-tools"
dependencies {
+implementation project(':core')
Review Comme
cadonna commented on code in PR #12821:
URL: https://github.com/apache/kafka/pull/12821#discussion_r1080946697
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateManagerUtilTest.java:
##
@@ -187,151 +137,107 @@ public void
testCloseStateManagerThrowsExce
cadonna commented on PR #12739:
URL: https://github.com/apache/kafka/pull/12739#issuecomment-1396582822
@shekhar-rajak Do you have any updates for this PR?
--
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
87 matches
Mail list logo
