[jira] [Commented] (KAFKA-7509) Kafka Connect logs unnecessary warnings about unused configurations

[ https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17507768#comment-17507768 ] Chris Egerton commented on KAFKA-7509: -- Bumping this again as the problem continues to persist for

[jira] [Assigned] (KAFKA-13497) Debug Log RegexRouter transform

[ https://issues.apache.org/jira/browse/KAFKA-13497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-13497: - Assignee: Chris Egerton > Debug Log RegexRouter transform >

[jira] [Commented] (KAFKA-12990) Infinite Loop in producing event to kafka

[ https://issues.apache.org/jira/browse/KAFKA-12990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17507303#comment-17507303 ] Chris Egerton commented on KAFKA-12990: --- Worth noting that with

[jira] [Commented] (KAFKA-13634) Kafka sends false information to the Debezium Connector in case the heartbeat topic does not exists

[ https://issues.apache.org/jira/browse/KAFKA-13634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17507299#comment-17507299 ] Chris Egerton commented on KAFKA-13634: --- Seems like this may be a duplicate of KAFKA-12990.

[jira] [Comment Edited] (KAFKA-13613) Kafka Connect has a hard dependency on KeyGenerator.HmacSHA256

[ https://issues.apache.org/jira/browse/KAFKA-13613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17506571#comment-17506571 ] Chris Egerton edited comment on KAFKA-13613 at 3/14/22, 10:58 PM: --

[jira] [Assigned] (KAFKA-13613) Kafka Connect has a hard dependency on KeyGenerator.HmacSHA256

[ https://issues.apache.org/jira/browse/KAFKA-13613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-13613: - Assignee: Chris Egerton > Kafka Connect has a hard dependency on

[jira] [Commented] (KAFKA-13613) Kafka Connect has a hard dependency on KeyGenerator.HmacSHA256

[ https://issues.apache.org/jira/browse/KAFKA-13613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17506571#comment-17506571 ] Chris Egerton commented on KAFKA-13613: --- Thanks for reporting this, [~that_guy]. I'm working on a

[jira] [Comment Edited] (KAFKA-13613) Kafka Connect has a hard dependency on KeyGenerator.HmacSHA256

[ https://issues.apache.org/jira/browse/KAFKA-13613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17506571#comment-17506571 ] Chris Egerton edited comment on KAFKA-13613 at 3/14/22, 9:29 PM: - Thanks

[jira] [Updated] (KAFKA-13731) Standalone Connect workers should not require connector configs to start

[ https://issues.apache.org/jira/browse/KAFKA-13731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-13731: -- Priority: Minor (was: Major) > Standalone Connect workers should not require connector

[jira] [Created] (KAFKA-13731) Standalone Connect workers should not require connector configs to start

Chris Egerton created KAFKA-13731: - Summary: Standalone Connect workers should not require connector configs to start Key: KAFKA-13731 URL: https://issues.apache.org/jira/browse/KAFKA-13731 Project:

[jira] [Comment Edited] (KAFKA-12879) Compatibility break in Admin.listOffsets()

[ https://issues.apache.org/jira/browse/KAFKA-12879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503865#comment-17503865 ] Chris Egerton edited comment on KAFKA-12879 at 3/9/22, 9:51 PM: Are

[jira] [Comment Edited] (KAFKA-12879) Compatibility break in Admin.listOffsets()

[ https://issues.apache.org/jira/browse/KAFKA-12879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503865#comment-17503865 ] Chris Egerton edited comment on KAFKA-12879 at 3/9/22, 9:50 PM: Are

[jira] [Commented] (KAFKA-12879) Compatibility break in Admin.listOffsets()

[ https://issues.apache.org/jira/browse/KAFKA-12879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503865#comment-17503865 ] Chris Egerton commented on KAFKA-12879: --- Are there any practical use cases for listing the offsets

[jira] [Created] (KAFKA-13709) Document exactly-once support for source connectors

Chris Egerton created KAFKA-13709: - Summary: Document exactly-once support for source connectors Key: KAFKA-13709 URL: https://issues.apache.org/jira/browse/KAFKA-13709 Project: Kafka Issue

[jira] [Comment Edited] (KAFKA-13631) Warning "Ignoring await stop request for non-present connector..." when shutting down connector via API in distributed mode

[ https://issues.apache.org/jira/browse/KAFKA-13631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499337#comment-17499337 ] Chris Egerton edited comment on KAFKA-13631 at 3/1/22, 5:27 AM:

[jira] [Comment Edited] (KAFKA-13631) Warning "Ignoring await stop request for non-present connector..." when shutting down connector via API in distributed mode

[ https://issues.apache.org/jira/browse/KAFKA-13631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499337#comment-17499337 ] Chris Egerton edited comment on KAFKA-13631 at 3/1/22, 5:26 AM:

[jira] [Commented] (KAFKA-13631) Warning "Ignoring await stop request for non-present connector..." when shutting down connector via API in distributed mode

[ https://issues.apache.org/jira/browse/KAFKA-13631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499337#comment-17499337 ] Chris Egerton commented on KAFKA-13631: --- Interestingly enough, it seemed initially like this was a

[jira] [Updated] (KAFKA-9374) Worker can be disabled by blocked connectors

[ https://issues.apache.org/jira/browse/KAFKA-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-9374: - Description: If a connector hangs during any of its {{{}initialize{}}}, {{{}start{}}},

[jira] [Created] (KAFKA-13669) Log messages for source tasks with no offsets to commit are noisy and confusing

Chris Egerton created KAFKA-13669: - Summary: Log messages for source tasks with no offsets to commit are noisy and confusing Key: KAFKA-13669 URL: https://issues.apache.org/jira/browse/KAFKA-13669

[jira] [Commented] (KAFKA-12495) Unbalanced connectors/tasks distribution will happen in Connect's incremental cooperative assignor

[ https://issues.apache.org/jira/browse/KAFKA-12495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489790#comment-17489790 ] Chris Egerton commented on KAFKA-12495: --- Hi [~showuon]! I'm taking time off right now but should

[jira] [Assigned] (KAFKA-12495) Unbalanced connectors/tasks distribution will happen in Connect's incremental cooperative assignor

[ https://issues.apache.org/jira/browse/KAFKA-12495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-12495: - Assignee: Chris Egerton (was: Luke Chen) > Unbalanced connectors/tasks distribution

[jira] [Assigned] (KAFKA-12495) Unbalanced connectors/tasks distribution will happen in Connect's incremental cooperative assignor

[ https://issues.apache.org/jira/browse/KAFKA-12495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-12495: - Assignee: Luke Chen (was: Chris Egerton) > Unbalanced connectors/tasks distribution

[jira] [Updated] (KAFKA-12495) Unbalanced connectors/tasks distribution will happen in Connect's incremental cooperative assignor

[ https://issues.apache.org/jira/browse/KAFKA-12495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-12495: -- Component/s: KafkaConnect > Unbalanced connectors/tasks distribution will happen in Connect's

[jira] [Created] (KAFKA-13533) Task resources are not cleaned up if task initialization fails

Chris Egerton created KAFKA-13533: - Summary: Task resources are not cleaned up if task initialization fails Key: KAFKA-13533 URL: https://issues.apache.org/jira/browse/KAFKA-13533 Project: Kafka

[jira] [Commented] (KAFKA-13469) End-of-life offset commit for source task can take place before all records are flushed

[ https://issues.apache.org/jira/browse/KAFKA-13469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448054#comment-17448054 ] Chris Egerton commented on KAFKA-13469: --- Approved as a 3.1 blocker on the [3.1 release

[jira] [Commented] (KAFKA-13472) Connect can lose track of last committed offsets for topic partitions after partial consumer revocation

[ https://issues.apache.org/jira/browse/KAFKA-13472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448053#comment-17448053 ] Chris Egerton commented on KAFKA-13472: --- Approved as a 3.1 blocker on the [3.1 release

[jira] [Updated] (KAFKA-13472) Connect can lose track of last committed offsets for topic partitions after partial consumer revocation

[ https://issues.apache.org/jira/browse/KAFKA-13472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-13472: -- Priority: Blocker (was: Major) > Connect can lose track of last committed offsets for topic

[jira] [Updated] (KAFKA-13472) Connect can lose track of last committed offsets for topic partitions after partial consumer revocation

[ https://issues.apache.org/jira/browse/KAFKA-13472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-13472: -- Fix Version/s: 3.1.0 3.0.1 > Connect can lose track of last committed

[jira] [Created] (KAFKA-13472) Connect can lose track of last committed offsets for topic partitions after partial consumer revocation

Chris Egerton created KAFKA-13472: - Summary: Connect can lose track of last committed offsets for topic partitions after partial consumer revocation Key: KAFKA-13472 URL:

[jira] [Created] (KAFKA-13469) End-of-life offset commit for source task can take place before all records are flushed

Chris Egerton created KAFKA-13469: - Summary: End-of-life offset commit for source task can take place before all records are flushed Key: KAFKA-13469 URL: https://issues.apache.org/jira/browse/KAFKA-13469

[jira] [Commented] (KAFKA-10334) Transactions not working properly

[ https://issues.apache.org/jira/browse/KAFKA-10334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445419#comment-17445419 ] Chris Egerton commented on KAFKA-10334: --- [~luis.araujo] that detail might help (but we should

[jira] [Assigned] (KAFKA-9279) Silent data loss in Kafka producer

[ https://issues.apache.org/jira/browse/KAFKA-9279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-9279: Assignee: Chris Egerton > Silent data loss in Kafka producer >

[jira] [Commented] (KAFKA-10334) Transactions not working properly

[ https://issues.apache.org/jira/browse/KAFKA-10334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444589#comment-17444589 ] Chris Egerton commented on KAFKA-10334: --- It seems like this may be a duplicate of

[jira] [Comment Edited] (KAFKA-13329) Connect does not perform preflight validation for per-connector key and value converters

[ https://issues.apache.org/jira/browse/KAFKA-13329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17421507#comment-17421507 ] Chris Egerton edited comment on KAFKA-13329 at 10/1/21, 4:02 PM: - I

[jira] [Commented] (KAFKA-13329) Connect does not perform preflight validation for per-connector key and value converters

[ https://issues.apache.org/jira/browse/KAFKA-13329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17421507#comment-17421507 ] Chris Egerton commented on KAFKA-13329: --- I agree that that'd be beneficial, although I think it'd

[jira] [Updated] (KAFKA-13328) Connect does not perform preflight validation for per-connector header converters

[ https://issues.apache.org/jira/browse/KAFKA-13328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-13328: -- Description: Users may specify a header converter class for their connector directly in the

[jira] [Created] (KAFKA-13329) Connect does not perform preflight validation for per-connector key and value converters

Chris Egerton created KAFKA-13329: - Summary: Connect does not perform preflight validation for per-connector key and value converters Key: KAFKA-13329 URL: https://issues.apache.org/jira/browse/KAFKA-13329

[jira] [Updated] (KAFKA-13328) Connect does not perform preflight validation for per-connector header converters

[ https://issues.apache.org/jira/browse/KAFKA-13328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-13328: -- Summary: Connect does not perform preflight validation for per-connector header converters

[jira] [Created] (KAFKA-13328) Preflight validation of header converters is not performed by Connect

Chris Egerton created KAFKA-13328: - Summary: Preflight validation of header converters is not performed by Connect Key: KAFKA-13328 URL: https://issues.apache.org/jira/browse/KAFKA-13328 Project:

[jira] [Created] (KAFKA-13327) Preflight validations of connectors leads to 500 responses

Chris Egerton created KAFKA-13327: - Summary: Preflight validations of connectors leads to 500 responses Key: KAFKA-13327 URL: https://issues.apache.org/jira/browse/KAFKA-13327 Project: Kafka

[jira] [Assigned] (KAFKA-9228) Reconfigured converters and clients may not be propagated to connector tasks

[ https://issues.apache.org/jira/browse/KAFKA-9228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-9228: Assignee: (was: Chris Egerton) > Reconfigured converters and clients may not be

[jira] [Updated] (KAFKA-12226) High-throughput source tasks fail to commit offsets

[ https://issues.apache.org/jira/browse/KAFKA-12226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-12226: -- Description: The current source task thread has the following workflow: # Poll messages from

[jira] [Resolved] (KAFKA-12857) Using Connect Sink with CooperativeStickyAssignor results in commit offsets failure

[ https://issues.apache.org/jira/browse/KAFKA-12857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-12857. --- Assignee: (was: dgd_contributor) Resolution: Duplicate > Using Connect Sink with

[jira] [Commented] (KAFKA-12857) Using Connect Sink with CooperativeStickyAssignor results in commit offsets failure

[ https://issues.apache.org/jira/browse/KAFKA-12857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17375714#comment-17375714 ] Chris Egerton commented on KAFKA-12857: --- I believe this is a duplicate of

[jira] [Updated] (KAFKA-13017) Excessive logging on sink task deserialization errors

[ https://issues.apache.org/jira/browse/KAFKA-13017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-13017: -- Description: Even with {{errors.log.enable}} set to {{false}}, deserialization failures are

[jira] [Created] (KAFKA-13017) Excessive logging on sink task deserialization errors

Chris Egerton created KAFKA-13017: - Summary: Excessive logging on sink task deserialization errors Key: KAFKA-13017 URL: https://issues.apache.org/jira/browse/KAFKA-13017 Project: Kafka

[jira] [Assigned] (KAFKA-12980) Allow consumers to return from poll when position advances due to aborted transactions

[ https://issues.apache.org/jira/browse/KAFKA-12980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-12980: - Assignee: Chris Egerton > Allow consumers to return from poll when position advances

[jira] [Commented] (KAFKA-12980) Allow consumers to return from poll when position advances due to aborted transactions

[ https://issues.apache.org/jira/browse/KAFKA-12980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17372052#comment-17372052 ] Chris Egerton commented on KAFKA-12980: --- [~ijuma] I'd be happy to. Wanted to make sure that this

[jira] [Commented] (KAFKA-12980) Allow consumers to return from poll when position advances due to aborted transactions

[ https://issues.apache.org/jira/browse/KAFKA-12980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17367563#comment-17367563 ] Chris Egerton commented on KAFKA-12980: --- [~guozhang] would you also like to weigh in? > Allow

[jira] [Commented] (KAFKA-12980) Allow consumers to return from poll when position advances due to aborted transactions

[ https://issues.apache.org/jira/browse/KAFKA-12980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17367556#comment-17367556 ] Chris Egerton commented on KAFKA-12980: --- CC [~hachikuji]--thoughts on this? > Allow consumers to

[jira] [Updated] (KAFKA-12980) Allow consumers to return from poll when position advances due to aborted transactions

[ https://issues.apache.org/jira/browse/KAFKA-12980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-12980: -- Summary: Allow consumers to return from poll when position advances due to aborted

[jira] [Created] (KAFKA-12980) Allow consumers to return from poll when position advances

Chris Egerton created KAFKA-12980: - Summary: Allow consumers to return from poll when position advances Key: KAFKA-12980 URL: https://issues.apache.org/jira/browse/KAFKA-12980 Project: Kafka

[jira] [Commented] (KAFKA-12487) Sink connectors do not work with the cooperative consumer rebalance protocol

[ https://issues.apache.org/jira/browse/KAFKA-12487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17362956#comment-17362956 ] Chris Egerton commented on KAFKA-12487: --- Hi [~showuon]--first off, congrats on the KIP! My PR has

[jira] [Commented] (KAFKA-12717) Remove internal converter config properties

[ https://issues.apache.org/jira/browse/KAFKA-12717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17339833#comment-17339833 ] Chris Egerton commented on KAFKA-12717: --- Filed

[jira] [Commented] (KAFKA-12726) misbehaving Task.stop() can prevent other Tasks from stopping

[ https://issues.apache.org/jira/browse/KAFKA-12726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337024#comment-17337024 ] Chris Egerton commented on KAFKA-12726: --- Okay, that makes the problem clearer (y). Maybe we can

[jira] [Commented] (KAFKA-12726) misbehaving Task.stop() can prevent other Tasks from stopping

[ https://issues.apache.org/jira/browse/KAFKA-12726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335638#comment-17335638 ] Chris Egerton commented on KAFKA-12726: --- Ahhh, that makes sense. We wrestled with this a bit in

[jira] [Commented] (KAFKA-12726) misbehaving Task.stop() can prevent other Tasks from stopping

[ https://issues.apache.org/jira/browse/KAFKA-12726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335389#comment-17335389 ] Chris Egerton commented on KAFKA-12726: --- [~ryannedolan] can you confirm that this has been

[jira] [Updated] (KAFKA-12717) Remove internal converter config properties

[ https://issues.apache.org/jira/browse/KAFKA-12717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-12717: -- Labels: needs-kip (was: ) > Remove internal converter config properties >

[jira] [Created] (KAFKA-12717) Remove internal converter config properties

Chris Egerton created KAFKA-12717: - Summary: Remove internal converter config properties Key: KAFKA-12717 URL: https://issues.apache.org/jira/browse/KAFKA-12717 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-5540) Deprecate internal converter configs

[ https://issues.apache.org/jira/browse/KAFKA-5540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-5540: - Summary: Deprecate internal converter configs (was: Deprecate and remove internal converter

[jira] [Updated] (KAFKA-12497) Source task offset commits continue even after task has failed

[ https://issues.apache.org/jira/browse/KAFKA-12497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-12497: -- Description: Source task offset commits take place on a dedicated thread, which periodically

[jira] [Comment Edited] (KAFKA-12487) Sink connectors do not work with the cooperative consumer rebalance protocol

[ https://issues.apache.org/jira/browse/KAFKA-12487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319412#comment-17319412 ] Chris Egerton edited comment on KAFKA-12487 at 4/12/21, 12:19 PM: --

[jira] [Commented] (KAFKA-12487) Sink connectors do not work with the cooperative consumer rebalance protocol

[ https://issues.apache.org/jira/browse/KAFKA-12487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319412#comment-17319412 ] Chris Egerton commented on KAFKA-12487: --- Based on recent

[jira] [Commented] (KAFKA-12651) Connect should register REST extensions before REST resources

[ https://issues.apache.org/jira/browse/KAFKA-12651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318793#comment-17318793 ] Chris Egerton commented on KAFKA-12651: --- Whoops, turns out the REST resources aren't online

[jira] [Resolved] (KAFKA-12651) Connect should register REST extensions before REST resources

[ https://issues.apache.org/jira/browse/KAFKA-12651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-12651. --- Resolution: Not A Problem > Connect should register REST extensions before REST resources >

[jira] [Created] (KAFKA-12651) Connect should register REST extensions before REST resources

Chris Egerton created KAFKA-12651: - Summary: Connect should register REST extensions before REST resources Key: KAFKA-12651 URL: https://issues.apache.org/jira/browse/KAFKA-12651 Project: Kafka

[jira] [Commented] (KAFKA-12463) Update default consumer partition assignor for sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17314151#comment-17314151 ] Chris Egerton commented on KAFKA-12463: --- Looks like this may be accomplished by

[jira] [Commented] (KAFKA-12463) Update default consumer partition assignor for sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17308235#comment-17308235 ] Chris Egerton commented on KAFKA-12463: --- Thanks [~kkonstantine]--I'll admit I was hoping to avoid

[jira] [Updated] (KAFKA-12463) Update default consumer partition assignor for sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-12463: -- Labels: needs-kip (was: ) > Update default consumer partition assignor for sink tasks >

[jira] [Updated] (KAFKA-12463) Update default consumer partition assignor for sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-12463: -- Description: Kafka consumers have a pluggable [partition assignment

[jira] [Updated] (KAFKA-12463) Update default consumer partition assignor for sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-12463: -- Description: Kafka consumers have a pluggable [partition assignment

[jira] [Commented] (KAFKA-12463) Update default consumer partition assignor for sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17304519#comment-17304519 ] Chris Egerton commented on KAFKA-12463: --- Thanks Randall-- {quote}I agree with you that we should

[jira] [Created] (KAFKA-12497) Source task offset commits continue even after task has failed

Chris Egerton created KAFKA-12497: - Summary: Source task offset commits continue even after task has failed Key: KAFKA-12497 URL: https://issues.apache.org/jira/browse/KAFKA-12497 Project: Kafka

[jira] [Resolved] (KAFKA-3813) Let SourceConnector implementations access the offset reader

[ https://issues.apache.org/jira/browse/KAFKA-3813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-3813. -- Resolution: Done > Let SourceConnector implementations access the offset reader >

[jira] [Comment Edited] (KAFKA-12463) Update default consumer partition assignor for sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302981#comment-17302981 ] Chris Egerton edited comment on KAFKA-12463 at 3/17/21, 1:34 AM: - Fun

[jira] [Comment Edited] (KAFKA-12463) Update default consumer partition assignor for sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302981#comment-17302981 ] Chris Egerton edited comment on KAFKA-12463 at 3/17/21, 1:32 AM: - Fun

[jira] [Updated] (KAFKA-12463) Update default consumer partition assignor for sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-12463: -- Description: Kafka consumers have a pluggable [partition assignment

[jira] [Comment Edited] (KAFKA-12463) Update default consumer partition assignor for sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302981#comment-17302981 ] Chris Egerton edited comment on KAFKA-12463 at 3/17/21, 12:03 AM: -- Fun

[jira] [Commented] (KAFKA-12463) Update default consumer partition assignor for sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302981#comment-17302981 ] Chris Egerton commented on KAFKA-12463: --- Fun fact--Connect does not like cooperative consumers.

[jira] [Updated] (KAFKA-12463) Update default consumer partition assignor for sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-12463: -- Description: Kafka consumers have a pluggable [partition assignment

[jira] [Updated] (KAFKA-12463) Update default consumer partition assignor for sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-12463: -- Description: Kafka consumers have a pluggable [partition assignment

[jira] [Commented] (KAFKA-12473) Make the CooperativeStickyAssignor the default assignor

[ https://issues.apache.org/jira/browse/KAFKA-12473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302970#comment-17302970 ] Chris Egerton commented on KAFKA-12473: --- This doesn't necessarily block the change proposed here,

[jira] [Created] (KAFKA-12487) Sink connectors do not work with the cooperative consumer rebalance protocol

Chris Egerton created KAFKA-12487: - Summary: Sink connectors do not work with the cooperative consumer rebalance protocol Key: KAFKA-12487 URL: https://issues.apache.org/jira/browse/KAFKA-12487

[jira] [Comment Edited] (KAFKA-12463) Update default consumer partition assignor for sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302205#comment-17302205 ] Chris Egerton edited comment on KAFKA-12463 at 3/16/21, 4:29 AM: - Haha,

[jira] [Commented] (KAFKA-12463) Update default consumer partition assignor for sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302205#comment-17302205 ] Chris Egerton commented on KAFKA-12463: --- Haha, I should have been clearer–we do use our own type

[jira] [Updated] (KAFKA-12474) Worker can die if unable to write new session key

[ https://issues.apache.org/jira/browse/KAFKA-12474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-12474: -- Issue Type: Bug (was: Improvement) > Worker can die if unable to write new session key >

[jira] [Created] (KAFKA-12476) Worker can block for longer than scheduled rebalance delay and/or session key TTL

Chris Egerton created KAFKA-12476: - Summary: Worker can block for longer than scheduled rebalance delay and/or session key TTL Key: KAFKA-12476 URL: https://issues.apache.org/jira/browse/KAFKA-12476

[jira] [Updated] (KAFKA-12474) Worker can die if unable to write new session key

[ https://issues.apache.org/jira/browse/KAFKA-12474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-12474: -- Affects Version/s: 3.0.0 > Worker can die if unable to write new session key >

[jira] [Created] (KAFKA-12474) Worker can die if unable to write new session key

Chris Egerton created KAFKA-12474: - Summary: Worker can die if unable to write new session key Key: KAFKA-12474 URL: https://issues.apache.org/jira/browse/KAFKA-12474 Project: Kafka Issue

[jira] [Commented] (KAFKA-12463) Update default consumer partition assignor for sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17301706#comment-17301706 ] Chris Egerton commented on KAFKA-12463: --- cc [~rhauch] what do you think about this? > Update

[jira] [Comment Edited] (KAFKA-12463) Update default consumer partition assignor for sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17301327#comment-17301327 ] Chris Egerton edited comment on KAFKA-12463 at 3/15/21, 3:26 PM: - Ah,

[jira] [Comment Edited] (KAFKA-12463) Update default consumer partition assignor for sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17301327#comment-17301327 ] Chris Egerton edited comment on KAFKA-12463 at 3/15/21, 2:00 AM: - Ah,

[jira] [Commented] (KAFKA-12463) Update default consumer partition assignor for sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17301327#comment-17301327 ] Chris Egerton commented on KAFKA-12463: --- Ah, thanks [~ableegoldman], I'd misread the javadocs for

[jira] [Updated] (KAFKA-12463) Update default consumer partition assignor for sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-12463: -- Description: Kafka consumers have a pluggable [partition assignment

[jira] [Commented] (KAFKA-12463) Update default consumer partition assignor for sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17301235#comment-17301235 ] Chris Egerton commented on KAFKA-12463: --- [~bchen225242] can you confirm the upgrade semantics

[jira] [Created] (KAFKA-12463) Update default consumer partition assignor for sink tasks

Chris Egerton created KAFKA-12463: - Summary: Update default consumer partition assignor for sink tasks Key: KAFKA-12463 URL: https://issues.apache.org/jira/browse/KAFKA-12463 Project: Kafka

[jira] [Commented] (KAFKA-10192) Flaky test BlockingConnectorTest#testBlockInConnectorStop

[ https://issues.apache.org/jira/browse/KAFKA-10192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17298108#comment-17298108 ] Chris Egerton commented on KAFKA-10192: --- [~mjsax] FYI, there's a PR up for this from [~showuon] if

[jira] [Commented] (KAFKA-12391) Add an option to store arbitrary metadata to a SourceRecord

[ https://issues.apache.org/jira/browse/KAFKA-12391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17295445#comment-17295445 ] Chris Egerton commented on KAFKA-12391: --- SMTs shouldn't interfere with option 2; both times

[jira] [Comment Edited] (KAFKA-12391) Add an option to store arbitrary metadata to a SourceRecord

[ https://issues.apache.org/jira/browse/KAFKA-12391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17295401#comment-17295401 ] Chris Egerton edited comment on KAFKA-12391 at 3/4/21, 4:50 PM: [~lb] I

[jira] [Commented] (KAFKA-12391) Add an option to store arbitrary metadata to a SourceRecord

[ https://issues.apache.org/jira/browse/KAFKA-12391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17295401#comment-17295401 ] Chris Egerton commented on KAFKA-12391: --- [~lb] I believe this is already possible by a few

<    3   4   5   6   7   8   9   10   11   >