[
https://issues.apache.org/jira/browse/KAFKA-7540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17506529#comment-17506529
]
Guozhang Wang commented on KAFKA-7540:
--
This test case is now very consistently failing with a
[
https://issues.apache.org/jira/browse/KAFKA-13699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17505386#comment-17505386
]
Guozhang Wang commented on KAFKA-13699:
---
I agree with [~mimaison], that we would only be able to
[
https://issues.apache.org/jira/browse/KAFKA-13690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503932#comment-17503932
]
Guozhang Wang commented on KAFKA-13690:
---
May cover
Guozhang Wang created KAFKA-13722:
-
Summary: Update internal interfaces that use ProcessorContext to
use StateStoreContext instead
Key: KAFKA-13722
URL: https://issues.apache.org/jira/browse/KAFKA-13722
[
https://issues.apache.org/jira/browse/KAFKA-7480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-7480:
-
Labels: needs-kip new-streams-runtime-should-fix (was: needs-kip)
> GlobalThread should honor
[
https://issues.apache.org/jira/browse/KAFKA-6106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17501162#comment-17501162
]
Guozhang Wang commented on KAFKA-6106:
--
As discussed with [~cadonna] offline, when we have completed
[
https://issues.apache.org/jira/browse/KAFKA-7934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-7934:
-
Labels: new-streams-runtime-should-fix (was: )
> Optimize restore for windowed and session
[
https://issues.apache.org/jira/browse/KAFKA-12634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12634:
--
Priority: Critical (was: Major)
> Should checkpoint after restore finished
>
[
https://issues.apache.org/jira/browse/KAFKA-12634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12634:
--
Labels: new-streams-runtime-should-fix newbie++ (was: newbie++)
> Should checkpoint after
[
https://issues.apache.org/jira/browse/KAFKA-6106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-6106:
-
Labels: new-streams-runtime-should-fix newbie++ (was: newbie++)
> Postpone normal processing of
[
https://issues.apache.org/jira/browse/KAFKA-13501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13501:
--
Labels: new-streams-runtime-should-fix (was: )
> Avoid state restore via rebalance if
[
https://issues.apache.org/jira/browse/KAFKA-8951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-8951:
-
Labels: new-rebalance-should-fix (was: )
> Avoid unnecessary rebalances and downtime for "safe"
[
https://issues.apache.org/jira/browse/KAFKA-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-7996:
-
Labels: needs-kip new-streams-runtime-should-fix (was: needs-kip)
> KafkaStreams does not pass
[
https://issues.apache.org/jira/browse/KAFKA-10563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10563:
--
Labels: new-streams-runtime-should-fix (was: )
> Make sure task directories don't remain
[
https://issues.apache.org/jira/browse/KAFKA-9062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-9062:
-
Labels: new-streams-runtime-should-fix (was: )
> Handle stalled writes to RocksDB
>
[
https://issues.apache.org/jira/browse/KAFKA-13295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13295:
--
Labels: eos new-streams-runtime-should-fix (was: eos)
> Long restoration times for new tasks
[
https://issues.apache.org/jira/browse/KAFKA-12738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12738:
--
Labels: new-streams-runtime-should-fix (was: )
> Improved error handling for better
[
https://issues.apache.org/jira/browse/KAFKA-10263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10263:
--
Labels: new-streams-runtime-should-fix (was: )
> Do not create standbys for those revoking
[
https://issues.apache.org/jira/browse/KAFKA-10294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10294:
--
Labels: new-streams-runtime-should-fix (was: )
> Consider whether some of
[
https://issues.apache.org/jira/browse/KAFKA-12693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12693:
--
Labels: new-streams-runtime-should-fix streams (was: streams)
> Consecutive rebalances with
[
https://issues.apache.org/jira/browse/KAFKA-10688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10688:
--
Labels: new-streams-runtime-should-fix (was: )
> Handle accidental truncation of repartition
[
https://issues.apache.org/jira/browse/KAFKA-12812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12812:
--
Labels: new-streams-runtime-should-fix (was: )
> Consider refactoring state store
[
https://issues.apache.org/jira/browse/KAFKA-8023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499831#comment-17499831
]
Guozhang Wang commented on KAFKA-8023:
--
One idea I'm having at the moment is that when we have
[
https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-8037:
-
Labels: new-streams-runtime-should-fix pull-request-available (was:
pull-request-available)
>
[
https://issues.apache.org/jira/browse/KAFKA-8023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-8023:
-
Labels: new-streams-runtime-should-fix performance (was: performance)
> Improve global state
[
https://issues.apache.org/jira/browse/KAFKA-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-7663:
-
Labels: new-streams-runtime-should-fix (was: )
> Custom Processor supplied on addGlobalStore is
[
https://issues.apache.org/jira/browse/KAFKA-10410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10410:
--
Labels: new-streams-runtime-should-fix (was: )
> OnRestoreStart disappeared from
[
https://issues.apache.org/jira/browse/KAFKA-10829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10829:
--
Labels: new-streams-runtime-should-fix (was: )
> Kafka Streams handle produce exception
[
https://issues.apache.org/jira/browse/KAFKA-10575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10575:
--
Labels: new-streams-runtime-should-fix (was: )
> StateRestoreListener#onRestoreEnd should
[
https://issues.apache.org/jira/browse/KAFKA-12370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12370:
--
Labels: needs-kip new-streams-runtime-should-fix (was: needs-kip)
> Refactor KafkaStreams
[
https://issues.apache.org/jira/browse/KAFKA-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10357:
--
Labels: needs-kip new-streams-runtime-should-fix (was: needs-kip)
> Handle accidental
[
https://issues.apache.org/jira/browse/KAFKA-10199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10199:
--
Labels: new-streams-runtime-should-fix (was: )
> Separate state restoration into separate
[
https://issues.apache.org/jira/browse/KAFKA-10532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10532:
--
Labels: new-streams-runtime-should-fix newbie++ (was: newbie++)
> Do not wipe state store
[
https://issues.apache.org/jira/browse/KAFKA-13694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499791#comment-17499791
]
Guozhang Wang commented on KAFKA-13694:
---
Actually my previous suggestion has a flaw: even when one
[
https://issues.apache.org/jira/browse/KAFKA-13694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499777#comment-17499777
]
Guozhang Wang commented on KAFKA-13694:
---
[~RivenSun] I think that's a good point, I agree with you
[
https://issues.apache.org/jira/browse/KAFKA-13699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499683#comment-17499683
]
Guozhang Wang commented on KAFKA-13699:
---
Hi [~lqxshay] thanks for filing the ticket. Just to
[
https://issues.apache.org/jira/browse/KAFKA-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-1:
--
Labels: new-streams-runtime-should-fix (was: )
> Optimize condition for triggering rebalance
[
https://issues.apache.org/jira/browse/KAFKA-12486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12486:
--
Labels: new-streams-runtime-should-fix (was: )
> Utilize HighAvailabilityTaskAssignor to
[
https://issues.apache.org/jira/browse/KAFKA-13694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498491#comment-17498491
]
Guozhang Wang commented on KAFKA-13694:
---
Thanks [~RivenSun].
It looks like we are in agreement on
[
https://issues.apache.org/jira/browse/KAFKA-13681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498236#comment-17498236
]
Guozhang Wang commented on KAFKA-13681:
---
[~DrozD_0] We have not decided when it would be applied
[
https://issues.apache.org/jira/browse/KAFKA-13694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498234#comment-17498234
]
Guozhang Wang commented on KAFKA-13694:
---
Hello [~RivenSun] thanks for the report. If I understand
[
https://issues.apache.org/jira/browse/KAFKA-13690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497725#comment-17497725
]
Guozhang Wang commented on KAFKA-13690:
---
I'll see if I can find a quick fix for this flakiness.
>
[
https://issues.apache.org/jira/browse/KAFKA-13690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497723#comment-17497723
]
Guozhang Wang commented on KAFKA-13690:
---
I took a quick look at
[
https://issues.apache.org/jira/browse/KAFKA-13678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497010#comment-17497010
]
Guozhang Wang commented on KAFKA-13678:
---
Hello [~lorenzocagnatel] thanks for reporting. There's
[
https://issues.apache.org/jira/browse/KAFKA-13681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497004#comment-17497004
]
Guozhang Wang commented on KAFKA-13681:
---
Thanks for reporting [~DrozD_0], I think this is indeed a
[
https://issues.apache.org/jira/browse/KAFKA-13683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497002#comment-17497002
]
Guozhang Wang commented on KAFKA-13683:
---
Hello,
I checked your uploaded files and cannot find any
[
https://issues.apache.org/jira/browse/KAFKA-13683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13683:
--
Labels: new-txn-protocol-should-fix (was: )
> Transactional Producer - Transaction with key
[
https://issues.apache.org/jira/browse/KAFKA-13684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17496995#comment-17496995
]
Guozhang Wang commented on KAFKA-13684:
---
Thanks [~petercipov] for reporting this, we will look
[
https://issues.apache.org/jira/browse/KAFKA-13684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13684:
--
Priority: Critical (was: Major)
> KStream rebalance can lead to JVM process crash when
[
https://issues.apache.org/jira/browse/KAFKA-13680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17496989#comment-17496989
]
Guozhang Wang commented on KAFKA-13680:
---
Thanks for reporting this Denis.
I think we still need
[
https://issues.apache.org/jira/browse/KAFKA-13689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17496981#comment-17496981
]
Guozhang Wang commented on KAFKA-13689:
---
Thanks [~RivenSun] for reporting this. I think logging
[
https://issues.apache.org/jira/browse/KAFKA-13676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13676:
--
Description:
When processing in ALOS, we might as well commit progress made by other tasks
[
https://issues.apache.org/jira/browse/KAFKA-13676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13676:
--
Summary: When processing in ALOS, when one task encounters a task-specific
exception we could
[
https://issues.apache.org/jira/browse/KAFKA-13615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491742#comment-17491742
]
Guozhang Wang commented on KAFKA-13615:
---
[~timcosta] You mean your brokers are on the MSK right?
[
https://issues.apache.org/jira/browse/KAFKA-12256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-12256.
---
Fix Version/s: 3.2.0
Resolution: Fixed
> auto commit causes delays due to retriable
[
https://issues.apache.org/jira/browse/KAFKA-12256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491076#comment-17491076
]
Guozhang Wang commented on KAFKA-12256:
---
Hello [~rleslie] yeah I think we can close this ticket
[
https://issues.apache.org/jira/browse/KAFKA-1935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-1935:
-
Labels: new-rebalance-should-fix newbie (was:
new-consumer-threading-should-fix newbie)
>
[
https://issues.apache.org/jira/browse/KAFKA-1935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-1935:
-
Labels: new-consumer-threading-should-fix newbie (was: newbie)
> Consumer should use a separate
[
https://issues.apache.org/jira/browse/KAFKA-4740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-4740:
-
Labels: new-consumer-threading-should-fix (was: )
> Using new consumer API with a Deserializer
[
https://issues.apache.org/jira/browse/KAFKA-3949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-3949:
-
Labels: new-consumer-threading-should-fix (was: )
> Consumer topic subscription change may be
[
https://issues.apache.org/jira/browse/KAFKA-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-2168:
-
Labels: new-consumer-threading-should-fix (was: )
> New consumer poll() can block other calls
[
https://issues.apache.org/jira/browse/KAFKA-9140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-9140:
-
Labels: new-consumer-threading-should-fix (was: )
> Consumer gets stuck rejoining the group
[
https://issues.apache.org/jira/browse/KAFKA-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-8104:
-
Labels: new-consumer-threading-should-fix (was: )
> Consumer cannot rejoin to the group after
[
https://issues.apache.org/jira/browse/KAFKA-12169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12169:
--
Labels: bug new-rebalance-should-fix (was: bug)
> Consumer can not know paritions change
[
https://issues.apache.org/jira/browse/KAFKA-12169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490715#comment-17490715
]
Guozhang Wang commented on KAFKA-12169:
---
This seems related to KAFKA-13543 as well.
> Consumer
[
https://issues.apache.org/jira/browse/KAFKA-10793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10793:
--
Labels: new-consumer-threading-should-fix (was: )
> Race condition in FindCoordinatorFuture
[
https://issues.apache.org/jira/browse/KAFKA-13425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13425:
--
Labels: new-consumer-threading-should-fix (was: )
> KafkaConsumer#pause() will lose its
[
https://issues.apache.org/jira/browse/KAFKA-13563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13563:
--
Labels: new-consumer-threading-should-fix (was: )
> FindCoordinatorFuture never get cleared
[
https://issues.apache.org/jira/browse/KAFKA-12256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12256:
--
Labels: new-consumer-threading-should-fix (was: )
> auto commit causes delays due to
[
https://issues.apache.org/jira/browse/KAFKA-7109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-7109:
-
Labels: new-consumer-threading-should-fix (was: )
> KafkaConsumer should close its incremental
[
https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13310:
--
Labels: new-consumer-threading-should-fix (was: new-rebalance-should-fix)
> KafkaConsumer
[
https://issues.apache.org/jira/browse/KAFKA-13322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13322:
--
Labels: new-consumer-threading-should-fix (was: new-rebalance-should-fix)
> Java client
[
https://issues.apache.org/jira/browse/KAFKA-13463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13463:
--
Labels: new-consumer-threading-should-fix (was: new-rebalance-should-fix)
> Improvement:
[
https://issues.apache.org/jira/browse/KAFKA-13435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13435:
--
Labels: new-rebalance-should-fix (was: )
> Group won't consume partitions added after static
[
https://issues.apache.org/jira/browse/KAFKA-13463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490704#comment-17490704
]
Guozhang Wang commented on KAFKA-13463:
---
Thanks for brining this up [~RivenSun].
Just to bring
[
https://issues.apache.org/jira/browse/KAFKA-13463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13463:
--
Labels: new-rebalance-should-fix (was: )
> Improvement: KafkaConsumer pause(Collection
[
https://issues.apache.org/jira/browse/KAFKA-13422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489744#comment-17489744
]
Guozhang Wang commented on KAFKA-13422:
---
I'm unfortunately less familiar with security.auth
[
https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-13310.
---
Fix Version/s: 3.2.0
Resolution: Fixed
> KafkaConsumer cannot jump out of the poll
[
https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13310:
--
Labels: new-rebalance-should-fix (was: )
> KafkaConsumer cannot jump out of the poll method,
[
https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang reassigned KAFKA-13310:
-
Assignee: RivenSun
> KafkaConsumer cannot jump out of the poll method, and the
[
https://issues.apache.org/jira/browse/KAFKA-13647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488332#comment-17488332
]
Guozhang Wang commented on KAFKA-13647:
---
TLDR: I think the `NO_FILE_OPENS` statistics is right,
[
https://issues.apache.org/jira/browse/KAFKA-13563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-13563.
---
Fix Version/s: 3.2.0
3.1.1
Resolution: Fixed
>
[
https://issues.apache.org/jira/browse/KAFKA-13346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17487405#comment-17487405
]
Guozhang Wang commented on KAFKA-13346:
---
I'm closing this ticket for now since we have not heard
[
https://issues.apache.org/jira/browse/KAFKA-13346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-13346.
---
Resolution: Not A Problem
> Kafka Streams fails due to RocksDB Locks Not Available
[
https://issues.apache.org/jira/browse/KAFKA-13600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17486808#comment-17486808
]
Guozhang Wang commented on KAFKA-13600:
---
Thanks guys for the great discussion here.
I think just
[
https://issues.apache.org/jira/browse/KAFKA-7572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17486780#comment-17486780
]
Guozhang Wang commented on KAFKA-7572:
--
Thanks for pinging me. I've just made a pass on the PR.
>
[
https://issues.apache.org/jira/browse/KAFKA-13621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17483938#comment-17483938
]
Guozhang Wang commented on KAFKA-13621:
---
When we did KAFKA-12631 we discussed where we can
[
https://issues.apache.org/jira/browse/KAFKA-13322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13322:
--
Labels: new-rebalance-should-fix (was: )
> Java client produces a large amount of garbage
[
https://issues.apache.org/jira/browse/KAFKA-13588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13588:
--
Fix Version/s: 3.3.0
> We should consolidate `changelogFor` methods to simplify the
[
https://issues.apache.org/jira/browse/KAFKA-13588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13588:
--
Description:
[https://github.com/apache/kafka/pull/11611#discussion_r772625486]
we should
[
https://issues.apache.org/jira/browse/KAFKA-13588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479643#comment-17479643
]
Guozhang Wang commented on KAFKA-13588:
---
[~surahman] Thanks for your interests. I should clarify
[
https://issues.apache.org/jira/browse/KAFKA-13349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang reassigned KAFKA-13349:
-
Assignee: Sagar Rao (was: loboxu)
> Allow Iterator.remove on KeyValueIterator
>
[
https://issues.apache.org/jira/browse/KAFKA-13349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479635#comment-17479635
]
Guozhang Wang commented on KAFKA-13349:
---
[~sagarrao] I've just re-assigned the task to you.
>
[
https://issues.apache.org/jira/browse/KAFKA-13600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479619#comment-17479619
]
Guozhang Wang commented on KAFKA-13600:
---
[~tim.patterson] Thanks for filing this ticket.
I'd like
[
https://issues.apache.org/jira/browse/KAFKA-13590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13590:
--
Labels: newbie (was: )
> Rename InternalTopologyBuilder's #topicGroups method to be more
[
https://issues.apache.org/jira/browse/KAFKA-13543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13543:
--
Labels: new-rebalance-should-fix (was: )
> Consumer may pass stale cluster metadata to the
[
https://issues.apache.org/jira/browse/KAFKA-13588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472368#comment-17472368
]
Guozhang Wang commented on KAFKA-13588:
---
This would also include consolidating the duplicated
[
https://issues.apache.org/jira/browse/KAFKA-13435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17470930#comment-17470930
]
Guozhang Wang commented on KAFKA-13435:
---
Sounds good, thanks @Jason. Let's do option 3) for now.
[
https://issues.apache.org/jira/browse/KAFKA-12537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469566#comment-17469566
]
Guozhang Wang commented on KAFKA-12537:
---
Hey [~wcarlson5] just for my own understanding: why is
[
https://issues.apache.org/jira/browse/KAFKA-13563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469023#comment-17469023
]
Guozhang Wang commented on KAFKA-13563:
---
Hi [~showuon] thanks for the report, I've reviewed the PR
201 - 300 of 2638 matches
Mail list logo
