Yash Mayya created KAFKA-16196:
--
Summary: Cast transform doesn't handle invalid whole value casts
gracefully
Key: KAFKA-16196
URL: https://issues.apache.org/jira/browse/KAFKA-16196
Project: Kafka
Yash Mayya created KAFKA-15888:
--
Summary: DistributedHerder log context should not use the same
client ID for each Connect worker by default
Key: KAFKA-15888
URL: https://issues.apache.org/jira/browse/KAFKA-15888
Yash Mayya created KAFKA-15570:
--
Summary: Add unit tests for MemoryConfigBackingStore
Key: KAFKA-15570
URL: https://issues.apache.org/jira/browse/KAFKA-15570
Project: Kafka
Issue Type: Test
[
https://issues.apache.org/jira/browse/KAFKA-15547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yash Mayya resolved KAFKA-15547.
Fix Version/s: 3.7.0
Resolution: Fixed
> Thread leak in MirrorMakerConfigTest#testClientCon
[
https://issues.apache.org/jira/browse/KAFKA-15177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yash Mayya resolved KAFKA-15177.
Fix Version/s: 3.6.0
Resolution: Fixed
> MirrorMaker 2 should implement the alterOffsets KI
Yash Mayya created KAFKA-15470:
--
Summary: Allow creating connectors in a stopped state
Key: KAFKA-15470
URL: https://issues.apache.org/jira/browse/KAFKA-15470
Project: Kafka
Issue Type: New Feat
[
https://issues.apache.org/jira/browse/KAFKA-14067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yash Mayya resolved KAFKA-14067.
Resolution: Fixed
> Sink connector override.consumer.group.id can conflict with worker group.id
>
Yash Mayya created KAFKA-15387:
--
Summary: Deprecate and remove Connect's duplicate task
configurations retrieval endpoint
Key: KAFKA-15387
URL: https://issues.apache.org/jira/browse/KAFKA-15387
Project:
Yash Mayya created KAFKA-15377:
--
Summary: GET /connectors/{connector}/tasks-config endpoint exposes
externalized secret values
Key: KAFKA-15377
URL: https://issues.apache.org/jira/browse/KAFKA-15377
Proj
Yash Mayya created KAFKA-15238:
--
Summary: Connect workers can be disabled by DLQ related stuck
admin client calls
Key: KAFKA-15238
URL: https://issues.apache.org/jira/browse/KAFKA-15238
Project: Kafka
Yash Mayya created KAFKA-15216:
--
Summary: InternalSinkRecord::newRecord method ignores the headers
argument
Key: KAFKA-15216
URL: https://issues.apache.org/jira/browse/KAFKA-15216
Project: Kafka
Yash Mayya created KAFKA-15182:
--
Summary: Normalize offsets before invoking
SourceConnector::alterOffsets
Key: KAFKA-15182
URL: https://issues.apache.org/jira/browse/KAFKA-15182
Project: Kafka
Yash Mayya created KAFKA-15179:
--
Summary: Add integration tests for the FileStream Sink and Source
connectors
Key: KAFKA-15179
URL: https://issues.apache.org/jira/browse/KAFKA-15179
Project: Kafka
Yash Mayya created KAFKA-15177:
--
Summary: MirrorMaker 2 should implement the alterOffsets KIP-875
API
Key: KAFKA-15177
URL: https://issues.apache.org/jira/browse/KAFKA-15177
Project: Kafka
Issu
Yash Mayya created KAFKA-15145:
--
Summary: AbstractWorkerSourceTask re-processes records filtered
out by SMTs on retriable exceptions
Key: KAFKA-15145
URL: https://issues.apache.org/jira/browse/KAFKA-15145
Yash Mayya created KAFKA-15121:
--
Summary: FileStreamSourceConnector and FileStreamSinkConnector
should implement KIP-875 APIs
Key: KAFKA-15121
URL: https://issues.apache.org/jira/browse/KAFKA-15121
Proje
Yash Mayya created KAFKA-15113:
--
Summary: Gracefully handle cases where a sink connector's admin
and consumer client config overrides target different Kafka clusters
Key: KAFKA-15113
URL: https://issues.apache.org/ji
[
https://issues.apache.org/jira/browse/KAFKA-14956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yash Mayya resolved KAFKA-14956.
Resolution: Fixed
> Flaky test
> org.apache.kafka.connect.integration.OffsetsApiIntegrationTest#t
Yash Mayya created KAFKA-14974:
--
Summary: Restore backward compatibility in KafkaBasedLog
Key: KAFKA-14974
URL: https://issues.apache.org/jira/browse/KAFKA-14974
Project: Kafka
Issue Type: Task
Yash Mayya created KAFKA-14933:
--
Summary: Document Kafka Connect's log level REST APIs added in
KIP-495
Key: KAFKA-14933
URL: https://issues.apache.org/jira/browse/KAFKA-14933
Project: Kafka
Is
Yash Mayya created KAFKA-14910:
--
Summary: Consider cancelling ongoing alter connector offsets
requests when the connector is resumed
Key: KAFKA-14910
URL: https://issues.apache.org/jira/browse/KAFKA-14910
Yash Mayya created KAFKA-14876:
--
Summary: Public documentation for new Kafka Connect offset
management REST APIs
Key: KAFKA-14876
URL: https://issues.apache.org/jira/browse/KAFKA-14876
Project: Kafka
Yash Mayya created KAFKA-14844:
--
Summary: Kafka Connect's OffsetBackingStore interface should
handle (de)serialization and connector namespacing
Key: KAFKA-14844
URL: https://issues.apache.org/jira/browse/KAFKA-14844
Yash Mayya created KAFKA-14732:
--
Summary: Use an exponential backoff retry mechanism while
reconfiguring connector tasks
Key: KAFKA-14732
URL: https://issues.apache.org/jira/browse/KAFKA-14732
Project: K
Yash Mayya created KAFKA-14569:
--
Summary: Migrate EmbeddedKafkaCluster used by Connect integration
tests from EmbeddedZookeeper to KRaft
Key: KAFKA-14569
URL: https://issues.apache.org/jira/browse/KAFKA-14569
Yash Mayya created KAFKA-14455:
--
Summary: Kafka Connect create and update REST APIs should surface
failures while writing to the config topic
Key: KAFKA-14455
URL: https://issues.apache.org/jira/browse/KAFKA-14455
Yash Mayya created KAFKA-14368:
--
Summary: Add an offset write REST API to Kafka Connect
Key: KAFKA-14368
URL: https://issues.apache.org/jira/browse/KAFKA-14368
Project: Kafka
Issue Type: New Fea
Yash Mayya created KAFKA-14353:
--
Summary: Make Kafka Connect REST request timeouts configurable
Key: KAFKA-14353
URL: https://issues.apache.org/jira/browse/KAFKA-14353
Project: Kafka
Issue Type:
Yash Mayya created KAFKA-14342:
--
Summary: KafkaOffsetBackingStore should clear offsets for source
partitions on tombstone messages
Key: KAFKA-14342
URL: https://issues.apache.org/jira/browse/KAFKA-14342
Yash Mayya created KAFKA-14193:
--
Summary: Connect system test ConnectRestApiTest is failing
Key: KAFKA-14193
URL: https://issues.apache.org/jira/browse/KAFKA-14193
Project: Kafka
Issue Type: Bug
Yash Mayya created KAFKA-14162:
--
Summary: HoistField SMT should not return an immutable map for
schemaless key/value
Key: KAFKA-14162
URL: https://issues.apache.org/jira/browse/KAFKA-14162
Project: Kafka
Yash Mayya created KAFKA-14147:
--
Summary: Some map objects in KafkaConfigBackingStore grow in size
monotonically
Key: KAFKA-14147
URL: https://issues.apache.org/jira/browse/KAFKA-14147
Project: Kafka
Yash Mayya created KAFKA-14134:
--
Summary: Replace EasyMock with Mockito for WorkerConnectorTest
Key: KAFKA-14134
URL: https://issues.apache.org/jira/browse/KAFKA-14134
Project: Kafka
Issue Type:
33 matches
Mail list logo