Guozhang Wang created KAFKA-13736:
-
Summary: Flaky
kafka.network.SocketServerTest.closingChannelWithBufferedReceives
Key: KAFKA-13736
URL: https://issues.apache.org/jira/browse/KAFKA-13736
Project: Ka
Guozhang Wang created KAFKA-13735:
-
Summary: Flaky
kafka.network.SocketServerTest.remoteCloseWithoutBufferedReceives
Key: KAFKA-13735
URL: https://issues.apache.org/jira/browse/KAFKA-13735
Project: Ka
[
https://issues.apache.org/jira/browse/KAFKA-13421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang reopened KAFKA-13421:
---
Re-opening this ticket since the test is still failing.
> Fix
> ConsumerBounceTest#testRolling
[
https://issues.apache.org/jira/browse/KAFKA-7540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506529#comment-17506529
]
Guozhang Wang commented on KAFKA-7540:
--
This test case is now very consistently fail
[
https://issues.apache.org/jira/browse/KAFKA-13699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17505386#comment-17505386
]
Guozhang Wang commented on KAFKA-13699:
---
I agree with [~mimaison], that we would o
[
https://issues.apache.org/jira/browse/KAFKA-13690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503932#comment-17503932
]
Guozhang Wang commented on KAFKA-13690:
---
May cover `shouldCommitCorrectOffsetIfInp
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 cu
[
https://issues.apache.org/jira/browse/KAFKA-6106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17501162#comment-17501162
]
Guozhang Wang commented on KAFKA-6106:
--
As discussed with [~cadonna] offline, when w
[
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 store
[
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 res
[
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 standby
[
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 t
[
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 lock
[
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 at-least-
[
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 ac
[
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 ProcessorStateExcep
[
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 z
[
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 registratio
[
https://issues.apache.org/jira/browse/KAFKA-8023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499831#comment-17499831
]
Guozhang Wang commented on KAFKA-8023:
--
One idea I'm having at the moment is that wh
[
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)
> K
[
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 sto
[
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 StateRestore
[
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 alw
[
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 impro
[
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 exp
[
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 deletio
[
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 thr
[
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 und
[
https://issues.apache.org/jira/browse/KAFKA-13694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499791#comment-17499791
]
Guozhang Wang commented on KAFKA-13694:
---
Actually my previous suggestion has a fla
[
https://issues.apache.org/jira/browse/KAFKA-13694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499777#comment-17499777
]
Guozhang Wang commented on KAFKA-13694:
---
[~RivenSun] I think that's a good point,
[
https://issues.apache.org/jira/browse/KAFKA-13699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499683#comment-17499683
]
Guozhang Wang commented on KAFKA-13699:
---
Hi [~lqxshay] thanks for filing the ticke
[
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 avoi
[
https://issues.apache.org/jira/browse/KAFKA-13694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498491#comment-17498491
]
Guozhang Wang commented on KAFKA-13694:
---
Thanks [~RivenSun].
It looks like we are
[
https://issues.apache.org/jira/browse/KAFKA-13681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498236#comment-17498236
]
Guozhang Wang commented on KAFKA-13681:
---
[~DrozD_0] We have not decided when it wo
[
https://issues.apache.org/jira/browse/KAFKA-13694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498234#comment-17498234
]
Guozhang Wang commented on KAFKA-13694:
---
Hello [~RivenSun] thanks for the report.
[
https://issues.apache.org/jira/browse/KAFKA-13690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17497725#comment-17497725
]
Guozhang Wang commented on KAFKA-13690:
---
I'll see if I can find a quick fix for th
[
https://issues.apache.org/jira/browse/KAFKA-13690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17497723#comment-17497723
]
Guozhang Wang commented on KAFKA-13690:
---
I took a quick look at https://github.com
[
https://issues.apache.org/jira/browse/KAFKA-13678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17497010#comment-17497010
]
Guozhang Wang commented on KAFKA-13678:
---
Hello [~lorenzocagnatel] thanks for repor
[
https://issues.apache.org/jira/browse/KAFKA-13681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17497004#comment-17497004
]
Guozhang Wang commented on KAFKA-13681:
---
Thanks for reporting [~DrozD_0], I think
[
https://issues.apache.org/jira/browse/KAFKA-13683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17497002#comment-17497002
]
Guozhang Wang commented on KAFKA-13683:
---
Hello,
I checked your uploaded files and
[
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 x
[
https://issues.apache.org/jira/browse/KAFKA-13684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17496995#comment-17496995
]
Guozhang Wang commented on KAFKA-13684:
---
Thanks [~petercipov] for reporting this,
[
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 networ
[
https://issues.apache.org/jira/browse/KAFKA-13680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17496989#comment-17496989
]
Guozhang Wang commented on KAFKA-13680:
---
Thanks for reporting this Denis.
I think
[
https://issues.apache.org/jira/browse/KAFKA-13689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17496981#comment-17496981
]
Guozhang Wang commented on KAFKA-13689:
---
Thanks [~RivenSun] for reporting this. I
[
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
wh
[
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&focusedCommentId=17491742#comment-17491742
]
Guozhang Wang commented on KAFKA-13615:
---
[~timcosta] You mean your brokers are on
[
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 U
[
https://issues.apache.org/jira/browse/KAFKA-12256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17491076#comment-17491076
]
Guozhang Wang commented on KAFKA-12256:
---
Hello [~rleslie] yeah I think we can clos
[
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)
> Consu
[
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 t
[
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 ig
[
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 li
[
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 inde
[
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 re
[
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 when
[
https://issues.apache.org/jira/browse/KAFKA-12169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490715#comment-17490715
]
Guozhang Wang commented on KAFKA-12169:
---
This seems related to KAFKA-13543 as well
[
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 p
[
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 effec
[
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 i
[
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 retriabl
[
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 f
[
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 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-consumer-threading-should-fix (was: new-rebalance-should-fix)
> Java client produ
[
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: Kafk
[
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&focusedCommentId=17490704#comment-17490704
]
Guozhang Wang commented on KAFKA-13463:
---
Thanks for brining this up [~RivenSun].
[
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 partit
[
https://issues.apache.org/jira/browse/KAFKA-13422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489744#comment-17489744
]
Guozhang Wang commented on KAFKA-13422:
---
I'm unfortunately less familiar with secu
[
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 me
[
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 consumer
[
https://issues.apache.org/jira/browse/KAFKA-13647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17488332#comment-17488332
]
Guozhang Wang commented on KAFKA-13647:
---
TLDR: I think the `NO_FILE_OPENS` statist
[
https://issues.apache.org/jira/browse/KAFKA-13615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17487852#comment-17487852
]
Guozhang Wang commented on KAFKA-13615:
---
[~timcosta] Thanks for reporting this iss
[
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
> FindCoordinatorFutu
[
https://issues.apache.org/jira/browse/KAFKA-13346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17487405#comment-17487405
]
Guozhang Wang commented on KAFKA-13346:
---
I'm closing this ticket for now since we
[
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 Exception
[
https://issues.apache.org/jira/browse/KAFKA-13600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17486808#comment-17486808
]
Guozhang Wang commented on KAFKA-13600:
---
Thanks guys for the great discussion here
[
https://issues.apache.org/jira/browse/KAFKA-7572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17486780#comment-17486780
]
Guozhang Wang commented on KAFKA-7572:
--
Thanks for pinging me. I've just made a pass
[
https://issues.apache.org/jira/browse/KAFKA-13621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17483938#comment-17483938
]
Guozhang Wang commented on KAFKA-13621:
---
When we did KAFKA-12631 we discussed wher
[
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 dur
[
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 generation
[
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 use
[
https://issues.apache.org/jira/browse/KAFKA-13588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479643#comment-17479643
]
Guozhang Wang commented on KAFKA-13588:
---
[~surahman] Thanks for your interests. I
[
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&focusedCommentId=17479635#comment-17479635
]
Guozhang Wang commented on KAFKA-13349:
---
[~sagarrao] I've just re-assigned the tas
[
https://issues.apache.org/jira/browse/KAFKA-13600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479619#comment-17479619
]
Guozhang Wang commented on KAFKA-13600:
---
[~tim.patterson] Thanks for filing this t
[
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 desc
[
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 as
201 - 300 of 2801 matches
Mail list logo