[
https://issues.apache.org/jira/browse/KAFKA-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dengziming updated KAFKA-10437:
---
Attachment: image.png
> KIP-478: Implement test-utils changes
>
[
https://issues.apache.org/jira/browse/KAFKA-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dengziming updated KAFKA-10437:
---
Attachment: (was: image.png)
> KIP-478: Implement test-utils changes
>
dengziming commented on pull request #10229:
URL: https://github.com/apache/kafka/pull/10229#issuecomment-786993345
@mjsax ,Hello, this is inspired by #10044 which forget
`WordCountProcessorDemo` and `WordCountTransformerDemo`, PTAL.
dengziming opened a new pull request #10229:
URL: https://github.com/apache/kafka/pull/10229
*More detailed description of your change*
As the title.
*Summary of testing strategy (including rationale)*
QA
### Committer Checklist (excluded from commit message)
- [ ]
ijuma commented on pull request #8830:
URL: https://github.com/apache/kafka/pull/8830#issuecomment-786989056
Rebased and regenerated the configs with graalvm ce 21.0.0.2. Need to
investigate the error during start-up:
> Exception in thread "main" java.lang.NoClassDefFoundError:
junrao commented on a change in pull request #10184:
URL: https://github.com/apache/kafka/pull/10184#discussion_r584019199
##
File path:
metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
##
@@ -349,6 +357,16 @@ public void
showuon commented on pull request #10228:
URL: https://github.com/apache/kafka/pull/10228#issuecomment-786981927
@abbccdda @ableegoldman @mjsax , could you help review this PR? Thanks.
This is an automated message from the
showuon opened a new pull request #10228:
URL: https://github.com/apache/kafka/pull/10228
We need to wait for the translation state changed to `READY` to start
consuming the records. But we didn't have any way to change the
transationManager state in client, so we can just wait. I've
Matthias J. Sax created KAFKA-12384:
---
Summary: Flaky Test
ListOffsetsRequestTest.testResponseIncludesLeaderEpoch
Key: KAFKA-12384
URL: https://issues.apache.org/jira/browse/KAFKA-12384
Project:
showuon commented on a change in pull request #10185:
URL: https://github.com/apache/kafka/pull/10185#discussion_r584015842
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationBaseTest.java
##
@@ -455,27 +470,44 @@
[
https://issues.apache.org/jira/browse/KAFKA-10251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17292005#comment-17292005
]
Luke Chen commented on KAFKA-10251:
---
This flaky test also points to the same root cause.
Colin McCabe created KAFKA-12383:
Summary: Get RaftClusterTest.java and other KIP-500 junit tests
working
Key: KAFKA-12383
URL: https://issues.apache.org/jira/browse/KAFKA-12383
Project: Kafka
showuon commented on pull request #10185:
URL: https://github.com/apache/kafka/pull/10185#issuecomment-786978491
@mimaison , thanks for your comments. I've addressed them and updated in
this commit:
Colin McCabe created KAFKA-12382:
Summary: Create KIP-500 README for the 2.8 rleease
Key: KAFKA-12382
URL: https://issues.apache.org/jira/browse/KAFKA-12382
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-12382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-12382:
-
Summary: Create KIP-500 README for the 2.8 release (was: Create KIP-500
README for the 2.8
showuon commented on a change in pull request #10185:
URL: https://github.com/apache/kafka/pull/10185#discussion_r584013857
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationBaseTest.java
##
@@ -455,27 +470,44 @@
showuon commented on a change in pull request #10185:
URL: https://github.com/apache/kafka/pull/10185#discussion_r584013620
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationBaseTest.java
##
@@ -455,27 +470,44 @@
cmccabe merged pull request #10226:
URL: https://github.com/apache/kafka/pull/10226
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to
cmccabe commented on a change in pull request #10184:
URL: https://github.com/apache/kafka/pull/10184#discussion_r584009213
##
File path:
metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
##
@@ -349,6 +357,16 @@ public void
cmccabe commented on a change in pull request #10184:
URL: https://github.com/apache/kafka/pull/10184#discussion_r584007497
##
File path:
metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
##
@@ -349,6 +357,16 @@ public void
cmccabe commented on pull request #10199:
URL: https://github.com/apache/kafka/pull/10199#issuecomment-786970988
I filed https://issues.apache.org/jira/browse/KAFKA-12381 to follow up on
the auto-topic-creation behavior change discussion.
cmccabe merged pull request #10199:
URL: https://github.com/apache/kafka/pull/10199
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-12381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17291991#comment-17291991
]
Colin McCabe commented on KAFKA-12381:
--
cc [~rndgstn], [~hachikuji], [~ijuma]
> Incompatible
[
https://issues.apache.org/jira/browse/KAFKA-12381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-12381:
-
Affects Version/s: 2.8.0
> Incompatible change in verifiable_producer.log in 2.8
>
[
https://issues.apache.org/jira/browse/KAFKA-12381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe reassigned KAFKA-12381:
Assignee: Boyang Chen
> Incompatible change in verifiable_producer.log in 2.8
>
Colin McCabe created KAFKA-12381:
Summary: Incompatible change in verifiable_producer.log in 2.8
Key: KAFKA-12381
URL: https://issues.apache.org/jira/browse/KAFKA-12381
Project: Kafka
Issue
cmccabe opened a new pull request #10227:
URL: https://github.com/apache/kafka/pull/10227
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
cmccabe opened a new pull request #10226:
URL: https://github.com/apache/kafka/pull/10226
* Fix CLASSPATH issues in the startup script
* Fix overly verbose log messages during loading
* Update to use the new MetadataRecordSerde (this is needed now that we
have a frame
hachikuji commented on pull request #10225:
URL: https://github.com/apache/kafka/pull/10225#issuecomment-786959937
@rondagostino Thanks for identifying the issue. Returning
`INVALID_REPLICATION_FACTOR` seems like a mistake to me if we were previously
returning `LEADER_NOT_AVAILABLE`. I'd
rondagostino commented on pull request #10225:
URL: https://github.com/apache/kafka/pull/10225#issuecomment-786955706
@abbccdda, @cmccabe. Ported from #10199 to discuss separately. We used to
see this error message in `verifiable_producer.log` when
`security_protocol='PLAINTEXT',
rondagostino opened a new pull request #10225:
URL: https://github.com/apache/kafka/pull/10225
The ZooKeeper version of this system test is failing because the producer is
no longer seeing `LEADER_NOT_AVAILABLE`. When the broker sees a METADATA
request for the test topic after it restarts
junrao commented on a change in pull request #10184:
URL: https://github.com/apache/kafka/pull/10184#discussion_r583984728
##
File path:
metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
##
@@ -349,6 +357,16 @@ public void
rondagostino opened a new pull request #10224:
URL: https://github.com/apache/kafka/pull/10224
Transactions are not supported in the KIP-500 early access release. This
patch disables a system test for Raft metadata quorums that uses transactions
and that was still enabled after #10194.
rhauch commented on a change in pull request #10203:
URL: https://github.com/apache/kafka/pull/10203#discussion_r583981010
##
File path: build.gradle
##
@@ -2026,52 +2043,53 @@ project(':connect:runtime') {
archivesBaseName = "connect-runtime"
dependencies {
-
-
[
https://issues.apache.org/jira/browse/KAFKA-9714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17291965#comment-17291965
]
Matthias J. Sax commented on KAFKA-9714:
Different test method:
[
https://issues.apache.org/jira/browse/KAFKA-10251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17291964#comment-17291964
]
Matthias J. Sax commented on KAFKA-10251:
-
Different test method:
[
https://issues.apache.org/jira/browse/KAFKA-8711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17291963#comment-17291963
]
Matthias J. Sax commented on KAFKA-8711:
Different but related test
[
https://issues.apache.org/jira/browse/KAFKA-10582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17291956#comment-17291956
]
Leonid Ilyevsky commented on KAFKA-10582:
-
I have the same problem, but in my case just
hachikuji opened a new pull request #10223:
URL: https://github.com/apache/kafka/pull/10223
We now accept topicIds in the `DescribeTopic` request. If the client
principal does not have `Describe` permission, then we return
`UNKNOWN_TOPIC_ID` regardless whether the topic exists or not.
cmccabe commented on a change in pull request #10184:
URL: https://github.com/apache/kafka/pull/10184#discussion_r583965997
##
File path: core/src/main/scala/kafka/server/ControllerApis.scala
##
@@ -154,6 +161,147 @@ class ControllerApis(val requestChannel: RequestChannel,
ijuma commented on pull request #8812:
URL: https://github.com/apache/kafka/pull/8812#issuecomment-786935020
Tests passed, merged to trunk and 2.8.
This is an automated message from the Apache Git Service.
To respond to the
rhauch commented on a change in pull request #10016:
URL: https://github.com/apache/kafka/pull/10016#discussion_r583964769
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java
##
@@ -259,6 +267,16 @@ public void execute() {
rhauch commented on a change in pull request #10016:
URL: https://github.com/apache/kafka/pull/10016#discussion_r583964769
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java
##
@@ -259,6 +267,16 @@ public void execute() {
Randall Hauch created KAFKA-12380:
-
Summary: Executor in Connect's Worker is not shut down when the
worker is
Key: KAFKA-12380
URL: https://issues.apache.org/jira/browse/KAFKA-12380
Project: Kafka
ijuma merged pull request #8812:
URL: https://github.com/apache/kafka/pull/8812
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
cmccabe commented on a change in pull request #10184:
URL: https://github.com/apache/kafka/pull/10184#discussion_r583962844
##
File path: core/src/main/scala/kafka/server/ControllerApis.scala
##
@@ -154,6 +161,147 @@ class ControllerApis(val requestChannel: RequestChannel,
cmccabe commented on a change in pull request #10184:
URL: https://github.com/apache/kafka/pull/10184#discussion_r583940888
##
File path: core/src/test/java/kafka/test/MockController.java
##
@@ -0,0 +1,224 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
cmccabe commented on a change in pull request #10184:
URL: https://github.com/apache/kafka/pull/10184#discussion_r583940677
##
File path: core/src/main/scala/kafka/server/ControllerApis.scala
##
@@ -154,6 +161,147 @@ class ControllerApis(val requestChannel: RequestChannel,
cmccabe merged pull request #10222:
URL: https://github.com/apache/kafka/pull/10222
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
rhauch edited a comment on pull request #9950:
URL: https://github.com/apache/kafka/pull/9950#issuecomment-786911483
The documentation is auto-generated from the transforms code, via
rhauch edited a comment on pull request #9950:
URL: https://github.com/apache/kafka/pull/9950#issuecomment-786911483
The documentation is auto-generated from the transforms code, via
rhauch edited a comment on pull request #9950:
URL: https://github.com/apache/kafka/pull/9950#issuecomment-786911483
The documentation is auto-generated from the transforms code, via
rhauch edited a comment on pull request #9950:
URL: https://github.com/apache/kafka/pull/9950#issuecomment-786911483
The documentation is auto-generated from the transforms code, via
rhauch commented on pull request #9950:
URL: https://github.com/apache/kafka/pull/9950#issuecomment-786911483
The documentation is auto-generated from the code, via
hachikuji commented on a change in pull request #10184:
URL: https://github.com/apache/kafka/pull/10184#discussion_r583886777
##
File path: core/src/main/scala/kafka/server/ControllerApis.scala
##
@@ -154,6 +161,147 @@ class ControllerApis(val requestChannel: RequestChannel,
rondagostino opened a new pull request #10222:
URL: https://github.com/apache/kafka/pull/10222
Transactions are not supported in the KIP-500 early access release. This
patch disables a system test for Raft metadata quorums that uses transactions
and that was still enabled after
dhruvilshah3 commented on pull request #10217:
URL: https://github.com/apache/kafka/pull/10217#issuecomment-786895408
Thanks for the review @rajinisivaram. I ran
`MirrorConnectorsIntegrationSSLTest` a few times locally and it passed. It
passed in the latest jenkins run as well. Couple of
ijuma commented on a change in pull request #8812:
URL: https://github.com/apache/kafka/pull/8812#discussion_r583907925
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -826,8 +832,16 @@ class Log(@volatile private var _dir: File,
preallocate =
cmccabe commented on a change in pull request #10184:
URL: https://github.com/apache/kafka/pull/10184#discussion_r583903614
##
File path:
metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
##
@@ -349,6 +357,16 @@ public void
cmccabe commented on a change in pull request #10184:
URL: https://github.com/apache/kafka/pull/10184#discussion_r583900849
##
File path: core/src/main/scala/kafka/server/ControllerApis.scala
##
@@ -154,6 +161,147 @@ class ControllerApis(val requestChannel: RequestChannel,
ableegoldman commented on pull request #10213:
URL: https://github.com/apache/kafka/pull/10213#issuecomment-786873825
Merged to trunk and cherrypicked to 2.8 cc @vvcephei
This is an automated message from the Apache Git
ableegoldman merged pull request #10213:
URL: https://github.com/apache/kafka/pull/10213
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
ableegoldman commented on pull request #10213:
URL: https://github.com/apache/kafka/pull/10213#issuecomment-786871581
One unrelated test failure:
`kafka.server.ListOffsetsRequestTest.testResponseIncludesLeaderEpoch`
Going to merge this now
[
https://issues.apache.org/jira/browse/KAFKA-12235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-12235:
-
Fix Version/s: 2.7.1
> ZkAdminManager.describeConfigs returns no config when 2+ configuration
cmccabe commented on a change in pull request #9990:
URL: https://github.com/apache/kafka/pull/9990#discussion_r583245201
##
File path: core/src/main/scala/kafka/server/ConfigHelper.scala
##
@@ -47,11 +47,11 @@ class ConfigHelper(metadataCache: MetadataCache, config:
[
https://issues.apache.org/jira/browse/KAFKA-9880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17291899#comment-17291899
]
A. Sophie Blee-Goldman commented on KAFKA-9880:
---
Since we turned off bulk loading in 2.6.0
[
https://issues.apache.org/jira/browse/KAFKA-9880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-9880.
---
Fix Version/s: 2.6.0
Resolution: Fixed
> Error while range compacting
hachikuji commented on a change in pull request #8812:
URL: https://github.com/apache/kafka/pull/8812#discussion_r583835401
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -826,8 +832,16 @@ class Log(@volatile private var _dir: File,
preallocate =
hachikuji commented on a change in pull request #10206:
URL: https://github.com/apache/kafka/pull/10206#discussion_r583877084
##
File path:
core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala
##
@@ -223,6 +224,46 @@ class
cmccabe merged pull request #9990:
URL: https://github.com/apache/kafka/pull/9990
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to
cmccabe merged pull request #10212:
URL: https://github.com/apache/kafka/pull/10212
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
hachikuji merged pull request #9958:
URL: https://github.com/apache/kafka/pull/9958
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
ableegoldman closed pull request #10214:
URL: https://github.com/apache/kafka/pull/10214
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
ableegoldman commented on pull request #10214:
URL: https://github.com/apache/kafka/pull/10214#issuecomment-786832334
Closing since this issue should be addressed on the side in
https://github.com/apache/kafka/pull/10137
cmccabe commented on a change in pull request #10212:
URL: https://github.com/apache/kafka/pull/10212#discussion_r583849492
##
File path: core/src/main/scala/kafka/tools/DumpLogSegments.scala
##
@@ -242,7 +246,8 @@ object DumpLogSegments {
ableegoldman commented on a change in pull request #10137:
URL: https://github.com/apache/kafka/pull/10137#discussion_r583848994
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java
##
@@ -211,7 +192,7 @@ public boolean
hachikuji commented on a change in pull request #8812:
URL: https://github.com/apache/kafka/pull/8812#discussion_r583835401
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -826,8 +832,16 @@ class Log(@volatile private var _dir: File,
preallocate =
ijuma commented on a change in pull request #10203:
URL: https://github.com/apache/kafka/pull/10203#discussion_r583834500
##
File path: build.gradle
##
@@ -2026,52 +2043,53 @@ project(':connect:runtime') {
archivesBaseName = "connect-runtime"
dependencies {
-
-
junrao commented on a change in pull request #8812:
URL: https://github.com/apache/kafka/pull/8812#discussion_r583834117
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -826,8 +832,16 @@ class Log(@volatile private var _dir: File,
preallocate =
dhruvilshah3 commented on a change in pull request #10217:
URL: https://github.com/apache/kafka/pull/10217#discussion_r583832959
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java
##
@@ -306,40 +307,84 @@ private void
mimaison opened a new pull request #10221:
URL: https://github.com/apache/kafka/pull/10221
… with MirrorMaker2
This commit implements KIP-716. It introduces a new setting
`offset-syncs.topic.location` that allows specifying where the offset-syncs
topic is created.
###
[
https://issues.apache.org/jira/browse/KAFKA-12379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-12379:
---
Description:
Ticket for KIP-716
[
https://issues.apache.org/jira/browse/KAFKA-12379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison reassigned KAFKA-12379:
--
Assignee: Mickael Maison
> KIP-716: Allow configuring the location of the offsetsync
[
https://issues.apache.org/jira/browse/KAFKA-12362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-12362:
---
Description: determine if a task is idling given the task Id. (was:
determine if a task is
Mickael Maison created KAFKA-12379:
--
Summary: KIP-716: Allow configuring the location of the offsetsync
topic with MirrorMaker2
Key: KAFKA-12379
URL: https://issues.apache.org/jira/browse/KAFKA-12379
[
https://issues.apache.org/jira/browse/KAFKA-12362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson closed KAFKA-12362.
--
> Determine if a Task is idling
> -
>
> Key:
[
https://issues.apache.org/jira/browse/KAFKA-12362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson resolved KAFKA-12362.
Resolution: Abandoned
> Determine if a Task is idling
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-12376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17291843#comment-17291843
]
Jose Armando Garcia Sancio commented on KAFKA-12376:
Yes [~rounak] . I am working on
wcarlson5 commented on a change in pull request #10215:
URL: https://github.com/apache/kafka/pull/10215#discussion_r583808502
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -463,9 +464,8 @@ private void replaceStreamThread(final Throwable
[
https://issues.apache.org/jira/browse/KAFKA-12319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17291826#comment-17291826
]
Matthias J. Sax commented on KAFKA-12319:
-
Failed again
Shane created KAFKA-12378:
-
Summary: If a broker is down for more then `delete.retention.ms`
deleted records in a compacted topic can come back.
Key: KAFKA-12378
URL: https://issues.apache.org/jira/browse/KAFKA-12378
cadonna commented on a change in pull request #10215:
URL: https://github.com/apache/kafka/pull/10215#discussion_r583801473
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -463,9 +464,8 @@ private void replaceStreamThread(final Throwable
[
https://issues.apache.org/jira/browse/KAFKA-12284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17291820#comment-17291820
]
Matthias J. Sax commented on KAFKA-12284:
-
Failde again:
{quote}java.lang.RuntimeException:
[
https://issues.apache.org/jira/browse/KAFKA-8003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17291818#comment-17291818
]
Matthias J. Sax commented on KAFKA-8003:
Different test method
rhauch commented on a change in pull request #10016:
URL: https://github.com/apache/kafka/pull/10016#discussion_r583796206
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java
##
@@ -259,6 +267,16 @@ public void execute() {
Matthias J. Sax created KAFKA-12377:
---
Summary: Flaky Test
SaslAuthenticatorTest#testSslClientAuthRequiredForSaslSslListener
Key: KAFKA-12377
URL: https://issues.apache.org/jira/browse/KAFKA-12377
[
https://issues.apache.org/jira/browse/KAFKA-12376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17291784#comment-17291784
]
Rounak Datta commented on KAFKA-12376:
--
{quote}records that need to be atomic
{quote}
Can you
wcarlson5 commented on a change in pull request #10215:
URL: https://github.com/apache/kafka/pull/10215#discussion_r583787814
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -1047,9 +1047,15 @@ private int getNumStreamThreads(final boolean
[
https://issues.apache.org/jira/browse/KAFKA-12375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17291777#comment-17291777
]
Bruno Cadonna commented on KAFKA-12375:
---
I agree with [~ableegoldman] that ensuring a unique
rhauch commented on a change in pull request #10203:
URL: https://github.com/apache/kafka/pull/10203#discussion_r583780438
##
File path: build.gradle
##
@@ -2026,52 +2043,53 @@ project(':connect:runtime') {
archivesBaseName = "connect-runtime"
dependencies {
-
-
1 - 100 of 152 matches
Mail list logo
