dengziming opened a new pull request #10400:
URL: https://github.com/apache/kafka/pull/10400
*More detailed description of your change*
We set the package name to `kafka.xxx` in all other classes, so also reset
the package name `IntegrationTestUtils` to `kafka.server`
*Summary of
[
https://issues.apache.org/jira/browse/KAFKA-10575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308411#comment-17308411
]
highluck commented on KAFKA-10575:
--
[~ableegoldman]
Yes, I am willing to work. However
kamalcph edited a comment on pull request #10202:
URL: https://github.com/apache/kafka/pull/10202#issuecomment-806380925
@chia7712 @tombentley
Can you comment/upvote on the KIP to deprecate this config?
--
This is an automated message from the Apache Git Service.
To respond to the mes
kamalcph commented on pull request #10202:
URL: https://github.com/apache/kafka/pull/10202#issuecomment-806380925
@chia7712
Can you comment/upvote on the KIP to deprecate this config?
--
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-12478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308383#comment-17308383
]
Guozhang Wang commented on KAFKA-12478:
---
Hello [~hudeqi] Thanks for the updates. I
[
https://issues.apache.org/jira/browse/KAFKA-12549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12549:
--
Description:
Right now Kafka Stream's EOS implementation does not make any assumptions about
satishd commented on pull request #10218:
URL: https://github.com/apache/kafka/pull/10218#issuecomment-806359943
@kowshik I discussed the proposed changes in the call on 23rd, and I
mentioned that PR is not updated with those changes. I will let you know once
those changes are pushed into
ijuma edited a comment on pull request #10399:
URL: https://github.com/apache/kafka/pull/10399#issuecomment-806344373
JDK 8:
JDK 11:
JDK 11:
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI buil
ijuma merged pull request #10394:
URL: https://github.com/apache/kafka/pull/10394
--
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.
For queries about this service, please c
[
https://issues.apache.org/jira/browse/KAFKA-12434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-12434.
-
Resolution: Fixed
> Admin API for DescribeProducers
> ---
>
[
https://issues.apache.org/jira/browse/KAFKA-12434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-12434:
Fix Version/s: 3.0.0
> Admin API for DescribeProducers
> ---
>
hachikuji merged pull request #10275:
URL: https://github.com/apache/kafka/pull/10275
--
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.
For queries about this service, plea
hachikuji commented on pull request #10275:
URL: https://github.com/apache/kafka/pull/10275#issuecomment-806331897
Merging to trunk. @chia7712 Yeah, we should create some jiras. I was going
to wait until the other use cases in KIP-664 had been fleshed out, but I guess
there's no harm conve
[
https://issues.apache.org/jira/browse/KAFKA-12540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308320#comment-17308320
]
Antony Stubbs commented on KAFKA-12540:
---
Yes Sophie, I think having the links is g
hachikuji opened a new pull request #10398:
URL: https://github.com/apache/kafka/pull/10398
I noticed this test hanging frequently locally. There is a race condition
between the background thread calling `ready` and the call to `MockTime.sleep`
in the test. If the call to `sleep` happens f
A. Sophie Blee-Goldman created KAFKA-12550:
--
Summary: Introduce RESTORING state to the KafkaStreams FSM
Key: KAFKA-12550
URL: https://issues.apache.org/jira/browse/KAFKA-12550
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308310#comment-17308310
]
A. Sophie Blee-Goldman commented on KAFKA-9430:
---
Hey [~vinoth] are you stil
[
https://issues.apache.org/jira/browse/KAFKA-10575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308309#comment-17308309
]
A. Sophie Blee-Goldman commented on KAFKA-10575:
[~high.lee] have you be
[
https://issues.apache.org/jira/browse/KAFKA-12468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308308#comment-17308308
]
Alan commented on KAFKA-12468:
--
I am seeing similar issue as well. I am also using a custom
[
https://issues.apache.org/jira/browse/KAFKA-9846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-9846.
---
Resolution: Fixed
Resolving since this is fixed in 2.6
> Race condition can
[
https://issues.apache.org/jira/browse/KAFKA-10532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-10532:
---
Labels: newbie++ (was: )
> Do not wipe state store under EOS when closing-d
[
https://issues.apache.org/jira/browse/KAFKA-8165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308302#comment-17308302
]
A. Sophie Blee-Goldman commented on KAFKA-8165:
---
[~xmar] IIRC there actuall
[
https://issues.apache.org/jira/browse/KAFKA-8042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-8042.
---
Fix Version/s: 2.6.0
Resolution: Fixed
I believe this issue should be
[
https://issues.apache.org/jira/browse/KAFKA-7213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-7213.
---
Resolution: Fixed
I think we can close this as the version is quite old now a
[
https://issues.apache.org/jira/browse/KAFKA-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-5256.
---
Resolution: Fixed
Closing this since the described behavior is now implemente
[
https://issues.apache.org/jira/browse/KAFKA-12538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308289#comment-17308289
]
A. Sophie Blee-Goldman commented on KAFKA-12538:
Note that this will be
[
https://issues.apache.org/jira/browse/KAFKA-12540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308284#comment-17308284
]
A. Sophie Blee-Goldman commented on KAFKA-12540:
Can we close this as a
[
https://issues.apache.org/jira/browse/KAFKA-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman reassigned KAFKA-7606:
-
Assignee: (was: Srinivas Reddy)
> Remove deprecated options from Str
[
https://issues.apache.org/jira/browse/KAFKA-12419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308274#comment-17308274
]
A. Sophie Blee-Goldman commented on KAFKA-12419:
[~guozhang] there are a
[
https://issues.apache.org/jira/browse/KAFKA-12526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308251#comment-17308251
]
A. Sophie Blee-Goldman commented on KAFKA-12526:
Cool thanks. I've pinge
[
https://issues.apache.org/jira/browse/KAFKA-12527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308245#comment-17308245
]
Guozhang Wang commented on KAFKA-12527:
---
Ah yes, thanks!
> Remove deprecated "Par
[
https://issues.apache.org/jira/browse/KAFKA-12526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308243#comment-17308243
]
Guozhang Wang commented on KAFKA-12526:
---
Yes, I think this may be a subset of KAFK
[
https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308240#comment-17308240
]
A. Sophie Blee-Goldman commented on KAFKA-10493:
What's the status here,
[
https://issues.apache.org/jira/browse/KAFKA-8531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308238#comment-17308238
]
A. Sophie Blee-Goldman commented on KAFKA-8531:
---
Hey [~mjsax], are you plan
[
https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308235#comment-17308235
]
Chris Egerton commented on KAFKA-12463:
---
Thanks [~kkonstantine]--I'll admit I was
[
https://issues.apache.org/jira/browse/KAFKA-12527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308234#comment-17308234
]
A. Sophie Blee-Goldman commented on KAFKA-12527:
Seems like a duplicate
[
https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-12463:
--
Labels: needs-kip (was: )
> Update default consumer partition assignor for sink tasks
> -
[
https://issues.apache.org/jira/browse/KAFKA-12527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman reassigned KAFKA-12527:
--
Assignee: Guozhang Wang
> Remove deprecated "PartitionGrouper" interf
[
https://issues.apache.org/jira/browse/KAFKA-12526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308233#comment-17308233
]
A. Sophie Blee-Goldman commented on KAFKA-12526:
[~guozhang] To clarify,
[
https://issues.apache.org/jira/browse/KAFKA-7106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman reassigned KAFKA-7106:
-
Assignee: Guozhang Wang
> Remove segment/segmentInterval from Window def
jsancio commented on a change in pull request #10085:
URL: https://github.com/apache/kafka/pull/10085#discussion_r600926563
##
File path: raft/src/main/java/org/apache/kafka/raft/ReplicatedCounter.java
##
@@ -87,6 +96,25 @@ public synchronized void handleCommit(BatchReader
rea
jsancio commented on a change in pull request #10085:
URL: https://github.com/apache/kafka/pull/10085#discussion_r600926104
##
File path: raft/src/main/java/org/apache/kafka/snapshot/SnapshotReader.java
##
@@ -0,0 +1,153 @@
+/*
+ * Licensed to the Apache Software Foundation (AS
Guozhang Wang created KAFKA-12549:
-
Summary: Allow state stores to opt-in transactional support
Key: KAFKA-12549
URL: https://issues.apache.org/jira/browse/KAFKA-12549
Project: Kafka
Issue Ty
jsancio commented on a change in pull request #10085:
URL: https://github.com/apache/kafka/pull/10085#discussion_r600925523
##
File path: raft/src/main/java/org/apache/kafka/raft/ReplicatedCounter.java
##
@@ -87,6 +96,25 @@ public synchronized void handleCommit(BatchReader
rea
[
https://issues.apache.org/jira/browse/KAFKA-7025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308102#comment-17308102
]
Nikolai Lubiagov edited comment on KAFKA-7025 at 3/24/21, 10:24 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-12548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-12548:
Summary: Invalid record error message is not getting sent to application
(was: Invalid re
Jason Gustafson created KAFKA-12548:
---
Summary: Invalid record error is not getting sent to application
Key: KAFKA-12548
URL: https://issues.apache.org/jira/browse/KAFKA-12548
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-8784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308198#comment-17308198
]
A. Sophie Blee-Goldman commented on KAFKA-8784:
---
Hey [~sbellapu], are you s
[
https://issues.apache.org/jira/browse/KAFKA-10046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308197#comment-17308197
]
A. Sophie Blee-Goldman edited comment on KAFKA-10046 at 3/24/21, 9:52 PM:
[
https://issues.apache.org/jira/browse/KAFKA-10046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-10046:
---
Fix Version/s: 3.0.0
> Deprecated PartitionGrouper config is ignored
> -
[
https://issues.apache.org/jira/browse/KAFKA-10046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308197#comment-17308197
]
A. Sophie Blee-Goldman commented on KAFKA-10046:
We're removing this con
ableegoldman commented on pull request #10302:
URL: https://github.com/apache/kafka/pull/10302#issuecomment-806209047
Seems like we have two seemingly identical tickets & PRs for this --
https://github.com/apache/kafka/pull/10380
cc @guozhangwang @highluck
--
This is an automated mes
ableegoldman commented on pull request #10397:
URL: https://github.com/apache/kafka/pull/10397#issuecomment-806194636
Ah ok, I saw the KIP had included "any aggregation or repartition operation"
in addition to the source KTable but I guess this just hasn't been implemented
yet. Looks like
A. Sophie Blee-Goldman created KAFKA-12547:
--
Summary: Drop idempotent updates for repartition operations
Key: KAFKA-12547
URL: https://issues.apache.org/jira/browse/KAFKA-12547
Project: Kafka
ijuma commented on a change in pull request #10173:
URL: https://github.com/apache/kafka/pull/10173#discussion_r600881585
##
File path:
clients/src/main/java/org/apache/kafka/server/log/remote/storage/LogSegmentData.java
##
@@ -0,0 +1,139 @@
+/*
+ * Licensed to the Apache Soft
A. Sophie Blee-Goldman created KAFKA-12546:
--
Summary: Drop idempotent updates for aggregations
Key: KAFKA-12546
URL: https://issues.apache.org/jira/browse/KAFKA-12546
Project: Kafka
ableegoldman commented on a change in pull request #10387:
URL: https://github.com/apache/kafka/pull/10387#discussion_r600875808
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -492,22 +492,18 @@ private void handleStreamsUncaughtException(f
[
https://issues.apache.org/jira/browse/KAFKA-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308175#comment-17308175
]
A. Sophie Blee-Goldman commented on KAFKA-9552:
---
Hey guys, what's the curre
kevin j staiger created KAFKA-12544:
---
Summary: Particular partitions lagging and consumers
intermittently reading
Key: KAFKA-12544
URL: https://issues.apache.org/jira/browse/KAFKA-12544
Project: Kaf
[
https://issues.apache.org/jira/browse/KAFKA-12544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
kevin j staiger updated KAFKA-12544:
Description: Hi, we are experiencing a strange issue with a kafka topic
where is seems lik
jsancio commented on a change in pull request #10085:
URL: https://github.com/apache/kafka/pull/10085#discussion_r600789602
##
File path: raft/src/main/java/org/apache/kafka/raft/ReplicatedCounter.java
##
@@ -87,6 +96,25 @@ public synchronized void handleCommit(BatchReader
rea
jsancio commented on a change in pull request #10085:
URL: https://github.com/apache/kafka/pull/10085#discussion_r600813565
##
File path: raft/src/test/java/org/apache/kafka/raft/MockLog.java
##
@@ -418,48 +414,49 @@ public RawSnapshotWriter createSnapshot(OffsetAndEpoch
snaps
Jose Armando Garcia Sancio created KAFKA-12545:
--
Summary: Integrate snapshot in the shell tool
Key: KAFKA-12545
URL: https://issues.apache.org/jira/browse/KAFKA-12545
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-10819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio reassigned KAFKA-10819:
--
Assignee: (was: Jose Armando Garcia Sancio)
> The freeze
vvcephei commented on pull request #10397:
URL: https://github.com/apache/kafka/pull/10397#issuecomment-806152365
Thanks, @ableegoldman !
As far as I know this was the only operator we updated to KIP-557.
This is the only commit I find referencing the KIP:
https://github.com/
[
https://issues.apache.org/jira/browse/KAFKA-10800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio reassigned KAFKA-10800:
--
Assignee: (was: Jose Armando Garcia Sancio)
> Validate th
ableegoldman commented on a change in pull request #10397:
URL: https://github.com/apache/kafka/pull/10397#discussion_r600832696
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableSourceTest.java
##
@@ -91,6 +92,7 @@ public void testKTable() {
vvcephei commented on a change in pull request #10397:
URL: https://github.com/apache/kafka/pull/10397#discussion_r600834715
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableSourceTest.java
##
@@ -91,6 +92,7 @@ public void testKTable() {
[
https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman reassigned KAFKA-4327:
-
Assignee: (was: Jorge Esteban Quilcate Otoya)
> Move Reset Tool from
[
https://issues.apache.org/jira/browse/KAFKA-7870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308153#comment-17308153
]
Tyran commented on KAFKA-7870:
--
Picked up a similar issue in 2.7 which causes the entire clu
vvcephei merged pull request #10386:
URL: https://github.com/apache/kafka/pull/10386
--
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.
For queries about this service, pleas
[
https://issues.apache.org/jira/browse/KAFKA-12513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308136#comment-17308136
]
Krzysztof Piecuch commented on KAFKA-12513:
---
Looking at the ConnectStringParse
dosvath commented on pull request #10375:
URL: https://github.com/apache/kafka/pull/10375#issuecomment-806084689
Thanks @kkonstantine I updated the 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 abov
vvcephei merged pull request #10392:
URL: https://github.com/apache/kafka/pull/10392
--
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.
For queries about this service, pleas
[
https://issues.apache.org/jira/browse/KAFKA-7025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308102#comment-17308102
]
Nikolai Lubiagov edited comment on KAFKA-7025 at 3/24/21, 6:51 PM:
vvcephei commented on pull request #10397:
URL: https://github.com/apache/kafka/pull/10397#issuecomment-806071340
Hey @ableegoldman @cadonna, can you spare a quick review here?
All I did was revert the KTableSourceProcessor to its state before the
KIP-557 implementation. I just ignor
vvcephei opened a new pull request #10397:
URL: https://github.com/apache/kafka/pull/10397
A major issue has been raised that this implementation of
emit-on-change is vulnerable to a number of data-loss bugs
in the presence of recovery with dirty state under at-least-once
semantics.
vvcephei commented on pull request #10392:
URL: https://github.com/apache/kafka/pull/10392#issuecomment-806067123
Ok, I've tested this fix locally, and it looks like, although we have some
flaky test failures, the builds are still functioning.
--
This is an automated message from the Apa
[
https://issues.apache.org/jira/browse/KAFKA-7025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308102#comment-17308102
]
Nikolai Lubiagov edited comment on KAFKA-7025 at 3/24/21, 6:35 PM:
[
https://issues.apache.org/jira/browse/KAFKA-7025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308102#comment-17308102
]
Nikolai Lubiagov edited comment on KAFKA-7025 at 3/24/21, 6:34 PM:
Jose Armando Garcia Sancio created KAFKA-12543:
--
Summary: Re-design the ownership model for snapshots
Key: KAFKA-12543
URL: https://issues.apache.org/jira/browse/KAFKA-12543
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-7025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308102#comment-17308102
]
Nikolai Lubiagov edited comment on KAFKA-7025 at 3/24/21, 6:31 PM:
[
https://issues.apache.org/jira/browse/KAFKA-7025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308102#comment-17308102
]
Nikolai Lubiagov commented on KAFKA-7025:
-
For me interested other question, how
C0urante commented on pull request #10396:
URL: https://github.com/apache/kafka/pull/10396#issuecomment-806057436
@gharris1727 @ncliang either of you care to take a look?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
C0urante opened a new pull request #10396:
URL: https://github.com/apache/kafka/pull/10396
[Jira](https://issues.apache.org/jira/browse/KAFKA-12474)
If a distributed worker fails to write (or read back) a new session key
to/from the config topic, it dies.
This fix softens the
[
https://issues.apache.org/jira/browse/KAFKA-12540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308091#comment-17308091
]
Antony Stubbs commented on KAFKA-12540:
---
Ah yes! Totally - thanks! Now we have the
cmccabe merged pull request #10281:
URL: https://github.com/apache/kafka/pull/10281
--
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.
For queries about this service, please
[
https://issues.apache.org/jira/browse/KAFKA-12508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308063#comment-17308063
]
John Roesler commented on KAFKA-12508:
--
Thanks [~cmaus] , I think you're right.
Si
[
https://issues.apache.org/jira/browse/KAFKA-12508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reopened KAFKA-12508:
--
Assignee: John Roesler (was: Bruno Cadonna)
> Emit-on-change tables may lose updates on err
[
https://issues.apache.org/jira/browse/KAFKA-12542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308053#comment-17308053
]
Guozhang Wang commented on KAFKA-12542:
---
Hi [~sinhash]
I cannot tell if `dlqTopic
vvcephei commented on a change in pull request #10392:
URL: https://github.com/apache/kafka/pull/10392#discussion_r600715320
##
File path: build.gradle
##
@@ -1622,7 +1622,6 @@ project(':streams:test-utils') {
javadoc {
include "**/org/apache/kafka/streams/test/**"
-
spena commented on a change in pull request #10331:
URL: https://github.com/apache/kafka/pull/10331#discussion_r600706763
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedWindowStoreBuilder.java
##
@@ -0,0 +1,80 @@
+/*
+ * Licensed to the
spena commented on pull request #10331:
URL: https://github.com/apache/kafka/pull/10331#issuecomment-806018503
@guozhangwang I just replace this PR with only the changes for the
`RocksDBTimeOrderedWindowStore`. I will create other PRs with your suggestions.
--
This is an automated messag
wcarlson5 commented on a change in pull request #10387:
URL: https://github.com/apache/kafka/pull/10387#discussion_r600698092
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -631,6 +625,14 @@ public void setStreamsUncaug
chia7712 commented on pull request #10389:
URL: https://github.com/apache/kafka/pull/10389#issuecomment-806010778
merge trunk to trigger QA again.
--
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 a change in pull request #10392:
URL: https://github.com/apache/kafka/pull/10392#discussion_r600696771
##
File path: build.gradle
##
@@ -1622,7 +1622,6 @@ project(':streams:test-utils') {
javadoc {
include "**/org/apache/kafka/streams/test/**"
-
1 - 100 of 156 matches
Mail list logo
