|
|
|
KAFKA-2774
|
KAFKA-2365
Rename Copycat -> Kafka Connect
|
Ewen Cheslack-Postava
|
Ewen Cheslack-Postava
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2765
|
KAFKA-2365
Connectors and tasks should have versions that can be reported when they are instantiated
|
Ewen Cheslack-Postava
|
Ewen Cheslack-Postava
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2713
|
KAFKA-2365
Copycat worker should not call connector's/task's start methods in the control thread
|
Ewen Cheslack-Postava
|
Ewen Cheslack-Postava
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2626
|
KAFKA-2365
Null offsets in copycat causes exception in OffsetStorageWriter
|
Ewen Cheslack-Postava
|
Ewen Cheslack-Postava
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2622
|
KAFKA-2365
Add Time logical type for Copycat
|
Ewen Cheslack-Postava
|
Ewen Cheslack-Postava
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2484
|
KAFKA-2365
Add schema projection utilities
|
Liquan Pei
|
Ewen Cheslack-Postava
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2482
|
KAFKA-2365
Allow copycat sink tasks to pause/resume consumption of specific topic partitions
|
Ewen Cheslack-Postava
|
Ewen Cheslack-Postava
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2481
|
KAFKA-2365
Allow copycat sinks to request periodic invocation of put even if no new data is available
|
Liquan Pei
|
Ewen Cheslack-Postava
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2480
|
KAFKA-2365
Handle non-CopycatExceptions from SinkTasks
|
Ewen Cheslack-Postava
|
Ewen Cheslack-Postava
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2479
|
KAFKA-2365
Add CopycatExceptions to indicate transient and permanent errors in a connector/task
|
Liquan Pei
|
Ewen Cheslack-Postava
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2476
|
KAFKA-2365
Define logical types for Copycat data API
|
Ewen Cheslack-Postava
|
Ewen Cheslack-Postava
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2475
|
KAFKA-2365
Reduce copycat configs to only specify a converter or serializer, not both
|
Ewen Cheslack-Postava
|
Ewen Cheslack-Postava
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2474
|
KAFKA-2365
Add caching for converted Copycat schemas in JSONConverter
|
Ewen Cheslack-Postava
|
Ewen Cheslack-Postava
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2422
|
KAFKA-2365
Allow copycat connector plugins to be aliased to simpler names
|
Gwen Shapira
|
Ewen Cheslack-Postava
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2379
|
KAFKA-2365
Add Copycat documentation
|
Ewen Cheslack-Postava
|
Ewen Cheslack-Postava
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2377
|
KAFKA-2365
Add copycat system tests
|
Ewen Cheslack-Postava
|
Ewen Cheslack-Postava
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2375
|
KAFKA-2365
Implement elasticsearch Copycat sink connector
|
Liquan Pei
|
Ewen Cheslack-Postava
|
|
Resolved |
Won't Fix
|
|
|
|
|
|
|
|
KAFKA-2374
|
KAFKA-2365
Implement Copycat log/file connector
|
Ewen Cheslack-Postava
|
Ewen Cheslack-Postava
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2373
|
KAFKA-2365
Copycat distributed offset storage
|
Ewen Cheslack-Postava
|
Ewen Cheslack-Postava
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2372
|
KAFKA-2365
Copycat distributed config storage
|
Ewen Cheslack-Postava
|
Ewen Cheslack-Postava
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2371
|
KAFKA-2365
Add distributed coordinator implementation for Copycat
|
Ewen Cheslack-Postava
|
Ewen Cheslack-Postava
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2370
|
KAFKA-2365
Add pause/unpause connector support
|
Jason Gustafson
|
Ewen Cheslack-Postava
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2369
|
KAFKA-2365
Add Copycat REST API
|
Ewen Cheslack-Postava
|
Ewen Cheslack-Postava
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2368
|
KAFKA-2365
Add Copycat standalone CLI
|
Ewen Cheslack-Postava
|
Ewen Cheslack-Postava
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2367
|
KAFKA-2365
Add Copycat runtime data API
|
Ewen Cheslack-Postava
|
Ewen Cheslack-Postava
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2366
|
KAFKA-2365
Initial patch for Copycat
|
Ewen Cheslack-Postava
|
Ewen Cheslack-Postava
|
|
Resolved |
Fixed
|
|
|
|
|