Sagar Rao created KAFKA-16197:
-
Summary: Connect Worker poll timeout prints Consumer poll timeout
specific warnings.
Key: KAFKA-16197
URL: https://issues.apache.org/jira/browse/KAFKA-16197
Project: Kafka
Sagar Rao created KAFKA-16056:
-
Summary: Worker poll timeout expiry can lead to Duplicate task
assignments.
Key: KAFKA-16056
URL: https://issues.apache.org/jira/browse/KAFKA-16056
Project: Kafka
Sagar Rao created KAFKA-15296:
-
Summary: Allow committing offsets for Dropped records via SMTs
Key: KAFKA-15296
URL: https://issues.apache.org/jira/browse/KAFKA-15296
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-15005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao resolved KAFKA-15005.
---
Resolution: Duplicate
> Status of KafkaConnect task not correct
>
[
https://issues.apache.org/jira/browse/KAFKA-12283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao resolved KAFKA-12283.
---
Resolution: Fixed
> Flaky Test
>
[
https://issues.apache.org/jira/browse/KAFKA-8391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao resolved KAFKA-8391.
--
Resolution: Fixed
Fixed with https://github.com/apache/kafka/pull/12561
> Flaky Test
Sagar Rao created KAFKA-15229:
-
Summary: Increase default value of
task.shutdown.graceful.timeout.ms
Key: KAFKA-15229
URL: https://issues.apache.org/jira/browse/KAFKA-15229
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-12525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao resolved KAFKA-12525.
---
Resolution: Fixed
> Inaccurate task status due to status record interleaving in fast rebalances
>
Sagar Rao created KAFKA-15127:
-
Summary: Allow offsets to be reset at the same time a connector is
deleted.
Key: KAFKA-15127
URL: https://issues.apache.org/jira/browse/KAFKA-15127
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-14913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao resolved KAFKA-14913.
---
Resolution: Fixed
> Migrate DistributedHerder Executor shutdown to use
>
Sagar Rao created KAFKA-15041:
-
Summary: Source Connector auto topic creation fails when topic is
deleted and brokers don't support auto topic creation
Key: KAFKA-15041
URL:
Sagar Rao created KAFKA-14997:
-
Summary: JmxToolTest failing with initializationError
Key: KAFKA-14997
URL: https://issues.apache.org/jira/browse/KAFKA-14997
Project: Kafka
Issue Type: Bug
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:
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
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-14586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao resolved KAFKA-14586.
---
Resolution: Fixed
> Move StreamsResetter to tools
> -
>
>
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
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
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-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
>
Sagar Rao created KAFKA-14461:
-
Summary:
StoreQueryIntegrationTest#shouldQuerySpecificActivePartitionStores logic to
check for active partitions seems brittle.
Key: KAFKA-14461
URL:
Sagar Rao created KAFKA-14454:
-
Summary:
KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest#shouldThrowIllegalArgumentExceptionWhenCustomPartionerReturnsMultiplePartitions
passes when run individually but not when is run as part of the
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-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-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
>
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-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-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-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-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"
>
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
Sagar Rao created KAFKA-12289:
-
Summary: Add Tests for prefixScan in InMemoryKeyValueStore
Key: KAFKA-12289
URL: https://issues.apache.org/jira/browse/KAFKA-12289
Project: Kafka
Issue Type:
Sagar Rao created KAFKA-10789:
-
Summary: Streamlining Tests in ChangeLoggingKeyValueBytesStoreTest
Key: KAFKA-10789
URL: https://issues.apache.org/jira/browse/KAFKA-10789
Project: Kafka
Issue
Sagar Rao created KAFKA-10788:
-
Summary: Streamlining Tests in CachingInMemoryKeyValueStoreTest
Key: KAFKA-10788
URL: https://issues.apache.org/jira/browse/KAFKA-10788
Project: Kafka
Issue Type:
Sagar Rao created KAFKA-10767:
-
Summary: Add Unit Test cases for missing methods in ThreadCacheTest
Key: KAFKA-10767
URL: https://issues.apache.org/jira/browse/KAFKA-10767
Project: Kafka
Issue
Sagar Rao created KAFKA-10766:
-
Summary: Add Unit Test cases for RocksDbRangeIterator
Key: KAFKA-10766
URL: https://issues.apache.org/jira/browse/KAFKA-10766
Project: Kafka
Issue Type:
Sagar Rao created KAFKA-10648:
-
Summary: Add Prefix Scan support to State Stores
Key: KAFKA-10648
URL: https://issues.apache.org/jira/browse/KAFKA-10648
Project: Kafka
Issue Type: Improvement
Sagar Rao created KAFKA-9168:
Summary: Integrate JNI direct buffer support to RocksDBStore
Key: KAFKA-9168
URL: https://issues.apache.org/jira/browse/KAFKA-9168
Project: Kafka
Issue Type: Task
[
https://issues.apache.org/jira/browse/KAFKA-4371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao resolved KAFKA-4371.
--
Resolution: Not A Problem
> Sporadic ConnectException shuts down the whole connect process
>
[
https://issues.apache.org/jira/browse/KAFKA-4371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15636091#comment-15636091
]
Sagar Rao commented on KAFKA-4371:
--
[~ewencp] By shutting down I meant that the processing of data
[
https://issues.apache.org/jira/browse/KAFKA-4371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632717#comment-15632717
]
Sagar Rao commented on KAFKA-4371:
--
Another thing to note is that we get this exception when I try to
Sagar Rao created KAFKA-4371:
Summary: Sporadic ConnectException shuts down the whole connect
process
Key: KAFKA-4371
URL: https://issues.apache.org/jira/browse/KAFKA-4371
Project: Kafka
Issue
Sagar Rao created KAFKA-4342:
Summary: Kafka-connect- support tinyint values
Key: KAFKA-4342
URL: https://issues.apache.org/jira/browse/KAFKA-4342
Project: Kafka
Issue Type: Bug
45 matches
Mail list logo
