[
https://issues.apache.org/jira/browse/KAFKA-10457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17438256#comment-17438256
]
Arjun Satish commented on KAFKA-10457:
--
looks like we would need a new [data
type|
[
https://issues.apache.org/jira/browse/KAFKA-10387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arjun Satish updated KAFKA-10387:
-
Summary: Cannot include SMT configs with source connector that uses
topic.creation.* properties
[
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}
{
[
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}
{
[
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:
{{{
"connector
[
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:
{{
{
"connecto
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
[
https://issues.apache.org/jira/browse/KAFKA-10340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arjun Satish updated KAFKA-10340:
-
Summary: Source connectors should report error when trying to produce
records to non-existent to
[
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
to
[
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
to
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: https://issues.apache.org/ji
[
https://issues.apache.org/jira/browse/KAFKA-10021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111584#comment-17111584
]
Arjun Satish commented on KAFKA-10021:
--
Thanks, [~hachikuji]!
> When reading to th
[
https://issues.apache.org/jira/browse/KAFKA-10021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111493#comment-17111493
]
Arjun Satish commented on KAFKA-10021:
--
[~hachikuji] [~skaundinya] do consumers in
[
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 addi
[
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
endpoint
[
https://issues.apache.org/jira/browse/KAFKA-8597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16876309#comment-16876309
]
Arjun Satish commented on KAFKA-8597:
-
Thanks for the feature request, [~conker84].
[
https://issues.apache.org/jira/browse/KAFKA-8597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16876309#comment-16876309
]
Arjun Satish edited comment on KAFKA-8597 at 7/1/19 4:10 PM:
-
[
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()
> --
[
https://issues.apache.org/jira/browse/KAFKA-7877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16828808#comment-16828808
]
Arjun Satish edited comment on KAFKA-7877 at 4/28/19 6:23 PM:
-
[
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()
> --
[
https://issues.apache.org/jira/browse/KAFKA-7877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16828805#comment-16828805
]
Arjun Satish commented on KAFKA-7877:
-
[~Andrew Bourgeois]: updated the KIP. Also, ad
[
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 ExampleConnectInteg
[
https://issues.apache.org/jira/browse/KAFKA-7999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16778230#comment-16778230
]
Arjun Satish commented on KAFKA-7999:
-
https://github.com/apache/kafka/pull/6326 was
[
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 ExampleConnectIntegrationTest#testProduceConsumeConnecto
[
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: Coordinator
[
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
> --
[
https://issues.apache.org/jira/browse/KAFKA-7909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16763812#comment-16763812
]
Arjun Satish commented on KAFKA-7909:
-
[~ijuma] I believe [this
commit|https://githu
[
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
> --
[
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 C
[
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
> --
[
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 C
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
[
https://issues.apache.org/jira/browse/KAFKA-7877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16756507#comment-16756507
]
Arjun Satish commented on KAFKA-7877:
-
This is not a bug. We decided to not implement
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: Impro
[
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)
> Integratio
[
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 re
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
Componen
[
https://issues.apache.org/jira/browse/KAFKA-7228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16584897#comment-16584897
]
Arjun Satish commented on KAFKA-7228:
-
Installation of hotfix jar:
# Navigate to the
[
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
>
[
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
> ---
[
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]
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
[
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
> ---
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
P
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
[
https://issues.apache.org/jira/browse/KAFKA-7001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arjun Satish updated KAFKA-7001:
Description: (was: Since errors.allowed.max indicates a continuous
value of possibilities)
> R
[
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 `errors.al
[
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 `erro
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
Iss
[
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 (errors.deadl
[
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
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
Proje
[
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 bet
[
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 bet
[
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 bet
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
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
[
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:
[
https://issues.apache.org/jira/browse/KAFKA-6193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16255688#comment-16255688
]
Arjun Satish commented on KAFKA-6193:
-
This test is failing for a PR I created. The Je
[
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 C
[
https://issues.apache.org/jira/browse/KAFKA-4827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arjun Satish reassigned KAFKA-4827:
---
Assignee: Arjun Satish (was: Sönke Liebau)
> Kafka connect: error with special characters in
61 matches
Mail list logo