Sagar Rao created KAFKA-14971:
-
Summary: Flaky Test
org.apache.kafka.connect.mirror.integration.IdentityReplicationIntegrationTest#testSyncTopicConfigs
Key: KAFKA-14971
URL:
Sagar Rao created KAFKA-14956:
-
Summary: Flaky test
org.apache.kafka.connect.integration.OffsetsApiIntegrationTest#testGetSinkConnectorOffsetsDifferentKafkaClusterTargeted
Key: KAFKA-14956
URL:
[
https://issues.apache.org/jira/browse/KAFKA-14952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17718063#comment-17718063
]
Sagar Rao commented on KAFKA-14952:
---
hi [~blacktooth] thanks for reporting this. This certainly looks
[
https://issues.apache.org/jira/browse/KAFKA-14929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17716686#comment-17716686
]
Sagar Rao commented on KAFKA-14929:
---
hey [~viktorsomogyi] i assigned this one to myself.
> Flaky
[
https://issues.apache.org/jira/browse/KAFKA-14929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14929:
-
Assignee: Sagar Rao (was: Viktor Somogyi-Vass)
> Flaky
Sagar Rao created KAFKA-14938:
-
Summary: Flaky test
org.apache.kafka.connect.integration.ExactlyOnceSourceIntegrationTest#testConnectorBoundary
Key: KAFKA-14938
URL: https://issues.apache.org/jira/browse/KAFKA-14938
[
https://issues.apache.org/jira/browse/KAFKA-14705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao updated KAFKA-14705:
--
Description:
Redirections:
- core/src/main/scala/kafka/tools/JmxTool
-
[
https://issues.apache.org/jira/browse/KAFKA-14586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17714140#comment-17714140
]
Sagar Rao commented on KAFKA-14586:
---
Thanks [~fvaleri] , I created the PR.
> Move StreamsResetter to
[
https://issues.apache.org/jira/browse/KAFKA-14586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17713911#comment-17713911
]
Sagar Rao commented on KAFKA-14586:
---
[~mjsax] , I can add the redirection for this. I have read
[
https://issues.apache.org/jira/browse/KAFKA-14913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14913:
-
Assignee: Sagar Rao
> Migrate DistributedHerder Executor shutdown to use
>
[
https://issues.apache.org/jira/browse/KAFKA-14913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao updated KAFKA-14913:
--
Component/s: KafkaConnect
> Migrate DistributedHerder Executor shutdown to use
>
[
https://issues.apache.org/jira/browse/KAFKA-14586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17713388#comment-17713388
]
Sagar Rao commented on KAFKA-14586:
---
[~mjsax] , oh I didn't know there was already a KIP and a Jira
[
https://issues.apache.org/jira/browse/KAFKA-14913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao updated KAFKA-14913:
--
Description: Some context here:
https://github.com/apache/kafka/pull/13557#issuecomment-1509738740
>
Sagar Rao created KAFKA-14913:
-
Summary: Migrate DistributedHerder Executor shutdown to use
ThreadUtils#shutdownExecutorServiceQuietly
Key: KAFKA-14913
URL: https://issues.apache.org/jira/browse/KAFKA-14913
[
https://issues.apache.org/jira/browse/KAFKA-14750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712649#comment-17712649
]
Sagar Rao commented on KAFKA-14750:
---
Thanks for your response [~morozov] . I have created a PR for the
[
https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712357#comment-17712357
]
Sagar Rao commented on KAFKA-13152:
---
Thanks for the clarification [~mimaison] !
> Replace
[
https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712289#comment-17712289
]
Sagar Rao commented on KAFKA-13152:
---
Thanks Mickael. I have a clarifying question, this KIP was
[
https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711830#comment-17711830
]
Sagar Rao commented on KAFKA-13152:
---
hi [~mimaison] , the PR has already been raised
[
https://issues.apache.org/jira/browse/KAFKA-14750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17710994#comment-17710994
]
Sagar Rao commented on KAFKA-14750:
---
hi [~morozov] , even I am not an expert on the Kafka Clients
[
https://issues.apache.org/jira/browse/KAFKA-14873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17710078#comment-17710078
]
Sagar Rao commented on KAFKA-14873:
---
Hi [~malthe] , thanks for reporting this. I think your point
[
https://issues.apache.org/jira/browse/KAFKA-14750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17710077#comment-17710077
]
Sagar Rao commented on KAFKA-14750:
---
I ran a few more tests for this. This issue is found specifically
[
https://issues.apache.org/jira/browse/KAFKA-14586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao resolved KAFKA-14586.
---
Resolution: Fixed
> Move StreamsResetter to tools
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-14851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao updated KAFKA-14851:
--
Description: This came up as a suggestion here:
Sagar Rao created KAFKA-14851:
-
Summary: Move StreamResetterTest to tools module
Key: KAFKA-14851
URL: https://issues.apache.org/jira/browse/KAFKA-14851
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-14851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao updated KAFKA-14851:
--
Priority: Minor (was: Major)
> Move StreamResetterTest to tools module
>
[
https://issues.apache.org/jira/browse/KAFKA-12525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-12525:
-
Assignee: Sagar Rao (was: Konstantine Karantasis)
> Inaccurate task status due to status
[
https://issues.apache.org/jira/browse/KAFKA-14843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14843:
-
Assignee: Jorge Esteban Quilcate Otoya
> Connector plugins config endpoint does not include
[
https://issues.apache.org/jira/browse/KAFKA-13295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17704320#comment-17704320
]
Sagar Rao commented on KAFKA-13295:
---
Thanks [~guozhang] , glad to know that!
> Long restoration times
[
https://issues.apache.org/jira/browse/KAFKA-14583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14583:
-
Assignee: (was: Sagar Rao)
> Move ReplicaVerificationTool to tools
>
[
https://issues.apache.org/jira/browse/KAFKA-14699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17702155#comment-17702155
]
Sagar Rao commented on KAFKA-14699:
---
hi [~miguel_costa] , thanks for filing this improvement ticket.
[
https://issues.apache.org/jira/browse/KAFKA-14520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17702152#comment-17702152
]
Sagar Rao commented on KAFKA-14520:
---
[~waleedfateem] , I think there's a very similar issue
[
https://issues.apache.org/jira/browse/KAFKA-14750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700263#comment-17700263
]
Sagar Rao commented on KAFKA-14750:
---
hmm I tried the approach from above and turns out it's not very
[
https://issues.apache.org/jira/browse/KAFKA-14750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14750:
-
Assignee: Sagar Rao
> Sink connector fails if a topic matching its topics.regex gets deleted
>
[
https://issues.apache.org/jira/browse/KAFKA-13349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699492#comment-17699492
]
Sagar Rao commented on KAFKA-13349:
---
hi [~mahesh98] , it was assigned to me but I un-assigned as I
[
https://issues.apache.org/jira/browse/KAFKA-14750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699384#comment-17699384
]
Sagar Rao commented on KAFKA-14750:
---
Thanks [~morozov] for filing this and [~ChrisEgerton] for trying
[
https://issues.apache.org/jira/browse/KAFKA-13295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17698327#comment-17698327
]
Sagar Rao commented on KAFKA-13295:
---
Had a discussion with [~guozhang] and the suggestion is to wait
[
https://issues.apache.org/jira/browse/KAFKA-13295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao updated KAFKA-13295:
--
Fix Version/s: 4.0.0
(was: 3.5.0)
> Long restoration times for new tasks can
[
https://issues.apache.org/jira/browse/KAFKA-14520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697509#comment-17697509
]
Sagar Rao commented on KAFKA-14520:
---
hi [~waleedfateem] , thanks for filing this. TimeoutException
[
https://issues.apache.org/jira/browse/KAFKA-14091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696923#comment-17696923
]
Sagar Rao edited comment on KAFKA-14091 at 3/6/23 3:36 PM:
---
hi [~ChrisEgerton]
[
https://issues.apache.org/jira/browse/KAFKA-14091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696923#comment-17696923
]
Sagar Rao edited comment on KAFKA-14091 at 3/6/23 12:40 PM:
hi
[
https://issues.apache.org/jira/browse/KAFKA-14091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696923#comment-17696923
]
Sagar Rao commented on KAFKA-14091:
---
hi [~ChrisEgerton] , I started working on this. Had a clarifying
[
https://issues.apache.org/jira/browse/KAFKA-12550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-12550:
-
Assignee: (was: Sagar Rao)
> Introduce RESTORING state to the KafkaStreams FSM
>
[
https://issues.apache.org/jira/browse/KAFKA-13501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-13501:
-
Assignee: (was: Sagar Rao)
> Avoid state restore via rebalance if standbys are enabled
>
[
https://issues.apache.org/jira/browse/KAFKA-13499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-13499:
-
Assignee: (was: Sagar Rao)
> Avoid restoring outdated records
>
[
https://issues.apache.org/jira/browse/KAFKA-12957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-12957:
-
Assignee: (was: Sagar Rao)
> Refactor Streams Logical Plan Generation
>
[
https://issues.apache.org/jira/browse/KAFKA-13336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-13336:
-
Assignee: (was: Sagar Rao)
> Migrate StreamsBuilder/Topology class to interfaces and move
[
https://issues.apache.org/jira/browse/KAFKA-13349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-13349:
-
Assignee: (was: Sagar Rao)
> 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: (was: Sagar Rao)
> Consider number if input topic partitions for task assignment
[
https://issues.apache.org/jira/browse/KAFKA-14585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14585:
-
Assignee: (was: Sagar Rao)
> Move StorageTool to tools
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-14487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14487:
-
Assignee: (was: Sagar Rao)
> Move LogManager to storage module
>
Sagar Rao created KAFKA-14734:
-
Summary: Use CommandDefaultOptions in StreamsResetter
Key: KAFKA-14734
URL: https://issues.apache.org/jira/browse/KAFKA-14734
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17688824#comment-17688824
]
Sagar Rao commented on KAFKA-13152:
---
Thanks [~guozhang] , [~mimaison]
> Replace
[
https://issues.apache.org/jira/browse/KAFKA-14401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao updated KAFKA-14401:
--
Labels: (was: KafkaConnect)
> Connector/Tasks reading offsets can get stuck if underneath
[
https://issues.apache.org/jira/browse/KAFKA-14401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao updated KAFKA-14401:
--
Component/s: KafkaConnect
> Connector/Tasks reading offsets can get stuck if underneath WorkThread
[
https://issues.apache.org/jira/browse/KAFKA-14401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao updated KAFKA-14401:
--
Labels: KafkaConnect (was: Connect)
> Connector/Tasks reading offsets can get stuck if underneath
[
https://issues.apache.org/jira/browse/KAFKA-14401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao updated KAFKA-14401:
--
Labels: Connect (was: )
> Connector/Tasks reading offsets can get stuck if underneath WorkThread
[
https://issues.apache.org/jira/browse/KAFKA-14487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17682769#comment-17682769
]
Sagar Rao edited comment on KAFKA-14487 at 1/31/23 9:22 PM:
I started
[
https://issues.apache.org/jira/browse/KAFKA-14487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17682769#comment-17682769
]
Sagar Rao commented on KAFKA-14487:
---
I started looking at this. It depends on
[
https://issues.apache.org/jira/browse/KAFKA-14487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14487:
-
Assignee: Sagar Rao
> Move LogManager to storage module
> -
>
[
https://issues.apache.org/jira/browse/KAFKA-14585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14585:
-
Assignee: Sagar Rao
> Move StorageTool to tools
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-14487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17680230#comment-17680230
]
Sagar Rao commented on KAFKA-14487:
---
[~ijuma] , is it ok if I can pick this one up? Seems like it's
[
https://issues.apache.org/jira/browse/KAFKA-14583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17680082#comment-17680082
]
Sagar Rao commented on KAFKA-14583:
---
Thanks Federico. Created this ticket for tracking:
[
https://issues.apache.org/jira/browse/KAFKA-14647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17680081#comment-17680081
]
Sagar Rao commented on KAFKA-14647:
---
Move TopicFilter in core/kafka/utils to server-common util since
Sagar Rao created KAFKA-14647:
-
Summary: Move TopicFilter shared class
Key: KAFKA-14647
URL: https://issues.apache.org/jira/browse/KAFKA-14647
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-14647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14647:
-
Assignee: Sagar Rao (was: Federico Valeri)
> Move TopicFilter shared class
>
[
https://issues.apache.org/jira/browse/KAFKA-14583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679555#comment-17679555
]
Sagar Rao edited comment on KAFKA-14583 at 1/22/23 1:20 PM:
This class has
[
https://issues.apache.org/jira/browse/KAFKA-14583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679555#comment-17679555
]
Sagar Rao commented on KAFKA-14583:
---
This class has a dependency on `TopicFilter` which is part of
[
https://issues.apache.org/jira/browse/KAFKA-10652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao resolved KAFKA-10652.
---
Resolution: Won't Fix
Not sure this is needed anymore.
> Raft leader should flush accumulated
[
https://issues.apache.org/jira/browse/KAFKA-13296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao resolved KAFKA-13296.
---
Resolution: Fixed
> Verify old assignment within StreamsPartitionAssignor
>
[
https://issues.apache.org/jira/browse/KAFKA-14153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14153:
-
Assignee: (was: Sagar Rao)
> UnknownTopicOrPartitionException should include the
[
https://issues.apache.org/jira/browse/KAFKA-14580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14580:
-
Assignee: Sagar Rao
> Move EndToEndLatency to tools
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-14625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17678259#comment-17678259
]
Sagar Rao commented on KAFKA-14625:
---
[~ijuma] , I see. [~satish.duggana] , do you think the collection
[
https://issues.apache.org/jira/browse/KAFKA-14625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17677875#comment-17677875
]
Sagar Rao commented on KAFKA-14625:
---
hey [~satish.duggana] , i am assuming you plan to work on this?
[
https://issues.apache.org/jira/browse/KAFKA-14586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14586:
-
Assignee: Sagar Rao
> Move StreamsResetter to tools
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-14583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14583:
-
Assignee: Sagar Rao
> Move ReplicaVerificationTool to tools
>
[
https://issues.apache.org/jira/browse/KAFKA-14490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17676593#comment-17676593
]
Sagar Rao commented on KAFKA-14490:
---
[~ijuma] , can I take this one up?
> Consider using
[
https://issues.apache.org/jira/browse/KAFKA-14460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14460:
-
Assignee: (was: Sagar Rao)
> In-memory store iterators can return results with null values
[
https://issues.apache.org/jira/browse/KAFKA-14461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao updated KAFKA-14461:
--
Description:
{noformat}
StoreQueryIntegrationTest#shouldQuerySpecificActivePartitionStores {noformat}
[
https://issues.apache.org/jira/browse/KAFKA-14461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao updated KAFKA-14461:
--
Description:
`StoreQueryIntegrationTest#shouldQuerySpecificActivePartitionStores` has a
logic to
[
https://issues.apache.org/jira/browse/KAFKA-14461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao updated KAFKA-14461:
--
Description:
`StoreQueryIntegrationTest#shouldQuerySpecificActivePartitionStores` has a
logic to
[
https://issues.apache.org/jira/browse/KAFKA-14461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao updated KAFKA-14461:
--
Description:
`
was:
> StoreQueryIntegrationTest#shouldQuerySpecificActivePartitionStores
[
https://issues.apache.org/jira/browse/KAFKA-14461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao updated KAFKA-14461:
--
Description:
was:
Newly added test
Sagar Rao created KAFKA-14461:
-
Summary:
StoreQueryIntegrationTest#shouldQuerySpecificActivePartitionStores logic to
check for active partitions seems brittle.
Key: KAFKA-14461
URL:
[
https://issues.apache.org/jira/browse/KAFKA-14460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14460:
-
Assignee: Sagar Rao
> In-memory store iterators can return results with null values
>
[
https://issues.apache.org/jira/browse/KAFKA-14454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao updated KAFKA-14454:
--
Description:
Newly added test
Sagar Rao created KAFKA-14454:
-
Summary:
KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest#shouldThrowIllegalArgumentExceptionWhenCustomPartionerReturnsMultiplePartitions
passes when run individually but not when is run as part of the
[
https://issues.apache.org/jira/browse/KAFKA-14401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637589#comment-17637589
]
Sagar Rao commented on KAFKA-14401:
---
There are a couple of routes that can be taken here:
1) As
[
https://issues.apache.org/jira/browse/KAFKA-14401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao updated KAFKA-14401:
--
Description:
When a connector or task tries to read the offsets from the offsets topic, it
issues
Sagar Rao created KAFKA-14401:
-
Summary: Connector/Tasks reading offsets can get stuck if
underneath WorkThread dies
Key: KAFKA-14401
URL: https://issues.apache.org/jira/browse/KAFKA-14401
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-14311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14311:
-
Assignee: Sagar Rao
> Connect Worker clean shutdown does not cleanly stop connectors/tasks
>
[
https://issues.apache.org/jira/browse/KAFKA-14153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14153:
-
Assignee: Sagar Rao
> UnknownTopicOrPartitionException should include the topic/partition in
[
https://issues.apache.org/jira/browse/KAFKA-14000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17585291#comment-17585291
]
Sagar Rao commented on KAFKA-14000:
---
I think one approach to reduce the above error could it to have
[
https://issues.apache.org/jira/browse/KAFKA-14015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17582519#comment-17582519
]
Sagar Rao edited comment on KAFKA-14015 at 8/26/22 10:24 AM:
-
[~rozza] ,
[
https://issues.apache.org/jira/browse/KAFKA-14000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17582972#comment-17582972
]
Sagar Rao commented on KAFKA-14000:
---
I took a look at this today. Looking at the trace logs, the
[
https://issues.apache.org/jira/browse/KAFKA-12495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17582710#comment-17582710
]
Sagar Rao edited comment on KAFKA-12495 at 8/22/22 3:46 AM:
Thanks
[
https://issues.apache.org/jira/browse/KAFKA-12495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17582710#comment-17582710
]
Sagar Rao commented on KAFKA-12495:
---
Thanks [~showuon] for your comments.
Regarding the new draft
[
https://issues.apache.org/jira/browse/KAFKA-14000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17582583#comment-17582583
]
Sagar Rao commented on KAFKA-14000:
---
[~ChrisEgerton] , Oh yeah.. Sorry I missed that. Thanks for
[
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
>
101 - 200 of 403 matches
Mail list logo
