[jira] (KAFKA-9975) KIP-611: Improved Handling of Abandoned Connectors and Tasks
[ https://issues.apache.org/jira/browse/KAFKA-9975 ] Sayed Mohammad Hossein Torabi deleted comment on KAFKA-9975: -- was (Author: blcksrx): I would like to work on this KIP > KIP-611: Improved Handling of Abandoned Connectors and Tasks > > > Key: KAFKA-9975 > URL: https://issues.apache.org/jira/browse/KAFKA-9975 > Project: Kafka > Issue Type: Task > Components: KafkaConnect >Reporter: Chris Egerton >Priority: Major > Labels: needs-kip > > (To be fleshed out once > [KIP-611|https://cwiki.apache.org/confluence/display/KAFKA/KIP-611%3A+Improved+Handling+of+Abandoned+Connectors+and+Tasks] > is finalized) -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (KAFKA-9975) KIP-611: Improved Handling of Abandoned Connectors and Tasks
[ https://issues.apache.org/jira/browse/KAFKA-9975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17681320#comment-17681320 ] Sayed Mohammad Hossein Torabi commented on KAFKA-9975: -- I would like to work on this KIP > KIP-611: Improved Handling of Abandoned Connectors and Tasks > > > Key: KAFKA-9975 > URL: https://issues.apache.org/jira/browse/KAFKA-9975 > Project: Kafka > Issue Type: Task > Components: KafkaConnect >Reporter: Chris Egerton >Priority: Major > Labels: needs-kip > > (To be fleshed out once > [KIP-611|https://cwiki.apache.org/confluence/display/KAFKA/KIP-611%3A+Improved+Handling+of+Abandoned+Connectors+and+Tasks] > is finalized) -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Comment Edited] (KAFKA-12617) Convert MetadataRequestTest to use ClusterTest
[ https://issues.apache.org/jira/browse/KAFKA-12617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17570519#comment-17570519 ] Sayed Mohammad Hossein Torabi edited comment on KAFKA-12617 at 7/24/22 5:33 PM: Convert `MetadataRequstTest` to use `ClusterTest` annotation needs to use `AutoStart.NO` was (Author: blcksrx): Convert `MetadataRequstTest` to use `ClusterTest` annotation needs to use `AutoStart.NO` > Convert MetadataRequestTest to use ClusterTest > -- > > Key: KAFKA-12617 > URL: https://issues.apache.org/jira/browse/KAFKA-12617 > Project: Kafka > Issue Type: Sub-task >Reporter: Jason Gustafson >Assignee: Jason Gustafson >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (KAFKA-12617) Convert MetadataRequestTest to use ClusterTest
[ https://issues.apache.org/jira/browse/KAFKA-12617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17570519#comment-17570519 ] Sayed Mohammad Hossein Torabi commented on KAFKA-12617: --- Convert `MetadataRequstTest` to use `ClusterTest` annotation needs to use `AutoStart.NO` > Convert MetadataRequestTest to use ClusterTest > -- > > Key: KAFKA-12617 > URL: https://issues.apache.org/jira/browse/KAFKA-12617 > Project: Kafka > Issue Type: Sub-task >Reporter: Jason Gustafson >Assignee: Jason Gustafson >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (KAFKA-12617) Convert MetadataRequestTest to use ClusterTest
[ https://issues.apache.org/jira/browse/KAFKA-12617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564941#comment-17564941 ] Sayed Mohammad Hossein Torabi commented on KAFKA-12617: --- I would like to work on it > Convert MetadataRequestTest to use ClusterTest > -- > > Key: KAFKA-12617 > URL: https://issues.apache.org/jira/browse/KAFKA-12617 > Project: Kafka > Issue Type: Sub-task >Reporter: Jason Gustafson >Assignee: Jason Gustafson >Priority: Major > -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Resolved] (KAFKA-10597) Still dealing issue with KAFKA-9066
[ https://issues.apache.org/jira/browse/KAFKA-10597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sayed Mohammad Hossein Torabi resolved KAFKA-10597. --- Resolution: Fixed > Still dealing issue with KAFKA-9066 > --- > > Key: KAFKA-10597 > URL: https://issues.apache.org/jira/browse/KAFKA-10597 > Project: Kafka > Issue Type: Bug > Components: KafkaConnect >Affects Versions: 2.6.0 >Reporter: Sayed Mohammad Hossein Torabi >Priority: Major > > I upgraded the Kafka cluster to 2.6.0. The version that seems to the is > #KAFKA-9066 not resolved yet. beside the *UNASGINED* connectors and tasks has > the same issue -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (KAFKA-10597) Still dealing issue with KAFKA-9066
Sayed Mohammad Hossein Torabi created KAFKA-10597: - Summary: Still dealing issue with KAFKA-9066 Key: KAFKA-10597 URL: https://issues.apache.org/jira/browse/KAFKA-10597 Project: Kafka Issue Type: Bug Components: KafkaConnect Affects Versions: 2.6.0 Reporter: Sayed Mohammad Hossein Torabi I upgraded the Kafka cluster to 2.6.0. The version that seems to the is #KAFKA-9066 not resolved yet. beside the *UNASGINED* connectors and tasks has the same issue -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (KAFKA-9680) Negative consumer lag
[ https://issues.apache.org/jira/browse/KAFKA-9680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057970#comment-17057970 ] Sayed Mohammad Hossein Torabi commented on KAFKA-9680: -- So, how can i fix this issue? > Negative consumer lag > - > > Key: KAFKA-9680 > URL: https://issues.apache.org/jira/browse/KAFKA-9680 > Project: Kafka > Issue Type: Bug > Components: consumer >Affects Versions: 2.3.1 >Reporter: Sayed Mohammad Hossein Torabi >Assignee: Evelyn Bayes >Priority: Major > > I'm using Kafka 2.3.1 and got negative consumer lag on it. Here is the result > of my consumergroup > {code:java} > // 1 18985 8576-10409 > connector-consumer-hdfs-sink-1-20e86f06-cf92-4b68-a67a-32e1876118f7 > /172.16.2.220 connector-consumer-hdfs-sink-1 > {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (KAFKA-9680) Negative consumer lag
Sayed Mohammad Hossein Torabi created KAFKA-9680: Summary: Negative consumer lag Key: KAFKA-9680 URL: https://issues.apache.org/jira/browse/KAFKA-9680 Project: Kafka Issue Type: Bug Components: consumer Affects Versions: 2.3.1 Reporter: Sayed Mohammad Hossein Torabi I'm using Kafka 2.3.1 and got negative consumer lag on it. Here is the result of my consumergroup {code:java} // 1 18985 8576-10409 connector-consumer-hdfs-sink-1-20e86f06-cf92-4b68-a67a-32e1876118f7 /172.16.2.220 connector-consumer-hdfs-sink-1 {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (KAFKA-9563) Fix Kafka connect consumer and producer override documentation
[ https://issues.apache.org/jira/browse/KAFKA-9563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sayed Mohammad Hossein Torabi updated KAFKA-9563: - Summary: Fix Kafka connect consumer and producer override documentation (was: Fix consumer and producer override documentation) > Fix Kafka connect consumer and producer override documentation > -- > > Key: KAFKA-9563 > URL: https://issues.apache.org/jira/browse/KAFKA-9563 > Project: Kafka > Issue Type: Bug > Components: docs, documentation, KafkaConnect >Affects Versions: 2.3.1 >Reporter: Sayed Mohammad Hossein Torabi >Priority: Minor > > The true parameters for overriding producer config or consumer config in > *Kafka-Connect* are > {code:java} > producer.override.[PRODUCER-CONFIG] {code} > or > {code:java} > consumer.override.[CONSUMER-CONFIG]{code} -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (KAFKA-9563) Fix consumer and producer override documentation
Sayed Mohammad Hossein Torabi created KAFKA-9563: Summary: Fix consumer and producer override documentation Key: KAFKA-9563 URL: https://issues.apache.org/jira/browse/KAFKA-9563 Project: Kafka Issue Type: Bug Components: docs, documentation, KafkaConnect Affects Versions: 2.3.1 Reporter: Sayed Mohammad Hossein Torabi The true parameters for overriding producer config or consumer config in *Kafka-Connect* are {code:java} producer.override.[PRODUCER-CONFIG] {code} or {code:java} consumer.override.[CONSUMER-CONFIG]{code} -- This message was sent by Atlassian Jira (v8.3.4#803005)