[
https://issues.apache.org/jira/browse/KAFKA-12526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17308243#comment-17308243
]
Guozhang Wang commented on KAFKA-12526:
---
Yes, I think this may be a subset of KAFKA-10434, it only
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
[
https://issues.apache.org/jira/browse/KAFKA-12542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17308053#comment-17308053
]
Guozhang Wang commented on KAFKA-12542:
---
Hi [~sinhash]
I cannot tell if `dlqTopic:outputTopic` is
[
https://issues.apache.org/jira/browse/KAFKA-12527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12527:
--
Summary: Remove deprecated "PartitionGrouper" interface (was: Remove
deprecated
Guozhang Wang created KAFKA-12527:
-
Summary: Remove deprecated "PartitionAssignor" interface
Key: KAFKA-12527
URL: https://issues.apache.org/jira/browse/KAFKA-12527
Project: Kafka
Issue
Guozhang Wang created KAFKA-12526:
-
Summary: Remove deprecated long ms overloads
Key: KAFKA-12526
URL: https://issues.apache.org/jira/browse/KAFKA-12526
Project: Kafka
Issue Type: Sub-task
Guozhang Wang created KAFKA-12524:
-
Summary: Remove deprecated WindowBytesStoreSupplier#segments
Key: KAFKA-12524
URL: https://issues.apache.org/jira/browse/KAFKA-12524
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-12472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306618#comment-17306618
]
Guozhang Wang commented on KAFKA-12472:
---
I'm now actually thinking, that for transition rules we
[
https://issues.apache.org/jira/browse/KAFKA-10830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306616#comment-17306616
]
Guozhang Wang commented on KAFKA-10830:
---
Hi [~dongjin], I think [~bchen225242] is trying to tackle
[
https://issues.apache.org/jira/browse/KAFKA-12514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-12514.
---
Fix Version/s: 3.0.0
Resolution: Fixed
> NPE in SubscriptionState
>
[
https://issues.apache.org/jira/browse/KAFKA-12477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306465#comment-17306465
]
Guozhang Wang commented on KAFKA-12477:
---
Thanks! After reviewing the PR I think I get it that we
[
https://issues.apache.org/jira/browse/KAFKA-12519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306460#comment-17306460
]
Guozhang Wang commented on KAFKA-12519:
---
Hmm, do you mean that, when user upgrade to 3.0, even
[
https://issues.apache.org/jira/browse/KAFKA-12506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12506:
--
Description:
Right now the AdjustStreamThreadCountTest runs a minimal topology that just
[
https://issues.apache.org/jira/browse/KAFKA-12506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12506:
--
Description:
Right now the AdjustStreamThreadCountTest runs a minimal topology that just
[
https://issues.apache.org/jira/browse/KAFKA-12519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306340#comment-17306340
]
Guozhang Wang commented on KAFKA-12519:
---
Hello Bruno, just to clarify: you are suggesting we
[
https://issues.apache.org/jira/browse/KAFKA-12503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17304523#comment-17304523
]
Guozhang Wang commented on KAFKA-12503:
---
Thanks for the summary [~wcarlson5] [~ableegoldman]. I'm
[
https://issues.apache.org/jira/browse/KAFKA-12472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12472:
--
Description:
Today to trouble shoot a rebalance issue operators need to do a lot of manual
[
https://issues.apache.org/jira/browse/KAFKA-12472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12472:
--
Description:
Today to trouble shoot a rebalance issue operators need to do a lot of manual
[
https://issues.apache.org/jira/browse/KAFKA-12472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17304295#comment-17304295
]
Guozhang Wang commented on KAFKA-12472:
---
I just added a few more states for Streams, regarding
[
https://issues.apache.org/jira/browse/KAFKA-12464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12464:
--
Labels: perfomance (was: )
> Enhance constrained sticky Assign algorithm
>
[
https://issues.apache.org/jira/browse/KAFKA-12464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12464:
--
Component/s: streams
> Enhance constrained sticky Assign algorithm
>
[
https://issues.apache.org/jira/browse/KAFKA-12478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303739#comment-17303739
]
Guozhang Wang commented on KAFKA-12478:
---
Hello [~hudeqi] this is a valid concern. One workaround
[
https://issues.apache.org/jira/browse/KAFKA-12475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303700#comment-17303700
]
Guozhang Wang commented on KAFKA-12475:
---
+1 to [~cadonna]. I've seen some people using remote
[
https://issues.apache.org/jira/browse/KAFKA-12472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303621#comment-17303621
]
Guozhang Wang edited comment on KAFKA-12472 at 3/17/21, 6:31 PM:
-
Good
[
https://issues.apache.org/jira/browse/KAFKA-12472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303621#comment-17303621
]
Guozhang Wang edited comment on KAFKA-12472 at 3/17/21, 5:55 PM:
-
Good
[
https://issues.apache.org/jira/browse/KAFKA-12472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303621#comment-17303621
]
Guozhang Wang commented on KAFKA-12472:
---
Good questions. I'd like to dump some of my rough
[
https://issues.apache.org/jira/browse/KAFKA-12477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302260#comment-17302260
]
Guozhang Wang edited comment on KAFKA-12477 at 3/16/21, 6:56 AM:
-
I
[
https://issues.apache.org/jira/browse/KAFKA-12477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302260#comment-17302260
]
Guozhang Wang edited comment on KAFKA-12477 at 3/16/21, 6:55 AM:
-
I
[
https://issues.apache.org/jira/browse/KAFKA-12477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302260#comment-17302260
]
Guozhang Wang commented on KAFKA-12477:
---
I think this is a reasonable idea. Just clarifying one
[
https://issues.apache.org/jira/browse/KAFKA-10518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10518:
--
Component/s: consumer
> Consumer fetches could be inefficient when lags are unbalanced
>
[
https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302191#comment-17302191
]
Guozhang Wang commented on KAFKA-12463:
---
Connect does not use ConsumerCoordinator but implements
[
https://issues.apache.org/jira/browse/KAFKA-12472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302186#comment-17302186
]
Guozhang Wang commented on KAFKA-12472:
---
Re. 1/2: Makes sense. I can distinguish them.
Re. 3: My
[
https://issues.apache.org/jira/browse/KAFKA-12473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302178#comment-17302178
]
Guozhang Wang commented on KAFKA-12473:
---
Thanks for filing this [~ableegoldman]! The plan SGTM.
>
[
https://issues.apache.org/jira/browse/KAFKA-12472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12472:
--
Description:
Today to trouble shoot a rebalance issue operators need to do a lot of manual
[
https://issues.apache.org/jira/browse/KAFKA-12472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12472:
--
Description:
Today to trouble shoot a rebalance issue operators need to do a lot of manual
[
https://issues.apache.org/jira/browse/KAFKA-12472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12472:
--
Description:
Today to trouble shoot a rebalance issue operators need to do a lot of manual
[
https://issues.apache.org/jira/browse/KAFKA-12472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12472:
--
Description:
Today to trouble shoot a rebalance issue operators need to do a lot of manual
[
https://issues.apache.org/jira/browse/KAFKA-12472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12472:
--
Description:
Today to trouble shoot a rebalance issue operators need to do a lot of manual
[
https://issues.apache.org/jira/browse/KAFKA-12472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12472:
--
Description:
Today to trouble shoot a rebalance issue operators need to do a lot of manual
Guozhang Wang created KAFKA-12472:
-
Summary: Add a Consumer / Streams metric to indicate the current
rebalance status
Key: KAFKA-12472
URL: https://issues.apache.org/jira/browse/KAFKA-12472
Project:
[
https://issues.apache.org/jira/browse/KAFKA-12428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12428:
--
Labels: newbie++ (was: newbie)
> Add a last-heartbeat-seconds-ago metric to Kafka Consumer
>
[
https://issues.apache.org/jira/browse/KAFKA-12460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12460:
--
Description: Eventually we will have to come up with some approach to
recover from committed
[
https://issues.apache.org/jira/browse/KAFKA-12446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17299967#comment-17299967
]
Guozhang Wang commented on KAFKA-12446:
---
+1 as well to make it explicit on public docs!
> Define
[
https://issues.apache.org/jira/browse/KAFKA-12457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17299964#comment-17299964
]
Guozhang Wang commented on KAFKA-12457:
---
[~jolshan] [~hachikuji] Just curious, are we going to
[
https://issues.apache.org/jira/browse/KAFKA-6599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17299960#comment-17299960
]
Guozhang Wang commented on KAFKA-6599:
--
Thanks [~aosipov] for your analysis! Though decouple caching
[
https://issues.apache.org/jira/browse/KAFKA-12428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17299798#comment-17299798
]
Guozhang Wang commented on KAFKA-12428:
---
Hello [~ketulgupta], thanks for your interests in
[
https://issues.apache.org/jira/browse/KAFKA-12265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17299790#comment-17299790
]
Guozhang Wang commented on KAFKA-12265:
---
Thanks [~jagsancio] for the updated description!
> Move
[
https://issues.apache.org/jira/browse/KAFKA-12428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17295791#comment-17295791
]
Guozhang Wang commented on KAFKA-12428:
---
Thinking about this a bit, maybe it's better to have two
Guozhang Wang created KAFKA-12428:
-
Summary: Add a last-heartbeat-seconds-ago metric to Kafka Consumer
Key: KAFKA-12428
URL: https://issues.apache.org/jira/browse/KAFKA-12428
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-12428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12428:
--
Component/s: streams
> Add a last-heartbeat-seconds-ago metric to Kafka Consumer
>
Guozhang Wang created KAFKA-12419:
-
Summary: Remove Deprecated APIs of Kafka Streams in 3.0
Key: KAFKA-12419
URL: https://issues.apache.org/jira/browse/KAFKA-12419
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-10847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17290685#comment-17290685
]
Guozhang Wang commented on KAFKA-10847:
---
I agree that we should delete upon emitting expired
[
https://issues.apache.org/jira/browse/KAFKA-12323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-12323.
---
Resolution: Fixed
> Record timestamps not populated in event
>
[
https://issues.apache.org/jira/browse/KAFKA-12370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289642#comment-17289642
]
Guozhang Wang commented on KAFKA-12370:
---
Note this would be related to
Guozhang Wang created KAFKA-12370:
-
Summary: Refactor KafkaStreams exposed metadata hierarchy
Key: KAFKA-12370
URL: https://issues.apache.org/jira/browse/KAFKA-12370
Project: Kafka
Issue
Guozhang Wang created KAFKA-12352:
-
Summary: Improve debuggability with continuous consumer rebalances
Key: KAFKA-12352
URL: https://issues.apache.org/jira/browse/KAFKA-12352
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-12169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17287431#comment-17287431
]
Guozhang Wang commented on KAFKA-12169:
---
Inside the AbstractCoordinator:
{code}
public
[
https://issues.apache.org/jira/browse/KAFKA-12169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12169:
--
Labels: bug (was: )
> Consumer can not know paritions change when client leader restart with
[
https://issues.apache.org/jira/browse/KAFKA-10847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286808#comment-17286808
]
Guozhang Wang commented on KAFKA-10847:
---
[~spena][~vcrfxia][~mjsax] I'd like to dump some more
[
https://issues.apache.org/jira/browse/KAFKA-12323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286016#comment-17286016
]
Guozhang Wang commented on KAFKA-12323:
---
I checked the source code between 2.6 and trunk, and I
[
https://issues.apache.org/jira/browse/KAFKA-12313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12313:
--
Fix Version/s: 3.0.0
> Consider deprecating the default.windowed.serde.inner.class configs
>
[
https://issues.apache.org/jira/browse/KAFKA-12314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282215#comment-17282215
]
Guozhang Wang commented on KAFKA-12314:
---
cc [~vcrfxia] a PR from 3 years ago on using customized
[
https://issues.apache.org/jira/browse/KAFKA-10648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278283#comment-17278283
]
Guozhang Wang commented on KAFKA-10648:
---
[~sagarrao] [~cadonna] Please feel free to resolve the
[
https://issues.apache.org/jira/browse/KAFKA-12265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276794#comment-17276794
]
Guozhang Wang commented on KAFKA-12265:
---
Just curious why we need this move? Could you elaborate a
[
https://issues.apache.org/jira/browse/KAFKA-10793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17274187#comment-17274187
]
Guozhang Wang commented on KAFKA-10793:
---
cc [~hachikuji] [~ijuma] Hopefully we nailed it this
[
https://issues.apache.org/jira/browse/KAFKA-12169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17274181#comment-17274181
]
Guozhang Wang commented on KAFKA-12169:
---
[~zoushengfu] by "restart with unknown member id", do you
[
https://issues.apache.org/jira/browse/KAFKA-12169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12169:
--
Summary: Consumer can not know paritions change when client leader restart
with static
[
https://issues.apache.org/jira/browse/KAFKA-10847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273421#comment-17273421
]
Guozhang Wang commented on KAFKA-10847:
---
Also, I'm wondering if we have considered if we should
[
https://issues.apache.org/jira/browse/KAFKA-10847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273417#comment-17273417
]
Guozhang Wang commented on KAFKA-10847:
---
Hello [~spena], thanks for the detailed implementation
[
https://issues.apache.org/jira/browse/KAFKA-12242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272362#comment-17272362
]
Guozhang Wang commented on KAFKA-12242:
---
One idea is adding a flag parameter in Materialized to
Guozhang Wang created KAFKA-12242:
-
Summary: Decouple state store materialization enforcement from
name/serde provider
Key: KAFKA-12242
URL: https://issues.apache.org/jira/browse/KAFKA-12242
Project:
[
https://issues.apache.org/jira/browse/KAFKA-10844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17268152#comment-17268152
]
Guozhang Wang commented on KAFKA-10844:
---
I agree with [~mjsax] that we can first look into fixing
[
https://issues.apache.org/jira/browse/KAFKA-10848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17268141#comment-17268141
]
Guozhang Wang commented on KAFKA-10848:
---
I'm thinking about maybe exposing a `RecordChooser`
[
https://issues.apache.org/jira/browse/KAFKA-12219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-12219.
---
Fix Version/s: 2.8.0
Resolution: Fixed
> Potential race condition in
[
https://issues.apache.org/jira/browse/KAFKA-12207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17267668#comment-17267668
]
Guozhang Wang commented on KAFKA-12207:
---
I'm +1 for this. For the magic number 1000 though, I'd
[
https://issues.apache.org/jira/browse/KAFKA-12207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12207:
--
Component/s: core
> Do not maintain list of latest producer append information
>
[
https://issues.apache.org/jira/browse/KAFKA-12190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12190:
--
Labels: bug (was: )
> Failure on Windows due to an UnsupportedOperationException when
>
[
https://issues.apache.org/jira/browse/KAFKA-12213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17267658#comment-17267658
]
Guozhang Wang commented on KAFKA-12213:
---
[~mjsax] Maybe we can break KIP-149/159 into smaller ones
[
https://issues.apache.org/jira/browse/KAFKA-12223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12223:
--
Labels: metrics (was: )
> Consider not to Treat Mixed Usage of Shared and Dedicated Block
[
https://issues.apache.org/jira/browse/KAFKA-10637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17267500#comment-17267500
]
Guozhang Wang commented on KAFKA-10637:
---
Saw similar stack trace from Streams embedded producer as
[
https://issues.apache.org/jira/browse/KAFKA-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17267493#comment-17267493
]
Guozhang Wang commented on KAFKA-10827:
---
Hi [~Jack-Lee], could you follow this process to submit a
[
https://issues.apache.org/jira/browse/KAFKA-10793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang reassigned KAFKA-10793:
-
Assignee: A. Sophie Blee-Goldman
> Race condition in FindCoordinatorFuture permanently
[
https://issues.apache.org/jira/browse/KAFKA-10793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10793:
--
Fix Version/s: 2.8.0
> Race condition in FindCoordinatorFuture permanently severs connection
[
https://issues.apache.org/jira/browse/KAFKA-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263670#comment-17263670
]
Guozhang Wang commented on KAFKA-10827:
---
[~jaebinyo] That's a fair point, but I think the original
[
https://issues.apache.org/jira/browse/KAFKA-10853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17249376#comment-17249376
]
Guozhang Wang commented on KAFKA-10853:
---
[~ambroff] I'm wondering, in this case where admin
[
https://issues.apache.org/jira/browse/KAFKA-10788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17249371#comment-17249371
]
Guozhang Wang commented on KAFKA-10788:
---
[~sagarrao], could you provide some more context, e.g.
[
https://issues.apache.org/jira/browse/KAFKA-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17246777#comment-17246777
]
Guozhang Wang commented on KAFKA-10827:
---
[~jaebinyo] I think your reasoning is right to the point.
Guozhang Wang created KAFKA-10830:
-
Summary: Kafka Producer API should throw unwrapped exceptions
Key: KAFKA-10830
URL: https://issues.apache.org/jira/browse/KAFKA-10830
Project: Kafka
Issue
Guozhang Wang created KAFKA-10829:
-
Summary: Kafka Streams handle produce exception improvement
Key: KAFKA-10829
URL: https://issues.apache.org/jira/browse/KAFKA-10829
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-10802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17246222#comment-17246222
]
Guozhang Wang commented on KAFKA-10802:
---
I merged a PR in trunk recently for this issue: I think
[
https://issues.apache.org/jira/browse/KAFKA-10636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10636:
--
Labels: raft-log-management (was: )
> Bypass log validation for writes to raft log
>
[
https://issues.apache.org/jira/browse/KAFKA-10688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242772#comment-17242772
]
Guozhang Wang commented on KAFKA-10688:
---
The main reason I did not go through the consumer route
[
https://issues.apache.org/jira/browse/KAFKA-10688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241992#comment-17241992
]
Guozhang Wang commented on KAFKA-10688:
---
Had some more discussions with [~cadonna] about different
[
https://issues.apache.org/jira/browse/KAFKA-10721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10721:
--
Labels: newbie++ (was: )
> Rewrite topology to allow for overlapping unequal topic
Guozhang Wang created KAFKA-10725:
-
Summary: Merge StoreQueryIntegrationTest and
QueryableStateIntegrationTest
Key: KAFKA-10725
URL: https://issues.apache.org/jira/browse/KAFKA-10725
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-10575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17229436#comment-17229436
]
Guozhang Wang commented on KAFKA-10575:
---
Of course. You can take a look at the
[
https://issues.apache.org/jira/browse/KAFKA-10688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228844#comment-17228844
]
Guozhang Wang commented on KAFKA-10688:
---
Normally the repartition topic should never have an
[
https://issues.apache.org/jira/browse/KAFKA-10688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17227545#comment-17227545
]
Guozhang Wang commented on KAFKA-10688:
---
No we don't actually :) In StreamThread we handle
[
https://issues.apache.org/jira/browse/KAFKA-10604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17227084#comment-17227084
]
Guozhang Wang commented on KAFKA-10604:
---
I personally would prefer not a KIP for this
[
https://issues.apache.org/jira/browse/KAFKA-10688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17227080#comment-17227080
]
Guozhang Wang edited comment on KAFKA-10688 at 11/5/20, 11:50 PM:
--
501 - 600 of 2638 matches
Mail list logo
