[jira] [Commented] (KAFKA-10457) JsonConverter.toConnectData trims BigInteger to Long for schema-less case

2021-11-03 Thread Arjun Satish (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438256#comment-17438256 ] Arjun Satish commented on KAFKA-10457: -- looks like we would need a new [data

[jira] [Updated] (KAFKA-10387) Cannot include SMT configs with source connector that include topic.creation.* properties

2020-08-11 Thread Arjun Satish (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish updated KAFKA-10387: - Description: Let's say we try to create a connector with the following config: {code:java} {

[jira] [Updated] (KAFKA-10387) Cannot include SMT configs with source connector that include topic.creation.* properties

2020-08-11 Thread Arjun Satish (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish updated KAFKA-10387: - Description: Let's say we try to create a connector with the following config: {code:java} {

[jira] [Updated] (KAFKA-10387) Cannot include SMT configs with source connector that include topic.creation.* properties

2020-08-11 Thread Arjun Satish (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish updated KAFKA-10387: - Description: Let's say we try to create a connector with the following config: {{{

[jira] [Updated] (KAFKA-10387) Cannot include SMT configs with source connector that include topic.creation.* properties

2020-08-11 Thread Arjun Satish (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish updated KAFKA-10387: - Description: Let's say we try to create a connector with the following config: {{ {

[jira] [Created] (KAFKA-10387) Cannot include SMT configs with source connector that include topic.creation.* properties

2020-08-11 Thread Arjun Satish (Jira)
Arjun Satish created KAFKA-10387: Summary: Cannot include SMT configs with source connector that include topic.creation.* properties Key: KAFKA-10387 URL: https://issues.apache.org/jira/browse/KAFKA-10387

[jira] [Updated] (KAFKA-10340) Source connectors should report error when trying to producer records to non-existent topics instead of hanging forever

2020-08-03 Thread Arjun Satish (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish updated KAFKA-10340: - Description: Currently, a source connector will blindly attempt to write a record to a Kafka

[jira] [Updated] (KAFKA-10340) Source connectors should report error when trying to producer records to non-existent topics instead of hanging forever

2020-08-03 Thread Arjun Satish (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish updated KAFKA-10340: - Description: Currently, a source connector will blindly attempt to write a record to a Kafka

[jira] [Created] (KAFKA-10340) Source connectors should report error when trying to producer records to non-existent topics instead of hanging forever

2020-08-03 Thread Arjun Satish (Jira)
Arjun Satish created KAFKA-10340: Summary: Source connectors should report error when trying to producer records to non-existent topics instead of hanging forever Key: KAFKA-10340 URL:

[jira] [Commented] (KAFKA-10021) When reading to the end of the config log, check if fetch.max.wait.ms is greater than worker.sync.timeout.ms

2020-05-19 Thread Arjun Satish (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111584#comment-17111584 ] Arjun Satish commented on KAFKA-10021: -- Thanks, [~hachikuji]! > When reading to the end of the

[jira] [Commented] (KAFKA-10021) When reading to the end of the config log, check if fetch.max.wait.ms is greater than worker.sync.timeout.ms

2020-05-19 Thread Arjun Satish (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111493#comment-17111493 ] Arjun Satish commented on KAFKA-10021: -- [~hachikuji] [~skaundinya] do consumers in a JVM share a

[jira] [Updated] (KAFKA-8774) Connect REST API exposes plaintext secrets in tasks endpoint if config value contains additional characters

2019-08-12 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish updated KAFKA-8774: Summary: Connect REST API exposes plaintext secrets in tasks endpoint if config value contains

[jira] [Updated] (KAFKA-8774) Connect REST API exposes plaintext secrets in tasks endpoint

2019-08-12 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish updated KAFKA-8774: Description: I have configured a Connector to use externalized secrets, and the following

[jira] [Commented] (KAFKA-8597) Give access to the Dead Letter Queue APIs to Kafka Connect Developers

2019-07-01 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16876309#comment-16876309 ] Arjun Satish commented on KAFKA-8597: - Thanks for the feature request, [~conker84].  I think there

[jira] [Comment Edited] (KAFKA-8597) Give access to the Dead Letter Queue APIs to Kafka Connect Developers

2019-07-01 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16876309#comment-16876309 ] Arjun Satish edited comment on KAFKA-8597 at 7/1/19 4:10 PM: - Thanks for the

[jira] [Resolved] (KAFKA-7877) Connect DLQ not used in SinkTask put()

2019-04-28 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish resolved KAFKA-7877. - Resolution: Fixed Updated KIP. > Connect DLQ not used in SinkTask put() >

[jira] [Comment Edited] (KAFKA-7877) Connect DLQ not used in SinkTask put()

2019-04-28 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16828808#comment-16828808 ] Arjun Satish edited comment on KAFKA-7877 at 4/28/19 6:23 PM: -- Resolving

[jira] [Assigned] (KAFKA-7877) Connect DLQ not used in SinkTask put()

2019-04-28 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish reassigned KAFKA-7877: --- Assignee: Arjun Satish > Connect DLQ not used in SinkTask put() >

[jira] [Resolved] (KAFKA-7999) Flaky Test ExampleConnectIntegrationTest#testProduceConsumeConnector

2019-02-26 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish resolved KAFKA-7999. - Resolution: Fixed PR: https://github.com/apache/kafka/pull/6326 > Flaky Test

[jira] [Commented] (KAFKA-7999) Flaky Test ExampleConnectIntegrationTest#testProduceConsumeConnector

2019-02-26 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16778230#comment-16778230 ] Arjun Satish commented on KAFKA-7999: - https://github.com/apache/kafka/pull/6326 was merged to

[jira] [Assigned] (KAFKA-7999) Flaky Test ExampleConnectIntegrationTest#testProduceConsumeConnector

2019-02-26 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish reassigned KAFKA-7999: --- Assignee: Arjun Satish > Flaky Test

[jira] [Updated] (KAFKA-7909) Ensure timely rebalance completion after pending members rejoin or fail

2019-02-19 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish updated KAFKA-7909: Summary: Ensure timely rebalance completion after pending members rejoin or fail (was:

[jira] [Assigned] (KAFKA-7909) Coordinator changes cause Connect integration test to fail

2019-02-08 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish reassigned KAFKA-7909: --- Assignee: Arjun Satish > Coordinator changes cause Connect integration test to fail >

[jira] [Commented] (KAFKA-7909) Coordinator changes cause Connect integration test to fail

2019-02-08 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16763812#comment-16763812 ] Arjun Satish commented on KAFKA-7909: - [~ijuma] I believe [this

[jira] [Updated] (KAFKA-7909) Coordinator changes cause Connect integration test to fail

2019-02-08 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish updated KAFKA-7909: Component/s: core > Coordinator changes cause Connect integration test to fail >

[jira] [Updated] (KAFKA-7909) Coordinator changes cause Connect integration test to fail

2019-02-08 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish updated KAFKA-7909: Description: We recently introduced integration tests in Connect. This test spins up one or more

[jira] [Updated] (KAFKA-7909) Coordinator changes cause Connect integration test to fail

2019-02-08 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish updated KAFKA-7909: Component/s: consumer > Coordinator changes cause Connect integration test to fail >

[jira] [Updated] (KAFKA-7909) Coordinator changes cause Connect integration test to fail

2019-02-08 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish updated KAFKA-7909: Description: We recently introduced integration tests in Connect. This test spins up one or more

[jira] [Created] (KAFKA-7909) Coordinator changes cause Connect integration test to fail

2019-02-08 Thread Arjun Satish (JIRA)
Arjun Satish created KAFKA-7909: --- Summary: Coordinator changes cause Connect integration test to fail Key: KAFKA-7909 URL: https://issues.apache.org/jira/browse/KAFKA-7909 Project: Kafka Issue

[jira] [Commented] (KAFKA-7877) Connect DLQ not used in SinkTask put()

2019-01-30 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756507#comment-16756507 ] Arjun Satish commented on KAFKA-7877: - This is not a bug. We decided to not implement DLQ to capture

[jira] [Created] (KAFKA-7772) Dynamically adjust log level in Connect workers

2018-12-27 Thread Arjun Satish (JIRA)
Arjun Satish created KAFKA-7772: --- Summary: Dynamically adjust log level in Connect workers Key: KAFKA-7772 URL: https://issues.apache.org/jira/browse/KAFKA-7772 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-7503) Integration Test Framework for Connect

2018-10-13 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish updated KAFKA-7503: Summary: Integration Test Framework for Connect (was: Integration Tests for Connect) >

[jira] [Updated] (KAFKA-7503) Integration Tests for Connect

2018-10-13 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish updated KAFKA-7503: Description: Implement a framework which enables writing and executing integration tests against

[jira] [Created] (KAFKA-7503) Integration Tests for Connect

2018-10-13 Thread Arjun Satish (JIRA)
Arjun Satish created KAFKA-7503: --- Summary: Integration Tests for Connect Key: KAFKA-7503 URL: https://issues.apache.org/jira/browse/KAFKA-7503 Project: Kafka Issue Type: Task

[jira] [Commented] (KAFKA-7228) DeadLetterQueue throws a NullPointerException

2018-08-18 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16584897#comment-16584897 ] Arjun Satish commented on KAFKA-7228: - Installation of hotfix jar: # Navigate to the lib/ directory

[jira] [Updated] (KAFKA-7228) DeadLetterQueue throws a NullPointerException

2018-08-18 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish updated KAFKA-7228: Attachment: connect-runtime-2.0.0-HOTFIX-7228.jar > DeadLetterQueue throws a NullPointerException

[jira] [Updated] (KAFKA-7228) DeadLetterQueue throws a NullPointerException

2018-08-01 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish updated KAFKA-7228: Fix Version/s: 2.1.0 2.0.1 > DeadLetterQueue throws a NullPointerException >

[jira] [Updated] (KAFKA-7228) DeadLetterQueue throws a NullPointerException

2018-08-01 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish updated KAFKA-7228: Description: Using the dead letter queue results in a NPE:  {code:java} [2018-08-01 07:41:08,907]

[jira] [Created] (KAFKA-7228) DeadLetterQueue throws a NullPointerException

2018-08-01 Thread Arjun Satish (JIRA)
Arjun Satish created KAFKA-7228: --- Summary: DeadLetterQueue throws a NullPointerException Key: KAFKA-7228 URL: https://issues.apache.org/jira/browse/KAFKA-7228 Project: Kafka Issue Type: Task

[jira] [Assigned] (KAFKA-7228) DeadLetterQueue throws a NullPointerException

2018-08-01 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish reassigned KAFKA-7228: --- Assignee: Arjun Satish > DeadLetterQueue throws a NullPointerException >

[jira] [Created] (KAFKA-7003) Add headers with error context in messages written to the Connect DeadLetterQueue topic

2018-06-05 Thread Arjun Satish (JIRA)
Arjun Satish created KAFKA-7003: --- Summary: Add headers with error context in messages written to the Connect DeadLetterQueue topic Key: KAFKA-7003 URL: https://issues.apache.org/jira/browse/KAFKA-7003

[jira] [Created] (KAFKA-7002) Allow replication factor to be set via a configuration property for the Connect DLQ topic

2018-06-05 Thread Arjun Satish (JIRA)
Arjun Satish created KAFKA-7002: --- Summary: Allow replication factor to be set via a configuration property for the Connect DLQ topic Key: KAFKA-7002 URL: https://issues.apache.org/jira/browse/KAFKA-7002

[jira] [Updated] (KAFKA-7001) Rename errors.allowed.max property in Connect to errors.tolerance

2018-06-05 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish updated KAFKA-7001: Summary: Rename errors.allowed.max property in Connect to errors.tolerance (was: Rename

[jira] [Updated] (KAFKA-7001) Rename `errors.allowed.max` in Connect to `errors.tolerance`

2018-06-05 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish updated KAFKA-7001: Description: Since errors.allowed.max indicates a continuous value of  possibilities > Rename

[jira] [Created] (KAFKA-7001) Rename `errors.allowed.max` in Connect to `errors.tolerance`

2018-06-05 Thread Arjun Satish (JIRA)
Arjun Satish created KAFKA-7001: --- Summary: Rename `errors.allowed.max` in Connect to `errors.tolerance` Key: KAFKA-7001 URL: https://issues.apache.org/jira/browse/KAFKA-7001 Project: Kafka

[jira] [Updated] (KAFKA-6981) Missing Connector Config (errors.deadletterqueue.topic.name) kills Connect Clusters

2018-06-01 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish updated KAFKA-6981: Description: The trunk version of AK currently tries to incorrectly read the property 

[jira] [Updated] (KAFKA-6981) Missing Connector Config (errors.deadletterqueue.topic.name) kills Connect Clusters

2018-06-01 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish updated KAFKA-6981: Priority: Major (was: Minor) > Missing Connector Config (errors.deadletterqueue.topic.name) kills

[jira] [Created] (KAFKA-6981) Missing Connector Config (errors.deadletterqueue.topic.name) kills Connect Clusters

2018-06-01 Thread Arjun Satish (JIRA)
Arjun Satish created KAFKA-6981: --- Summary: Missing Connector Config (errors.deadletterqueue.topic.name) kills Connect Clusters Key: KAFKA-6981 URL: https://issues.apache.org/jira/browse/KAFKA-6981

[jira] [Updated] (KAFKA-6833) KafkaProducer throws "Invalid partition given with record" exception

2018-04-27 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish updated KAFKA-6833: Description: Currently, when creating topics via ZooKeeper, there is a small but definite delay

[jira] [Updated] (KAFKA-6833) KafkaProducer throws "Invalid partition given with record" exception

2018-04-27 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish updated KAFKA-6833: Description: Currently, when creating topics via ZooKeeper, there is a small but definite delay

[jira] [Updated] (KAFKA-6833) KafkaProducer throws "Invalid partition given with record" exception

2018-04-27 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish updated KAFKA-6833: Description: Currently, when creating topics via ZooKeeper, there is a small but definite delay

[jira] [Created] (KAFKA-6833) KafkaProducer throws "Invalid partition given with record" exception

2018-04-27 Thread Arjun Satish (JIRA)
Arjun Satish created KAFKA-6833: --- Summary: KafkaProducer throws "Invalid partition given with record" exception Key: KAFKA-6833 URL: https://issues.apache.org/jira/browse/KAFKA-6833 Project: Kafka

[jira] [Created] (KAFKA-6511) Connect header parser incorrectly parses arrays

2018-01-31 Thread Arjun Satish (JIRA)
Arjun Satish created KAFKA-6511: --- Summary: Connect header parser incorrectly parses arrays Key: KAFKA-6511 URL: https://issues.apache.org/jira/browse/KAFKA-6511 Project: Kafka Issue Type: Bug

[jira] [Closed] (KAFKA-4827) Kafka connect: error with special characters in connector name

2017-11-29 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish closed KAFKA-4827. --- Changes have been merged and backported to 0.10.0, 0.10.1, 0.10.2 and 0.11.0 branches. > Kafka connect:

[jira] [Commented] (KAFKA-6193) ReassignPartitionsClusterTest.shouldPerformMultipleReassignmentOperationsOverVariousTopics fails sometimes

2017-11-16 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16255688#comment-16255688 ] Arjun Satish commented on KAFKA-6193: - This test is failing for a PR I created. The Jenkins build is

[jira] [Assigned] (KAFKA-4115) Grow default heap settings for distributed Connect from 256M to 1G

2017-11-13 Thread Arjun Satish (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arjun Satish reassigned KAFKA-4115: --- Assignee: Arjun Satish (was: Shikhar Bhushan) > Grow default heap settings for distributed