[jira] [Commented] (KAFKA-14740) Missing source tag on MirrorSource metrics

[ https://issues.apache.org/jira/browse/KAFKA-14740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692252#comment-17692252 ] Ryanne Dolan commented on KAFKA-14740: -- [~mimaison] the topic name usually includes the source

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500205#comment-17500205 ] Ryanne Dolan commented on KAFKA-7500: - mm2 will not skip records. > MirrorMaker 2.0 (KIP-382) >

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499835#comment-17499835 ] Ryanne Dolan commented on KAFKA-7500: - [~gsavinov] mm2 cannot guarantee that the downstream topics

[jira] [Commented] (KAFKA-13255) Mirrormaker config property config.properties.exclude is not working as expected

[ https://issues.apache.org/jira/browse/KAFKA-13255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407742#comment-17407742 ] Ryanne Dolan commented on KAFKA-13255: -- hey [~anadkarni], you'll need to create a pull request on

[jira] [Assigned] (KAFKA-13038) document IdentityReplicationPolicy

[ https://issues.apache.org/jira/browse/KAFKA-13038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan reassigned KAFKA-13038: Assignee: Ryanne Dolan > document IdentityReplicationPolicy >

[jira] [Updated] (KAFKA-13038) document IdentityReplicationPolicy

[ https://issues.apache.org/jira/browse/KAFKA-13038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan updated KAFKA-13038: - Issue Type: Task (was: Bug) > document IdentityReplicationPolicy >

[jira] [Created] (KAFKA-13038) document IdentityReplicationPolicy

Ryanne Dolan created KAFKA-13038: Summary: document IdentityReplicationPolicy Key: KAFKA-13038 URL: https://issues.apache.org/jira/browse/KAFKA-13038 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-9726) LegacyReplicationPolicy for MM2 to mimic MM1

[ https://issues.apache.org/jira/browse/KAFKA-9726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan updated KAFKA-9726: Fix Version/s: 3.0.0 > LegacyReplicationPolicy for MM2 to mimic MM1 >

[jira] [Updated] (KAFKA-9726) LegacyReplicationPolicy for MM2 to mimic MM1

[ https://issues.apache.org/jira/browse/KAFKA-9726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan updated KAFKA-9726: Priority: Major (was: Minor) > LegacyReplicationPolicy for MM2 to mimic MM1 >

[jira] [Commented] (KAFKA-9726) IdentityReplicationPolicy for MM2 to mimic MM1

[ https://issues.apache.org/jira/browse/KAFKA-9726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17357014#comment-17357014 ] Ryanne Dolan commented on KAFKA-9726: - PR ready for merge. > IdentityReplicationPolicy for MM2 to

[jira] [Updated] (KAFKA-9726) IdentityReplicationPolicy for MM2 to mimic MM1

[ https://issues.apache.org/jira/browse/KAFKA-9726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan updated KAFKA-9726: Summary: IdentityReplicationPolicy for MM2 to mimic MM1 (was: LegacyReplicationPolicy for MM2 to

[jira] [Assigned] (KAFKA-9726) LegacyReplicationPolicy for MM2 to mimic MM1

[ https://issues.apache.org/jira/browse/KAFKA-9726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan reassigned KAFKA-9726: --- Assignee: Ryanne Dolan (was: Matthew de Detrich) > LegacyReplicationPolicy for MM2 to

[jira] [Resolved] (KAFKA-7815) SourceTask should expose ACK'd offsets, metadata

[ https://issues.apache.org/jira/browse/KAFKA-7815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan resolved KAFKA-7815. - Fix Version/s: 2.4.0 Resolution: Fixed Equivalent functionality was included as part of

[jira] [Commented] (KAFKA-12436) deprecate MirrorMaker v1

[ https://issues.apache.org/jira/browse/KAFKA-12436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17355841#comment-17355841 ] Ryanne Dolan commented on KAFKA-12436: -- [~ijuma] can I get a review please? > deprecate

[jira] [Updated] (KAFKA-12436) deprecate MirrorMaker v1

[ https://issues.apache.org/jira/browse/KAFKA-12436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan updated KAFKA-12436: - Reviewer: Ismael Juma (was: Konstantine Karantasis) > deprecate MirrorMaker v1 >

[jira] [Commented] (KAFKA-12430) emit.heartbeats.enabled = false should disable heartbeats topic creation

[ https://issues.apache.org/jira/browse/KAFKA-12430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351104#comment-17351104 ] Ryanne Dolan commented on KAFKA-12430: -- Hmm. I guess the downside to not creating the topics is

[jira] [Commented] (KAFKA-12838) Kafka Broker - Request threads inefficiently blocking during produce

[ https://issues.apache.org/jira/browse/KAFKA-12838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350606#comment-17350606 ] Ryanne Dolan commented on KAFKA-12838: -- Would it help to significantly increase the number of

[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=17338575#comment-17338575 ] Ryanne Dolan commented on KAFKA-12726: -- Relevant tests here: 

[jira] [Resolved] (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:all-tabpanel ] Ryanne Dolan resolved KAFKA-12726. -- Resolution: Fixed Closing as duplicate. > misbehaving Task.stop() can prevent other Tasks

[jira] [Updated] (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:all-tabpanel ] Ryanne Dolan updated KAFKA-12726: - Description: We've observed a misbehaving Task fail to stop in a timely manner (e.g. stuck 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=17337603#comment-17337603 ] Ryanne Dolan commented on KAFKA-12726: -- Thanks for the detailed analysis [~ChrisEgerton]. I added

[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=17336550#comment-17336550 ] Ryanne Dolan commented on KAFKA-12726: -- [~ChrisEgerton] Yeah, the problem is that we were seeing,

[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=17335592#comment-17335592 ] Ryanne Dolan commented on KAFKA-12726: -- [~ChrisEgerton] ah, indeed I have conflated

[jira] [Assigned] (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:all-tabpanel ] Ryanne Dolan reassigned KAFKA-12726: Assignee: Ryanne Dolan > misbehaving Task.stop() can prevent other Tasks from stopping >

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

Ryanne Dolan created KAFKA-12726: Summary: misbehaving Task.stop() can prevent other Tasks from stopping Key: KAFKA-12726 URL: https://issues.apache.org/jira/browse/KAFKA-12726 Project: Kafka

[jira] [Assigned] (KAFKA-12558) MM2 may not sync partition offsets correctly

[ https://issues.apache.org/jira/browse/KAFKA-12558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan reassigned KAFKA-12558: Assignee: Ryanne Dolan > MM2 may not sync partition offsets correctly >

[jira] [Created] (KAFKA-12645) KIP-731: Record Rate Limiting for Kafka Connect

Ryanne Dolan created KAFKA-12645: Summary: KIP-731: Record Rate Limiting for Kafka Connect Key: KAFKA-12645 URL: https://issues.apache.org/jira/browse/KAFKA-12645 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-12563) Something wrong with MM2 metrics

[ https://issues.apache.org/jira/browse/KAFKA-12563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309447#comment-17309447 ] Ryanne Dolan commented on KAFKA-12563: -- You can look at the lag of the internal consumers to get an

[jira] [Commented] (KAFKA-12563) Something wrong with MM2 metrics

[ https://issues.apache.org/jira/browse/KAFKA-12563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309191#comment-17309191 ] Ryanne Dolan commented on KAFKA-12563: -- The metric is calculated based on the timestamp of each

[jira] [Commented] (KAFKA-12558) MM2 may not sync partition offsets correctly

[ https://issues.apache.org/jira/browse/KAFKA-12558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17308968#comment-17308968 ] Ryanne Dolan commented on KAFKA-12558: -- This sounds right. Updating the partition store without

[jira] [Updated] (KAFKA-12436) deprecate MirrorMaker v1

[ https://issues.apache.org/jira/browse/KAFKA-12436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan updated KAFKA-12436: - Description: Per KIP-382, the old MirrorMaker code (MM1) should be deprecated and subsequently

[jira] [Commented] (KAFKA-12436) deprecate MirrorMaker v1

[ https://issues.apache.org/jira/browse/KAFKA-12436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17296773#comment-17296773 ] Ryanne Dolan commented on KAFKA-12436: -- Thanks I'll update the ticket. > deprecate MirrorMaker v1

[jira] [Created] (KAFKA-12436) deprecate MirrorMaker v1

Ryanne Dolan created KAFKA-12436: Summary: deprecate MirrorMaker v1 Key: KAFKA-12436 URL: https://issues.apache.org/jira/browse/KAFKA-12436 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-10370) WorkerSinkTask: IllegalStateException cased by consumer.seek(tp, offsets) when (tp, offsets) are supplied by WorkerSinkTaskContext

[ https://issues.apache.org/jira/browse/KAFKA-10370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17179220#comment-17179220 ] Ryanne Dolan commented on KAFKA-10370: -- Thanks [~yangguo1220]. I believe that using assign()

[jira] [Commented] (KAFKA-9726) LegacyReplicationPolicy for MM2 to mimic MM1

[ https://issues.apache.org/jira/browse/KAFKA-9726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17179133#comment-17179133 ] Ryanne Dolan commented on KAFKA-9726: - [~ivanyu] that'd be great! > LegacyReplicationPolicy for MM2

[jira] [Commented] (KAFKA-10339) MirrorMaker2 Exactly-once Semantics

[ https://issues.apache.org/jira/browse/KAFKA-10339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17171642#comment-17171642 ] Ryanne Dolan commented on KAFKA-10339: -- I believe your proposed task.loadOffsets() is taken care of

[jira] [Commented] (KAFKA-10339) MirrorMaker2 Exactly-once Semantics

[ https://issues.apache.org/jira/browse/KAFKA-10339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17171519#comment-17171519 ] Ryanne Dolan commented on KAFKA-10339: -- I think what you mean is that a read-process-write loop

[jira] [Commented] (KAFKA-10339) MirrorMaker2 Exactly-once Semantics

[ https://issues.apache.org/jira/browse/KAFKA-10339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170425#comment-17170425 ] Ryanne Dolan commented on KAFKA-10339: -- Yeah, I guess it would be possible to switch from

[jira] [Commented] (KAFKA-10339) MirrorMaker2 Exactly-once Semantics

[ https://issues.apache.org/jira/browse/KAFKA-10339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170377#comment-17170377 ] Ryanne Dolan commented on KAFKA-10339: -- [~yangguo1220] this is awesome, thanks! My team has looked

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17140849#comment-17140849 ] Ryanne Dolan commented on KAFKA-7500: - [~har5havardhan] I think that is unlikely, given all the

[jira] [Commented] (KAFKA-10159) MirrorSourceConnector don`t work on connect-distributed.sh

[ https://issues.apache.org/jira/browse/KAFKA-10159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17135817#comment-17135817 ] Ryanne Dolan commented on KAFKA-10159: -- I think you are missing target.cluster.bootstrap.servers.

[jira] [Commented] (KAFKA-10160) Kafka MM2 consumer configuration

[ https://issues.apache.org/jira/browse/KAFKA-10160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17135815#comment-17135815 ] Ryanne Dolan commented on KAFKA-10160: -- Agree this is a bug. This property is hard-coded but

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17114309#comment-17114309 ] Ryanne Dolan commented on KAFKA-7500: - [~qq619618919] I usually recommend using a load balancers and

[jira] [Commented] (KAFKA-9981) Running a dedicated mm2 cluster with more than one nodes,When the configuration is updated the task is not aware and will lose the update operation.

[ https://issues.apache.org/jira/browse/KAFKA-9981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108701#comment-17108701 ] Ryanne Dolan commented on KAFKA-9981: - Configuration updates only come from the REST API, afaik,

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17082634#comment-17082634 ] Ryanne Dolan commented on KAFKA-7500: - [~Lothar] you have a small misunderstanding: after failover

[jira] [Commented] (KAFKA-9746) MM2 produces messages in the wrong cluster

[ https://issues.apache.org/jira/browse/KAFKA-9746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071927#comment-17071927 ] Ryanne Dolan commented on KAFKA-9746: - This is because MM2 hands off records to Connect to produce to

[jira] [Created] (KAFKA-9726) LegacyReplicationPolicy for MM2 to mimic MM1

Ryanne Dolan created KAFKA-9726: --- Summary: LegacyReplicationPolicy for MM2 to mimic MM1 Key: KAFKA-9726 URL: https://issues.apache.org/jira/browse/KAFKA-9726 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-9376) Plugin class loader not found using MM2

[ https://issues.apache.org/jira/browse/KAFKA-9376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17039327#comment-17039327 ] Ryanne Dolan commented on KAFKA-9376: - Is it possible you all have the MM2 Connectors in your Connect

[jira] [Commented] (KAFKA-9013) Flaky Test MirrorConnectorsIntegrationTest#testReplication

[ https://issues.apache.org/jira/browse/KAFKA-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17034850#comment-17034850 ] Ryanne Dolan commented on KAFKA-9013: - I'm seeing loglines like `Found 11 topic-partitions on

[jira] [Commented] (KAFKA-9013) Flaky Test MirrorConnectorsIntegrationTest#testReplication

[ https://issues.apache.org/jira/browse/KAFKA-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17026700#comment-17026700 ] Ryanne Dolan commented on KAFKA-9013: - Sounds reasonable. I'll take a look as well. > Flaky Test

[jira] [Closed] (KAFKA-9351) Higher count in destination cluster using Kafka MM2

[ https://issues.apache.org/jira/browse/KAFKA-9351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan closed KAFKA-9351. --- > Higher count in destination cluster using Kafka MM2 >

[jira] [Resolved] (KAFKA-9351) Higher count in destination cluster using Kafka MM2

[ https://issues.apache.org/jira/browse/KAFKA-9351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan resolved KAFKA-9351. - Resolution: Information Provided > Higher count in destination cluster using Kafka MM2 >

[jira] [Commented] (KAFKA-9351) Higher count in destination cluster using Kafka MM2

[ https://issues.apache.org/jira/browse/KAFKA-9351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17010033#comment-17010033 ] Ryanne Dolan commented on KAFKA-9351: - [~nitishgoyal13] retries in the producer wouldn't normally

[jira] [Updated] (KAFKA-9376) Plugin class loader not found using MM2

[ https://issues.apache.org/jira/browse/KAFKA-9376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan updated KAFKA-9376: Priority: Minor (was: Major) > Plugin class loader not found using MM2 >

[jira] [Commented] (KAFKA-9376) Plugin class loader not found using MM2

[ https://issues.apache.org/jira/browse/KAFKA-9376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17009904#comment-17009904 ] Ryanne Dolan commented on KAFKA-9376: - Thanks for the report. I'm unable to reproduce this so far,

[jira] [Commented] (KAFKA-9345) Deploy Mirror Maker 2.0 and dynamically modify the topic whitelist through REST API

[ https://issues.apache.org/jira/browse/KAFKA-9345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17009040#comment-17009040 ] Ryanne Dolan commented on KAFKA-9345: - [~xinzhuxianshenger] no inconvenience. I'll close this ticket,

[jira] [Resolved] (KAFKA-9345) Deploy Mirror Maker 2.0 and dynamically modify the topic whitelist through REST API

[ https://issues.apache.org/jira/browse/KAFKA-9345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan resolved KAFKA-9345. - Resolution: Information Provided > Deploy Mirror Maker 2.0 and dynamically modify the topic

[jira] [Closed] (KAFKA-9345) Deploy Mirror Maker 2.0 and dynamically modify the topic whitelist through REST API

[ https://issues.apache.org/jira/browse/KAFKA-9345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan closed KAFKA-9345. --- > Deploy Mirror Maker 2.0 and dynamically modify the topic whitelist through > REST API >

[jira] [Updated] (KAFKA-9351) Higher count in destination cluster using Kafka MM2

[ https://issues.apache.org/jira/browse/KAFKA-9351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan updated KAFKA-9351: Priority: Minor (was: Blocker) > Higher count in destination cluster using Kafka MM2 >

[jira] [Commented] (KAFKA-9351) Higher count in destination cluster using Kafka MM2

[ https://issues.apache.org/jira/browse/KAFKA-9351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17009035#comment-17009035 ] Ryanne Dolan commented on KAFKA-9351: - [~nitishgoyal13] are those event counts or offsets? MM2 cannot

[jira] [Commented] (KAFKA-9345) Deploy Mirror Maker 2.0 and dynamically modify the topic whitelist through REST API

[ https://issues.apache.org/jira/browse/KAFKA-9345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17005402#comment-17005402 ] Ryanne Dolan commented on KAFKA-9345: - [~xinzhuxianshenger] can you ask these questions on the user

[jira] [Resolved] (KAFKA-9221) Kafka REST Proxy wrongly converts quotes in message when sending json

[ https://issues.apache.org/jira/browse/KAFKA-9221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan resolved KAFKA-9221. - Resolution: Invalid not relevant to this project > Kafka REST Proxy wrongly converts quotes in

[jira] [Commented] (KAFKA-9175) MirrorMaker 2 emits invalid topic partition metrics

[ https://issues.apache.org/jira/browse/KAFKA-9175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16973597#comment-16973597 ] Ryanne Dolan commented on KAFKA-9175: - Thanks [~ecomar], [~mimaison], lgtm. > MirrorMaker 2 emits

[jira] [Commented] (KAFKA-9121) Mirror Maker 2.0 doesn't handle the topic names in consumer checkpoints properly when topic name contain separator

[ https://issues.apache.org/jira/browse/KAFKA-9121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963519#comment-16963519 ] Ryanne Dolan commented on KAFKA-9121: - Hmm, I think we'll always run into such issues if the

[jira] [Commented] (KAFKA-9076) MirrorMaker 2.0 automated consumer offset sync

[ https://issues.apache.org/jira/browse/KAFKA-9076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16957563#comment-16957563 ] Ryanne Dolan commented on KAFKA-9076: - [~yangguo1220] I took a look at the PR. Very cool! I see that

[jira] [Commented] (KAFKA-9076) MirrorMaker 2.0 automated consumer offset sync

[ https://issues.apache.org/jira/browse/KAFKA-9076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16957016#comment-16957016 ] Ryanne Dolan commented on KAFKA-9076: - [~yangguo1220] I agree this would be an improvement, but there

[jira] [Commented] (KAFKA-6080) Transactional EoS for source connectors

[ https://issues.apache.org/jira/browse/KAFKA-6080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16952954#comment-16952954 ] Ryanne Dolan commented on KAFKA-6080: - My goal is to eliminate duplicates downstream of a

[jira] [Assigned] (KAFKA-6080) Transactional EoS for source connectors

[ https://issues.apache.org/jira/browse/KAFKA-6080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan reassigned KAFKA-6080: --- Assignee: Ryanne Dolan > Transactional EoS for source connectors >

[jira] [Commented] (KAFKA-6080) Transactional EoS for source connectors

[ https://issues.apache.org/jira/browse/KAFKA-6080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16952205#comment-16952205 ] Ryanne Dolan commented on KAFKA-6080: - I'm thinking about this differently than you guys [~rhauch]

[jira] [Commented] (KAFKA-8929) MM2 system tests

[ https://issues.apache.org/jira/browse/KAFKA-8929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16943741#comment-16943741 ] Ryanne Dolan commented on KAFKA-8929: - I've got ducktape system tests implemented to match the

[jira] [Created] (KAFKA-8929) MM2 system tests

Ryanne Dolan created KAFKA-8929: --- Summary: MM2 system tests Key: KAFKA-8929 URL: https://issues.apache.org/jira/browse/KAFKA-8929 Project: Kafka Issue Type: Improvement Components:

[jira] [Created] (KAFKA-8930) MM2 documentation

Ryanne Dolan created KAFKA-8930: --- Summary: MM2 documentation Key: KAFKA-8930 URL: https://issues.apache.org/jira/browse/KAFKA-8930 Project: Kafka Issue Type: Improvement Components:

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932658#comment-16932658 ] Ryanne Dolan commented on KAFKA-7500: - [~qihong] the direct passthrough described there is what MM2

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931776#comment-16931776 ] Ryanne Dolan commented on KAFKA-7500: - [~qihong] That's all correct :) In fact, KIP-382 mentions a

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931597#comment-16931597 ] Ryanne Dolan commented on KAFKA-7500: - [~chridtian.hagel] we try to be smart about what config

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16929359#comment-16929359 ] Ryanne Dolan commented on KAFKA-7500: - [~chridtian.hagel] thanks for giving it a spin. The "failed to

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16927978#comment-16927978 ] Ryanne Dolan commented on KAFKA-7500: - [~qihong] thanks for the questions. > But couldn't find any

[jira] [Assigned] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan reassigned KAFKA-7500: --- Assignee: Manikumar > MirrorMaker 2.0 (KIP-382) > - > >

[jira] [Resolved] (KAFKA-8568) MirrorMaker 2.0 resource leak

[ https://issues.apache.org/jira/browse/KAFKA-8568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan resolved KAFKA-8568. - Resolution: Fixed > MirrorMaker 2.0 resource leak > - > >

[jira] [Commented] (KAFKA-8568) MirrorMaker 2.0 resource leak

[ https://issues.apache.org/jira/browse/KAFKA-8568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16922927#comment-16922927 ] Ryanne Dolan commented on KAFKA-8568: - This was fixed a while back. MM2 was re-using some top-level

[jira] [Updated] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan updated KAFKA-7500: Labels: pull-request-available ready-to-commit (was: ) > MirrorMaker 2.0 (KIP-382) >

[jira] [Updated] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan updated KAFKA-7500: Priority: Major (was: Minor) > MirrorMaker 2.0 (KIP-382) > - > >

[jira] [Updated] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan updated KAFKA-7500: Affects Version/s: 2.4.0 > MirrorMaker 2.0 (KIP-382) > - > >

[jira] [Comment Edited] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16886520#comment-16886520 ] Ryanne Dolan edited comment on KAFKA-7500 at 8/21/19 7:57 PM: -- [~apriceq] I

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16912637#comment-16912637 ] Ryanne Dolan commented on KAFKA-7500: - [~shoxdid] This is now fixed, thanks for reporting! >

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16886520#comment-16886520 ] Ryanne Dolan commented on KAFKA-7500: - [~apriceq] I would recommend pulling down the PR and building

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16886515#comment-16886515 ] Ryanne Dolan commented on KAFKA-7500: - [~sdeokulecluster] Kafka releases are time-based, every 4

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16886512#comment-16886512 ] Ryanne Dolan commented on KAFKA-7500: - @Munamala I discuss this a bit in the readme:

[jira] [Comment Edited] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16886512#comment-16886512 ] Ryanne Dolan edited comment on KAFKA-7500 at 7/16/19 10:19 PM: --- [~Munamala]

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16878308#comment-16878308 ] Ryanne Dolan commented on KAFKA-7500: - [~Munamala] Yes, the translateOffsets() works both ways. When

[jira] [Assigned] (KAFKA-8568) MirrorMaker 2.0 resource leak

[ https://issues.apache.org/jira/browse/KAFKA-8568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan reassigned KAFKA-8568: --- Assignee: Ryanne Dolan > MirrorMaker 2.0 resource leak > - > >

[jira] [Commented] (KAFKA-7077) KIP-318: Make Kafka Connect Source idempotent

[ https://issues.apache.org/jira/browse/KAFKA-7077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16875021#comment-16875021 ] Ryanne Dolan commented on KAFKA-7077: - [~vpernin] yes, this is a frequent ask for MM2. Would love to

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16869925#comment-16869925 ] Ryanne Dolan commented on KAFKA-7500: - [~abellemare] Thanks for trying it out. > 1) Are the offset

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16847632#comment-16847632 ] Ryanne Dolan commented on KAFKA-7500: - [~Munamala] thanks for trying it out! > The topics are

[jira] [Assigned] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan reassigned KAFKA-7500: --- Assignee: Colin P. McCabe (was: Ryanne Dolan) Reviewer: Colin P. McCabe

[jira] [Updated] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan updated KAFKA-7500: Fix Version/s: 2.3.0 > MirrorMaker 2.0 (KIP-382) > - > >

[jira] [Updated] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan updated KAFKA-7500: Description: Implement a drop-in replacement for MirrorMaker leveraging the Connect framework.

[jira] [Comment Edited] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16836058#comment-16836058 ] Ryanne Dolan edited comment on KAFKA-7500 at 5/9/19 2:41 PM: - [~cloudfrog],

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16836058#comment-16836058 ] Ryanne Dolan commented on KAFKA-7500: - [~cloudfrog], glad you are taking a look. I'm looking forward

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825346#comment-16825346 ] Ryanne Dolan commented on KAFKA-7500: - [~terence.yi] the most trivial scenario would be something

  1   2   >