[
https://issues.apache.org/jira/browse/KAFKA-14432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Brutschy updated KAFKA-14432:
---
Priority: Blocker (was: Major)
> RocksDBStore relies on finalizers to not leak memory
> ---
[
https://issues.apache.org/jira/browse/KAFKA-14432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Brutschy updated KAFKA-14432:
---
Fix Version/s: 3.4.0
> RocksDBStore relies on finalizers to not leak memory
> --
divijvaidya commented on PR #12911:
URL: https://github.com/apache/kafka/pull/12911#issuecomment-1340820090
Discarding this PR. We will start a KIP for a better way to handle
modifications of number of partitions for `__consumer_offsets`.
--
This is an automated message from the Apache G
divijvaidya closed pull request #12911: KAFKA-14418: Do not allow modifying
partition of internal topics from admin commands
URL: https://github.com/apache/kafka/pull/12911
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
cadonna commented on code in PR #12935:
URL: https://github.com/apache/kafka/pull/12935#discussion_r1042067136
##
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java:
##
@@ -108,7 +108,9 @@ public class RocksDBStore implements KeyValueStore, BatchWri
divijvaidya commented on PR #12331:
URL: https://github.com/apache/kafka/pull/12331#issuecomment-1340831891
@MPeli what is the latest on this one?
--
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
rajinisivaram commented on PR #12954:
URL: https://github.com/apache/kafka/pull/12954#issuecomment-1340845106
@dajac Thanks for the review, merging to trunk. Will also confirm with
@ableegoldman if we can merge to 3.4 branch.
--
This is an automated message from the Apache Git Service.
To
rajinisivaram merged PR #12954:
URL: https://github.com/apache/kafka/pull/12954
--
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.a
dengziming commented on code in PR #12951:
URL: https://github.com/apache/kafka/pull/12951#discussion_r1042114095
##
bin/kafka-metadata-quorum.sh:
##
@@ -14,4 +14,4 @@
# See the License for the specific language governing permissions and
# limitations under the License.
-exe
lucasbru commented on code in PR #12935:
URL: https://github.com/apache/kafka/pull/12935#discussion_r1042174486
##
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java:
##
@@ -108,7 +108,9 @@ public class RocksDBStore implements KeyValueStore, BatchWr
dengziming commented on code in PR #12961:
URL: https://github.com/apache/kafka/pull/12961#discussion_r1042151200
##
core/src/main/scala/kafka/server/KafkaConfig.scala:
##
@@ -1665,6 +1665,7 @@ class KafkaConfig private(doLog: Boolean, val props:
java.util.Map[_, _], dynami
dengziming commented on PR #12961:
URL: https://github.com/apache/kafka/pull/12961#issuecomment-1340958183
We can close #11042 and #11281 after merging this, but we can take a look to
see whether we can port some useful code.
--
This is an automated message from the Apache Git Service.
To
dengziming merged PR #12912:
URL: https://github.com/apache/kafka/pull/12912
--
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.apac
dengziming commented on code in PR #12797:
URL: https://github.com/apache/kafka/pull/12797#discussion_r1042208012
##
core/src/main/scala/kafka/admin/BrokerApiVersionsCommand.scala:
##
@@ -95,8 +96,6 @@ object BrokerApiVersionsCommand {
def checkArgs(): Unit = {
Com
justinrlee commented on code in PR #12797:
URL: https://github.com/apache/kafka/pull/12797#discussion_r1042238071
##
core/src/main/scala/kafka/admin/BrokerApiVersionsCommand.scala:
##
@@ -95,8 +96,6 @@ object BrokerApiVersionsCommand {
def checkArgs(): Unit = {
Com
justinrlee commented on code in PR #12797:
URL: https://github.com/apache/kafka/pull/12797#discussion_r1042243417
##
core/src/main/scala/kafka/tools/ConsoleConsumer.scala:
##
@@ -218,7 +220,7 @@ object ConsoleConsumer extends Logging {
.withRequiredArg
.describedAs
justinrlee commented on PR #12797:
URL: https://github.com/apache/kafka/pull/12797#issuecomment-1341013617
Hey @dengziming thanks for the review! I can build and test all of this
locally and add output to the PR description. Are you also asking that I add
automated tests for these, or is th
dajac commented on PR #12797:
URL: https://github.com/apache/kafka/pull/12797#issuecomment-1341049038
Do we need a KIP for these changes? It seems that we are changing public
interfaces here.
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
justinrlee commented on PR #12797:
URL: https://github.com/apache/kafka/pull/12797#issuecomment-1341058382
> Do we need a KIP for these changes? It seems that we are changing public
interfaces here.
I was hoping no considering that this is a minor, non-breaking change (all
existing u
dajac commented on PR #12797:
URL: https://github.com/apache/kafka/pull/12797#issuecomment-1341074602
> As an additional quality-of-life change, kafka-console-producer and
kafka-console-consumer also now support --command-config (in addition to
continuing to support --producer.config and --
[
https://issues.apache.org/jira/browse/KAFKA-13878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shaik Zakir Hussain reassigned KAFKA-13878:
---
Assignee: Shaik Zakir Hussain
> Connect deadlock in WorkerConnector on desi
C0urante commented on PR #12955:
URL: https://github.com/apache/kafka/pull/12955#issuecomment-1341129084
@ableegoldman Thanks for taking a look--I agree that a more thorough
refactoring can wait for a follow-up PR.
@gharris1727 I really like the general approach in the new
`Backgroun
David Arthur created KAFKA-14448:
Summary: ZK brokers register with KRaft during migration
Key: KAFKA-14448
URL: https://issues.apache.org/jira/browse/KAFKA-14448
Project: Kafka
Issue Type: S
David Arthur created KAFKA-14447:
Summary: Controlled shutdown for ZK brokers during migration
Key: KAFKA-14447
URL: https://issues.apache.org/jira/browse/KAFKA-14447
Project: Kafka
Issue Typ
mumrah commented on code in PR #12961:
URL: https://github.com/apache/kafka/pull/12961#discussion_r1042322800
##
core/src/main/scala/kafka/server/BrokerToControllerChannelManager.scala:
##
@@ -37,42 +38,53 @@ import scala.collection.Seq
import scala.compat.java8.OptionConverter
mumrah commented on PR #12946:
URL: https://github.com/apache/kafka/pull/12946#issuecomment-1341224855
@dengziming yes, there will be more PRs coming :). We are trying to get the
basics for migration in place for 3.4 as an "early access" feature. If you find
issues or have questions after t
Swathi Mocharla created KAFKA-14449:
---
Summary: Brokers not re-joining the ISR list and stuck at started
until all the brokers restart
Key: KAFKA-14449
URL: https://issues.apache.org/jira/browse/KAFKA-14449
divijvaidya commented on code in PR #11390:
URL: https://github.com/apache/kafka/pull/11390#discussion_r1042140948
##
core/src/main/scala/kafka/server/ReplicaFetcherThread.scala:
##
@@ -192,4 +204,140 @@ class ReplicaFetcherThread(name: String,
partition.truncateFullyAndSta
cmccabe commented on PR #12932:
URL: https://github.com/apache/kafka/pull/12932#issuecomment-1341277577
Thanks for this, @dajac . Can you add a test that the `Invalid default for
struct field` message appears as expected when the default is set to something
other than `null`? `MessageDataGe
yashmayya commented on code in PR #12947:
URL: https://github.com/apache/kafka/pull/12947#discussion_r1042258502
##
connect/runtime/src/main/java/org/apache/kafka/connect/cli/AbstractConnectCli.java:
##
@@ -0,0 +1,123 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) u
yashmayya commented on code in PR #12947:
URL: https://github.com/apache/kafka/pull/12947#discussion_r1042468179
##
connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectStandalone.java:
##
@@ -21,41 +21,51 @@
import org.apache.kafka.common.utils.Utils;
import
org
kirktrue closed pull request #12814: KAFKA-14274: Implement fetching logic
URL: https://github.com/apache/kafka/pull/12814
--
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 un
kirktrue closed pull request #12832: KAFKA-14365: Refactor Fetcher to allow
different implementations 1/2
URL: https://github.com/apache/kafka/pull/12832
--
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
kirktrue closed pull request #12834: KAFKA-14365: Refactor Fetcher to allow
different implementations 2/2
URL: https://github.com/apache/kafka/pull/12834
--
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
Rajini Sivaram created KAFKA-14450:
--
Summary: Rack-aware partition assignment for consumers (KIP-881)
Key: KAFKA-14450
URL: https://issues.apache.org/jira/browse/KAFKA-14450
Project: Kafka
I
[
https://issues.apache.org/jira/browse/KAFKA-14352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rajini Sivaram updated KAFKA-14352:
---
Parent: KAFKA-14450
Issue Type: Sub-task (was: New Feature)
> Support rack-aware pa
Rajini Sivaram created KAFKA-14451:
--
Summary: Make range assignor rack-aware if consumer racks are
configured
Key: KAFKA-14451
URL: https://issues.apache.org/jira/browse/KAFKA-14451
Project: Kafka
Rajini Sivaram created KAFKA-14452:
--
Summary: Make sticky assignors rack-aware if consumer racks are
configured.
Key: KAFKA-14452
URL: https://issues.apache.org/jira/browse/KAFKA-14452
Project: Kafka
mumrah commented on PR #12913:
URL: https://github.com/apache/kafka/pull/12913#issuecomment-1341366297
@mimaison thanks for taking a look. This was a PR for the POC I've been
working on for KIP-866. Now that the KIP is approved, we've started targeting
`trunk`. I'll open a new PR to replace
mumrah closed pull request #12913: KIP-866 Allow ZK brokers to register in KRaft
URL: https://github.com/apache/kafka/pull/12913
--
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.
mjsax commented on code in PR #12944:
URL: https://github.com/apache/kafka/pull/12944#discussion_r1042536401
##
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java:
##
@@ -1076,7 +1082,12 @@ public class StreamsConfig extends AbstractConfig {
T
lihaosky commented on code in PR #12944:
URL: https://github.com/apache/kafka/pull/12944#discussion_r1042544360
##
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java:
##
@@ -1076,7 +1082,12 @@ public class StreamsConfig extends AbstractConfig {
[
https://issues.apache.org/jira/browse/KAFKA-14449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17644466#comment-17644466
]
Swathi Mocharla commented on KAFKA-14449:
-
[~jsancio] , could you take a look?
cmccabe commented on PR #12958:
URL: https://github.com/apache/kafka/pull/12958#issuecomment-1341414560
failing test is unrelated
--
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 comm
cmccabe merged PR #12958:
URL: https://github.com/apache/kafka/pull/12958
--
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.
junrao commented on PR #11390:
URL: https://github.com/apache/kafka/pull/11390#issuecomment-1341457933
@showuon : I plan to take another look at the PR in the next few days.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
akhileshchg commented on code in PR #12961:
URL: https://github.com/apache/kafka/pull/12961#discussion_r1042536606
##
clients/src/main/java/org/apache/kafka/common/requests/AbstractControlRequest.java:
##
@@ -43,6 +49,8 @@ protected AbstractControlRequest(ApiKeys api, short vers
dajac merged PR #12853:
URL: https://github.com/apache/kafka/pull/12853
--
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
hachikuji opened a new pull request, #12963:
URL: https://github.com/apache/kafka/pull/12963
The ID we use for snapshots consists of the exclusive committed offset and
epoch. That is, the offset in the ID is one more than the offset of the last
committed record. This is currently handled a
dajac commented on PR #12932:
URL: https://github.com/apache/kafka/pull/12932#issuecomment-1341640919
> Can you add a test that the Invalid default for struct field message
appears as expected when the default is set to something other than null?
MessageDataGeneratorTest.java has some examp
Chris Egerton created KAFKA-14453:
-
Summary: Flaky test suite
MirrorConnectorsWithCustomForwardingAdminIntegrationTest
Key: KAFKA-14453
URL: https://issues.apache.org/jira/browse/KAFKA-14453
Project:
C0urante commented on PR #12955:
URL: https://github.com/apache/kafka/pull/12955#issuecomment-1341647209
The integration test failures, though worrying, do not appear to be caused
by these changes and have been occurring for some time now. I've filed
https://issues.apache.org/jira/browse/KA
C0urante merged PR #12955:
URL: https://github.com/apache/kafka/pull/12955
--
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
[
https://issues.apache.org/jira/browse/KAFKA-14443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-14443:
--
Affects Version/s: (was: 3.4.0)
> Mirror Maker Connectors leak admin clients used for topi
[
https://issues.apache.org/jira/browse/KAFKA-14443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-14443:
--
Priority: Blocker (was: Critical)
> Mirror Maker Connectors leak admin clients used for topic
C0urante commented on PR #12955:
URL: https://github.com/apache/kafka/pull/12955#issuecomment-1341649696
Merged and backported to the 3.4 release branch.
--
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-14443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17644530#comment-17644530
]
Chris Egerton commented on KAFKA-14443:
---
Merged and backported the fix to the 3.4
cmccabe opened a new pull request, #12964:
URL: https://github.com/apache/kafka/pull/12964
Introduce MetadataProvenance to encapsulate the three-tuple of (offset,
epoch, timestamp) that is associated with each MetadataImage, as well as each
on-disk snapshot.
Remove offset and epoch t
jsancio commented on code in PR #12963:
URL: https://github.com/apache/kafka/pull/12963#discussion_r1042716470
##
core/src/main/scala/kafka/server/metadata/BrokerMetadataPublisher.scala:
##
@@ -261,7 +261,7 @@ class BrokerMetadataPublisher(
if (_firstPublish) {
f
cmccabe commented on code in PR #12961:
URL: https://github.com/apache/kafka/pull/12961#discussion_r1042759981
##
clients/src/main/java/org/apache/kafka/common/requests/LeaderAndIsrRequest.java:
##
@@ -66,10 +75,14 @@ public LeaderAndIsrRequest build(short version) {
cmccabe commented on code in PR #12961:
URL: https://github.com/apache/kafka/pull/12961#discussion_r1042760995
##
clients/src/main/resources/common/message/EnvelopeRequest.json:
##
@@ -16,10 +16,11 @@
{
"apiKey": 58,
"type": "request",
- "listeners": ["controller"],
+ "
cmccabe commented on code in PR #12961:
URL: https://github.com/apache/kafka/pull/12961#discussion_r1042763145
##
core/src/main/scala/kafka/server/BrokerToControllerChannelManager.scala:
##
@@ -37,42 +38,55 @@ import scala.collection.Seq
import scala.compat.java8.OptionConverte
cmccabe commented on code in PR #12961:
URL: https://github.com/apache/kafka/pull/12961#discussion_r1042763929
##
core/src/main/scala/kafka/server/BrokerToControllerChannelManager.scala:
##
@@ -164,25 +184,63 @@ class BrokerToControllerChannelManagerImpl(
private val logConte
cmccabe commented on PR #12961:
URL: https://github.com/apache/kafka/pull/12961#issuecomment-1341714694
I think the better approach to take here would be to make the
`ControllerNodeProvider` return a tuple of `(isKraft, controller id)` and then
have it check the metadata cache to see if it
hachikuji commented on code in PR #12862:
URL: https://github.com/apache/kafka/pull/12862#discussion_r1042773463
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CoordinatorRequestManager.java:
##
@@ -0,0 +1,303 @@
+/*
+ * Licensed to the Apache Software Foun
philipnee commented on code in PR #12862:
URL: https://github.com/apache/kafka/pull/12862#discussion_r1042792698
##
clients/src/main/java/org/apache/kafka/common/requests/FindCoordinatorResponse.java:
##
@@ -50,6 +52,22 @@ public FindCoordinatorResponse(FindCoordinatorResponseDa
hachikuji commented on code in PR #12945:
URL: https://github.com/apache/kafka/pull/12945#discussion_r1042793295
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetsFinder.java:
##
@@ -0,0 +1,805 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
mumrah opened a new pull request, #12965:
URL: https://github.com/apache/kafka/pull/12965
Prior to starting a KIP-866 migration, the ZK brokers must register
themselves with the active KRaft controller. The controller waits for all
brokers to register in order to verify that all the brokers
kirktrue commented on code in PR #12945:
URL: https://github.com/apache/kafka/pull/12945#discussion_r1042805066
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetsFinder.java:
##
@@ -0,0 +1,805 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
jsancio commented on code in PR #12963:
URL: https://github.com/apache/kafka/pull/12963#discussion_r1042809968
##
core/src/test/scala/unit/kafka/server/metadata/BrokerMetadataListenerTest.scala:
##
@@ -166,15 +172,15 @@ class BrokerMetadataListenerTest {
image = newImage
jolshan opened a new pull request, #12966:
URL: https://github.com/apache/kafka/pull/12966
To handle the server side, we will leave it to the client to timeout and
retry forever (long max) for now. I've also configured the poll on the array
blocking queue to this value.
In the future
jsancio commented on code in PR #12963:
URL: https://github.com/apache/kafka/pull/12963#discussion_r1042828301
##
core/src/test/scala/unit/kafka/utils/TestUtils.scala:
##
@@ -1230,7 +1230,7 @@ object TestUtils extends Logging {
TestUtils.waitUntilTrue(
() => {
ableegoldman commented on code in PR #12935:
URL: https://github.com/apache/kafka/pull/12935#discussion_r1042855507
##
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java:
##
@@ -526,6 +521,9 @@ public synchronized void close() {
fOptions.cl
ableegoldman commented on code in PR #12935:
URL: https://github.com/apache/kafka/pull/12935#discussion_r1042856605
##
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java:
##
@@ -526,6 +521,9 @@ public synchronized void close() {
fOptions.cl
dengziming commented on PR #12797:
URL: https://github.com/apache/kafka/pull/12797#issuecomment-1341885319
> This part definitely needs one because we introduce a new command line
argument.
Yes, I agree with you, we can't add/delete/change arguments without a KIP.
in this PR, I think
ableegoldman commented on code in PR #12935:
URL: https://github.com/apache/kafka/pull/12935#discussion_r1042857583
##
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java:
##
@@ -229,40 +230,34 @@ void openDB(final Map configs, final File
stateDir)
ableegoldman commented on PR #12935:
URL: https://github.com/apache/kafka/pull/12935#issuecomment-1341889792
I did look over this and it seems reasonable but I'll refer to @cadonna's
evaluation here as the expert on RocksDB metrics/statistics. Since he approved
and the build passed (modulo
Sagar Rao created KAFKA-14454:
-
Summary:
KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest#shouldThrowIllegalArgumentExceptionWhenCustomPartionerReturnsMultiplePartitions
passes when run individually but not when is run as part of the I
ableegoldman merged PR #12935:
URL: https://github.com/apache/kafka/pull/12935
--
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.ap
ableegoldman commented on PR #12935:
URL: https://github.com/apache/kafka/pull/12935#issuecomment-1341892785
Merged to trunk and cherrypicked 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 t
ableegoldman merged PR #12960:
URL: https://github.com/apache/kafka/pull/12960
--
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.ap
[
https://issues.apache.org/jira/browse/KAFKA-14432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-14432.
Resolution: Fixed
> RocksDBStore relies on finalizers to not leak memory
>
ableegoldman commented on PR #12955:
URL: https://github.com/apache/kafka/pull/12955#issuecomment-1341916089
Thanks guys, appreciate you splitting out the refactoring even though it's a
hassle (and maybe doesn't feel as good) 🙏
--
This is an automated message from the Apache Git Service.
philipnee commented on code in PR #12862:
URL: https://github.com/apache/kafka/pull/12862#discussion_r1042900099
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CoordinatorRequestManager.java:
##
@@ -0,0 +1,303 @@
+/*
+ * Licensed to the Apache Software Foun
philipnee commented on code in PR #12862:
URL: https://github.com/apache/kafka/pull/12862#discussion_r1042905241
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/DefaultBackgroundThread.java:
##
@@ -50,57 +49,83 @@ public class DefaultBackgroundThread extends
ableegoldman commented on code in PR #12962:
URL: https://github.com/apache/kafka/pull/12962#discussion_r1042911388
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentTestUtils.java:
##
@@ -112,6 +113,56 @@ public final class AssignmentTes
[
https://issues.apache.org/jira/browse/KAFKA-12886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17644601#comment-17644601
]
Deng Ziming commented on KAFKA-12886:
-
KAFKA-14446 will enable forwarding for migrat
tikimims commented on code in PR #12941:
URL: https://github.com/apache/kafka/pull/12941#discussion_r1042930128
##
docs/connect.html:
##
@@ -369,6 +369,114 @@ Error Reportin
# Tolerate all errors.
errors.tolerance=all
+Exactly-once
support
+
+Kafka Connect is capabl
tikimims commented on code in PR #12941:
URL: https://github.com/apache/kafka/pull/12941#discussion_r1042935917
##
docs/connect.html:
##
@@ -369,6 +369,114 @@ Error Reportin
# Tolerate all errors.
errors.tolerance=all
+Exactly-once
support
+
+Kafka Connect is capabl
tikimims commented on code in PR #12941:
URL: https://github.com/apache/kafka/pull/12941#discussion_r1042936427
##
docs/connect.html:
##
@@ -369,6 +369,114 @@ Error Reportin
# Tolerate all errors.
errors.tolerance=all
+Exactly-once
support
+
+Kafka Connect is capabl
tikimims commented on code in PR #12941:
URL: https://github.com/apache/kafka/pull/12941#discussion_r1042935917
##
docs/connect.html:
##
@@ -369,6 +369,114 @@ Error Reportin
# Tolerate all errors.
errors.tolerance=all
+Exactly-once
support
+
+Kafka Connect is capabl
tikimims commented on code in PR #12941:
URL: https://github.com/apache/kafka/pull/12941#discussion_r1042942666
##
docs/connect.html:
##
@@ -369,6 +369,114 @@ Error Reportin
# Tolerate all errors.
errors.tolerance=all
+Exactly-once
support
+
+Kafka Connect is capabl
tikimims commented on code in PR #12941:
URL: https://github.com/apache/kafka/pull/12941#discussion_r1042943030
##
docs/connect.html:
##
@@ -369,6 +369,114 @@ Error Reportin
# Tolerate all errors.
errors.tolerance=all
+Exactly-once
support
+
+Kafka Connect is capabl
tikimims commented on code in PR #12941:
URL: https://github.com/apache/kafka/pull/12941#discussion_r104291
##
docs/connect.html:
##
@@ -593,6 +701,107 @@ Resuming from Previous Off
Of course, you might need to read many keys for each of the input
streams. The Offset
tikimims commented on code in PR #12941:
URL: https://github.com/apache/kafka/pull/12941#discussion_r1042945330
##
docs/connect.html:
##
@@ -593,6 +701,107 @@ Resuming from Previous Off
Of course, you might need to read many keys for each of the input
streams. The Offset
tikimims commented on code in PR #12941:
URL: https://github.com/apache/kafka/pull/12941#discussion_r1042946060
##
docs/connect.html:
##
@@ -593,6 +701,107 @@ Resuming from Previous Off
Of course, you might need to read many keys for each of the input
streams. The Offset
tikimims commented on code in PR #12941:
URL: https://github.com/apache/kafka/pull/12941#discussion_r1042946621
##
docs/connect.html:
##
@@ -593,6 +701,107 @@ Resuming from Previous Off
Of course, you might need to read many keys for each of the input
streams. The Offset
tikimims commented on code in PR #12941:
URL: https://github.com/apache/kafka/pull/12941#discussion_r1042947164
##
docs/connect.html:
##
@@ -369,6 +369,114 @@ Error Reportin
# Tolerate all errors.
errors.tolerance=all
+Exactly-once
support
+
+Kafka Connect is capabl
tikimims commented on code in PR #12941:
URL: https://github.com/apache/kafka/pull/12941#discussion_r1042949185
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedConfig.java:
##
@@ -232,9 +232,12 @@ public String toString() {
public
tikimims commented on PR #12941:
URL: https://github.com/apache/kafka/pull/12941#issuecomment-1342083368
Hi @C0urante I took a first pass. :) Let me know if you'd like me to take
another pass after any updates. 👍
--
This is an automated message from the Apache Git Service.
To respond to
1 - 100 of 103 matches
Mail list logo
