[
https://issues.apache.org/jira/browse/KAFKA-14015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17582519#comment-17582519
]
Sagar Rao commented on KAFKA-14015:
---
[~rozza] , Thanks for filing this issue. There seems to be a
[
https://issues.apache.org/jira/browse/KAFKA-14000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17582346#comment-17582346
]
Sagar Rao commented on KAFKA-14000:
---
hi [~xinzou] , Thanks for filing the bug. One thing that I wanted
[
https://issues.apache.org/jira/browse/KAFKA-14000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14000:
-
Assignee: Sagar Rao
> Kafka-connect standby server shows empty tasks list
>
[
https://issues.apache.org/jira/browse/KAFKA-14015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14015:
-
Assignee: Sagar Rao
> ConfigProvider with ttl fails to restart tasks
>
[
https://issues.apache.org/jira/browse/KAFKA-14012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao resolved KAFKA-14012.
---
Resolution: Fixed
> passing a "method" into the `Utils.closeQuietly` method cause NPE
>
[
https://issues.apache.org/jira/browse/KAFKA-14007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao resolved KAFKA-14007.
---
Resolution: Fixed
> Connect header converters are never closed
>
[
https://issues.apache.org/jira/browse/KAFKA-12495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17581914#comment-17581914
]
Sagar Rao commented on KAFKA-12495:
---
[~ChrisEgerton] , I was looking at this and this comment of yours
[
https://issues.apache.org/jira/browse/KAFKA-14138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17577552#comment-17577552
]
Sagar Rao commented on KAFKA-14138:
---
Thanks [~guozhang] . I went through KIP-691 and got some ideas
[
https://issues.apache.org/jira/browse/KAFKA-14121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17576503#comment-17576503
]
Sagar Rao commented on KAFKA-14121:
---
hey [~enether] i saw the KIP discussion. Forgot to re-assign it
[
https://issues.apache.org/jira/browse/KAFKA-14121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14121:
-
Assignee: Stanislav Kozlovski (was: Sagar Rao)
> AlterPartitionReassignments API should allow
[
https://issues.apache.org/jira/browse/KAFKA-12495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-12495:
-
Assignee: Sagar Rao
> Unbalanced connectors/tasks distribution will happen in Connect's
[
https://issues.apache.org/jira/browse/KAFKA-14131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17575390#comment-17575390
]
Sagar Rao edited comment on KAFKA-14131 at 8/4/22 6:20 PM:
---
[~Justinwins] i
[
https://issues.apache.org/jira/browse/KAFKA-14131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17575390#comment-17575390
]
Sagar Rao commented on KAFKA-14131:
---
[~Justinwins] i created a PR here =>
[
https://issues.apache.org/jira/browse/KAFKA-14118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17575366#comment-17575366
]
Sagar Rao commented on KAFKA-14118:
---
[~jsancio] i assigned this to myself, but I figured this is part
[
https://issues.apache.org/jira/browse/KAFKA-14118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14118:
-
Assignee: (was: Sagar Rao)
> Generate and persist storage uuiid
>
[
https://issues.apache.org/jira/browse/KAFKA-12495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17575362#comment-17575362
]
Sagar Rao commented on KAFKA-12495:
---
[~ChrisEgerton] You summed it up correctly. Regarding #1, you are
[
https://issues.apache.org/jira/browse/KAFKA-14126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14126:
-
Assignee: David Arthur (was: Sagar Rao)
> Convert remaining DynamicBrokerReconfigurationTest
[
https://issues.apache.org/jira/browse/KAFKA-14126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17575295#comment-17575295
]
Sagar Rao commented on KAFKA-14126:
---
Hey . I saw it was unassigned so assigned it to myself. If it’s
[
https://issues.apache.org/jira/browse/KAFKA-14138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17575246#comment-17575246
]
Sagar Rao commented on KAFKA-14138:
---
[~guozhang] , I did some analysis. From what I understood,
[
https://issues.apache.org/jira/browse/KAFKA-14138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14138:
-
Assignee: Sagar Rao
> The Exception Throwing Behavior of Transactional Producer is
[
https://issues.apache.org/jira/browse/KAFKA-14118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14118:
-
Assignee: Sagar Rao
> Generate and persist storage uuiid
> --
[
https://issues.apache.org/jira/browse/KAFKA-14121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14121:
-
Assignee: Sagar Rao
> AlterPartitionReassignments API should allow callers to specify the
[
https://issues.apache.org/jira/browse/KAFKA-14131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14131:
-
Assignee: Sagar Rao
> KafkaBasedLog#readToLogEnd() may accciedently falls into infinite loop
>
[
https://issues.apache.org/jira/browse/KAFKA-14091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14091:
-
Assignee: Sagar Rao
> Suddenly-killed tasks can leave hanging transactions open
>
[
https://issues.apache.org/jira/browse/KAFKA-14126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14126:
-
Assignee: Sagar Rao
> Convert remaining DynamicBrokerReconfigurationTest tests to KRaft
>
[
https://issues.apache.org/jira/browse/KAFKA-12495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17575018#comment-17575018
]
Sagar Rao commented on KAFKA-12495:
---
Thanks [~ChrisEgerton] . I would take a look. I had another idea
[
https://issues.apache.org/jira/browse/KAFKA-12495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17574767#comment-17574767
]
Sagar Rao commented on KAFKA-12495:
---
[~showuon] , is this still open? I can take a stab at it. Let me
[
https://issues.apache.org/jira/browse/KAFKA-14040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao updated KAFKA-14040:
--
Description: We noticed an issue with KIP-770 where the ordering of metrics
for enforced processing
[
https://issues.apache.org/jira/browse/KAFKA-14040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao updated KAFKA-14040:
--
Summary: Improve test coverage for total buffer bytes metric (was: Improve
test coverage for max
[
https://issues.apache.org/jira/browse/KAFKA-14040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao updated KAFKA-14040:
--
Issue Type: Task (was: Bug)
> Improve test coverage for max buffer bytes metrics
>
[
https://issues.apache.org/jira/browse/KAFKA-14040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao updated KAFKA-14040:
--
Priority: Major (was: Critical)
> Improve test coverage for max buffer bytes metrics
>
[
https://issues.apache.org/jira/browse/KAFKA-14040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao updated KAFKA-14040:
--
Labels: (was: eos new-streams-runtime-should-fix)
> Improve test coverage for max buffer bytes
Sagar Rao created KAFKA-14040:
-
Summary: Improve test coverage for max buffer bytes metrics
Key: KAFKA-14040
URL: https://issues.apache.org/jira/browse/KAFKA-14040
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-13602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17558753#comment-17558753
]
Sagar Rao edited comment on KAFKA-13602 at 6/25/22 10:43 AM:
-
Hey @florin ,
[
https://issues.apache.org/jira/browse/KAFKA-13602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17558753#comment-17558753
]
Sagar Rao commented on KAFKA-13602:
---
Hey @florin , I have already sent out a Kip for this. Here is the
[
https://issues.apache.org/jira/browse/KAFKA-14012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14012:
-
Assignee: Sagar Rao
> passing a "method" into the `Utils.closeQuietly` method cause NPE
>
[
https://issues.apache.org/jira/browse/KAFKA-14007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14007:
-
Assignee: Sagar Rao
> Connect header converters are never closed
>
[
https://issues.apache.org/jira/browse/KAFKA-13970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao resolved KAFKA-13970.
---
Resolution: Won't Fix
> TopicAdmin topic creation should be retried on TimeoutException
>
[
https://issues.apache.org/jira/browse/KAFKA-13976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-13976:
-
Assignee: Sagar Rao
> Improvements for OpenAPI specs
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-13970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17552046#comment-17552046
]
Sagar Rao commented on KAFKA-13970:
---
Aah ok.. Sure I guess you would be handling it in your unmerged
[
https://issues.apache.org/jira/browse/KAFKA-13970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17551730#comment-17551730
]
Sagar Rao commented on KAFKA-13970:
---
[~durban] , I couldn't find
[
https://issues.apache.org/jira/browse/KAFKA-13970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-13970:
-
Assignee: Sagar Rao
> TopicAdmin topic creation should be retried on TimeoutException
>
[
https://issues.apache.org/jira/browse/KAFKA-13745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17537026#comment-17537026
]
Sagar Rao commented on KAFKA-13745:
---
Thanks [~guozhang] . Sure we can re-create if needed.
> Flaky
>
[
https://issues.apache.org/jira/browse/KAFKA-13745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17536230#comment-17536230
]
Sagar Rao commented on KAFKA-13745:
---
[~guozhang] , i looked at few of the builds happening across the
[
https://issues.apache.org/jira/browse/KAFKA-13745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17533381#comment-17533381
]
Sagar Rao commented on KAFKA-13745:
---
[~Jack-Lee] , Sorry I couldn't follow your comment. How do you
[
https://issues.apache.org/jira/browse/KAFKA-13846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-13846:
-
Assignee: Sagar Rao
> Add an overloaded metricOrElseCreate function in Metrics
>
[
https://issues.apache.org/jira/browse/KAFKA-13745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-13745:
-
Assignee: Sagar Rao
> Flaky
>
[
https://issues.apache.org/jira/browse/KAFKA-13746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-13746:
-
Assignee: Sagar Rao
> Flaky
>
[
https://issues.apache.org/jira/browse/KAFKA-13816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17524701#comment-17524701
]
Sagar Rao commented on KAFKA-13816:
---
hey [~ChrisEgerton] , thanks for the input! No worries, I will
[
https://issues.apache.org/jira/browse/KAFKA-13816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17523997#comment-17523997
]
Sagar Rao commented on KAFKA-13816:
---
[~ChrisEgerton] , thanks for that info. I think if we can
[
https://issues.apache.org/jira/browse/KAFKA-13816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17523604#comment-17523604
]
Sagar Rao commented on KAFKA-13816:
---
hey [~ChrisEgerton] , i looked at the rough draft of the fix.
[
https://issues.apache.org/jira/browse/KAFKA-13816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-13816:
-
Assignee: Sagar Rao
> Downgrading Connect rebalancing protocol from incremental to eager
[
https://issues.apache.org/jira/browse/KAFKA-13624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao resolved KAFKA-13624.
---
Resolution: Won't Fix
Taken care as part of KIP-770
> Add Metric for Store Cache Size
>
[
https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao updated KAFKA-13152:
--
Fix Version/s: 3.3.0
(was: 3.2.0)
> Replace "buffered.records.per.partition"
[
https://issues.apache.org/jira/browse/KAFKA-13501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498563#comment-17498563
]
Sagar Rao commented on KAFKA-13501:
---
[~mjsax] , In 12486 idea was to use the
[
https://issues.apache.org/jira/browse/KAFKA-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao resolved KAFKA-9168.
--
Resolution: Later
This would be taken up once we have a more complete solution
> Integrate JNI direct
[
https://issues.apache.org/jira/browse/KAFKA-13624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao updated KAFKA-13624:
--
External issue URL: (was:
[
https://issues.apache.org/jira/browse/KAFKA-13624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao updated KAFKA-13624:
--
External issue URL:
[
https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao resolved KAFKA-13152.
---
Resolution: Done
> Replace "buffered.records.per.partition" with "input.buffer.max.bytes"
>
[
https://issues.apache.org/jira/browse/KAFKA-13602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-13602:
-
Assignee: Sagar Rao
> Allow to broadcast a result record
> --
[
https://issues.apache.org/jira/browse/KAFKA-13624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao updated KAFKA-13624:
--
Description: KIP-770 introduced a new metric called
`{*}input-buffer-bytes-total`{*} to track the
Sagar Rao created KAFKA-13624:
-
Summary: Add Metric for Store Cache Size
Key: KAFKA-13624
URL: https://issues.apache.org/jira/browse/KAFKA-13624
Project: Kafka
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/KAFKA-13349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480539#comment-17480539
]
Sagar Rao commented on KAFKA-13349:
---
Thanks [~guozhang] !
> Allow Iterator.remove on KeyValueIterator
[
https://issues.apache.org/jira/browse/KAFKA-13555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-13555:
-
Assignee: Sagar Rao
> Consider number if input topic partitions for task assignment
>
[
https://issues.apache.org/jira/browse/KAFKA-13349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17476821#comment-17476821
]
Sagar Rao commented on KAFKA-13349:
---
hey [~loboxu] , [~guozhang] . do you think I can take this one up
[
https://issues.apache.org/jira/browse/KAFKA-13349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17459635#comment-17459635
]
Sagar Rao commented on KAFKA-13349:
---
hey [~loboxu] are you still looking at this one?
> Allow
[
https://issues.apache.org/jira/browse/KAFKA-13499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-13499:
-
Assignee: Sagar Rao
> Avoid restoring outdated records
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-13501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-13501:
-
Assignee: Sagar Rao
> Avoid state restore via rebalance if standbys are enabled
>
[
https://issues.apache.org/jira/browse/KAFKA-12960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434075#comment-17434075
]
Sagar Rao commented on KAFKA-12960:
---
That’s something which the pr already addresses for persistent
[
https://issues.apache.org/jira/browse/KAFKA-13295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17426321#comment-17426321
]
Sagar Rao commented on KAFKA-13295:
---
hey [~ableegoldman], whenever you get the chance, plz help me
[
https://issues.apache.org/jira/browse/KAFKA-12957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17426311#comment-17426311
]
Sagar Rao commented on KAFKA-12957:
---
[~ableegoldman], sure. Assigned that one to myself.
> Refactor
[
https://issues.apache.org/jira/browse/KAFKA-13336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-13336:
-
Assignee: Sagar Rao
> Migrate StreamsBuilder/Topology class to interfaces and move Topology
>
[
https://issues.apache.org/jira/browse/KAFKA-13286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17422292#comment-17422292
]
Sagar Rao commented on KAFKA-13286:
---
hey [~guozhang], wanted to know is there anything that can be
[
https://issues.apache.org/jira/browse/KAFKA-13295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17422290#comment-17422290
]
Sagar Rao commented on KAFKA-13295:
---
[~ableegoldman], yes it does. I wanted to ask the same question,
[
https://issues.apache.org/jira/browse/KAFKA-13296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-13296:
-
Assignee: Sagar Rao
> Verify old assignment within StreamsPartitionAssignor
>
[
https://issues.apache.org/jira/browse/KAFKA-13295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17415486#comment-17415486
]
Sagar Rao commented on KAFKA-13295:
---
[~guozhang]/ [~ableegoldman] I assigned this to myself.. Would go
[
https://issues.apache.org/jira/browse/KAFKA-13295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-13295:
-
Assignee: Sagar Rao
> Long restoration times for new tasks can lead to transaction timeouts
>
[
https://issues.apache.org/jira/browse/KAFKA-13286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17413490#comment-17413490
]
Sagar Rao commented on KAFKA-13286:
---
[~guozhang], thanks for notifying about this on the PR link. I
[
https://issues.apache.org/jira/browse/KAFKA-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410473#comment-17410473
]
Sagar Rao commented on KAFKA-8295:
--
Sure thanks [~guozhang]
> Add merge() operator to State Stores.
>
[
https://issues.apache.org/jira/browse/KAFKA-12550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410010#comment-17410010
]
Sagar Rao commented on KAFKA-12550:
---
[~ableegoldman]/ [~mjsax], Thanks. it makes sense now. I liked
[
https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17401763#comment-17401763
]
Sagar Rao commented on KAFKA-13152:
---
Thanks [~mjsax]/[~guozhang]. I will start writing a KIP and send
[
https://issues.apache.org/jira/browse/KAFKA-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17401043#comment-17401043
]
Sagar Rao commented on KAFKA-8295:
--
I see. Is there a KIP for list append types for windowed joins? I
[
https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17401034#comment-17401034
]
Sagar Rao commented on KAFKA-13152:
---
[~mjsax], [~guozhang] I had a slightly different thought whereby
[
https://issues.apache.org/jira/browse/KAFKA-12550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17399177#comment-17399177
]
Sagar Rao commented on KAFKA-12550:
---
[~ableegoldman] assigned this one to myself. Couple of questions
[
https://issues.apache.org/jira/browse/KAFKA-12550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-12550:
-
Assignee: Sagar Rao
> Introduce RESTORING state to the KafkaStreams FSM
>
[
https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17399173#comment-17399173
]
Sagar Rao commented on KAFKA-13152:
---
[~guozhang], I was looking at this. One question i have is, what
[
https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17396412#comment-17396412
]
Sagar Rao commented on KAFKA-13152:
---
hey [~guozhang], i would like to take this up.. Will go through
[
https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-13152:
-
Assignee: Sagar Rao
> Replace "buffered.records.per.partition" with "input.buffer.max.bytes"
[
https://issues.apache.org/jira/browse/KAFKA-12957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17388947#comment-17388947
]
Sagar Rao commented on KAFKA-12957:
---
hey [~guozhang] i would like to work on this one.. regarding the
[
https://issues.apache.org/jira/browse/KAFKA-12957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-12957:
-
Assignee: Sagar Rao
> Refactor Streams Logical Plan Generation
>
[
https://issues.apache.org/jira/browse/KAFKA-12960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-12960:
-
Assignee: Sagar Rao
> WindowStore and SessionStore do not enforce strict retention time
>
[
https://issues.apache.org/jira/browse/KAFKA-12960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17388946#comment-17388946
]
Sagar Rao commented on KAFKA-12960:
---
I would like to take a stab at this one [~mjsax]. assigned this
[
https://issues.apache.org/jira/browse/KAFKA-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao updated KAFKA-8295:
-
Summary: Add merge() operator to State Stores. (was: Optimize count()
using RocksDB merge operator)
>
[
https://issues.apache.org/jira/browse/KAFKA-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17388924#comment-17388924
]
Sagar Rao commented on KAFKA-8295:
--
I see what you mean and I agree with what you say. I. guess updating
[
https://issues.apache.org/jira/browse/KAFKA-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17388235#comment-17388235
]
Sagar Rao edited comment on KAFKA-8295 at 7/27/21, 6:15 PM:
[~ableegoldman]..
[
https://issues.apache.org/jira/browse/KAFKA-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17388235#comment-17388235
]
Sagar Rao commented on KAFKA-8295:
--
[~ableegoldman].. wanted to know, if we can have a KIP for merge()
[
https://issues.apache.org/jira/browse/KAFKA-12486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17379188#comment-17379188
]
Sagar Rao commented on KAFKA-12486:
---
i was looking at this one today. Had one question on this.
I
[
https://issues.apache.org/jira/browse/KAFKA-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378253#comment-17378253
]
Sagar Rao commented on KAFKA-8295:
--
hey sorry to bug you on this again.. but wondering if you got a
[
https://issues.apache.org/jira/browse/KAFKA-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17373572#comment-17373572
]
Sagar Rao edited comment on KAFKA-8295 at 7/2/21, 2:36 PM:
---
[~ableegoldman], I
[
https://issues.apache.org/jira/browse/KAFKA-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17373572#comment-17373572
]
Sagar Rao commented on KAFKA-8295:
--
[~ableegoldman], I did some more analysis and here's a summary of
201 - 300 of 406 matches
Mail list logo
