[jira] [Resolved] (KAFKA-7217) Loading dynamic topic data into kafka connector sink using regex

[ https://issues.apache.org/jira/browse/KAFKA-7217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris resolved KAFKA-7217. Fix Version/s: 1.1.0 Resolution: Fixed > Loading dynamic topic data into kafka connec

Re: Problems with Kafka Connector Base classes

ngliche Nachricht- > Von: Chris Egerton > Gesendet: Donnerstag, 2. März 2023 17:33 > An: dev@kafka.apache.org > Betreff: Re: Problems with Kafka Connector Base classes > > [You don't often get email from chr...@aiven.io.invalid. Learn why this > is important at https://a

AW: Problems with Kafka Connector Base classes

G_FOR_TASK_CONFIG" - that would be awesome 😉 Thanks Michael -Ursprüngliche Nachricht- Von: Chris Egerton Gesendet: Donnerstag, 2. März 2023 17:33 An: dev@kafka.apache.org Betreff: Re: Problems with Kafka Connector Base classes [You don't often get email from chr...@aiven.io

Re: Problems with Kafka Connector Base classes

Hi Michael, The purpose of the Connector::taskConfigs method is to specify (implicitly) the number of tasks that need to be run for the connector, and (explicitly) how each task should be configured. The former is provided implicitly by the size of the list returned from that method; for each elem

Problems with Kafka Connector Base classes

Hi I'm using: org.apache.kafka:connect-api:3.4.0 I have a simple connector: == public class SimpleSinkConnector extends SinkConnector { @Override public List> taskConfigs(int maxTasks) { ArrayList> configs = new ArrayList<>(); for (int i = 0; i < maxTasks; i++) {

[jira] [Resolved] (KAFKA-12795) Create kafka connector use chinese character failed

[ https://issues.apache.org/jira/browse/KAFKA-12795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] pengWei Dou resolved KAFKA-12795. - Resolution: Won't Fix > Create kafka connector use chinese characte

[jira] [Created] (KAFKA-12795) Create kafka connector use chinese character failed

pengWei Dou created KAFKA-12795: --- Summary: Create kafka connector use chinese character failed Key: KAFKA-12795 URL: https://issues.apache.org/jira/browse/KAFKA-12795 Project: Kafka Issue Type

[jira] [Resolved] (KAFKA-12182) Kafka connector is failing due to ' OffsetStorageWriter is already flushing' error

[ https://issues.apache.org/jira/browse/KAFKA-12182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-12182. --- Resolution: Duplicate > Kafka connector is failing due to ' OffsetStorageWriter is

[jira] [Created] (KAFKA-12182) Kafka connector is failing due to ' OffsetStorageWriter is already flushing' error

Fátima Galera created KAFKA-12182: - Summary: Kafka connector is failing due to ' OffsetStorageWriter is already flushing' error Key: KAFKA-12182 URL: https://issues.apache.org/jira/browse/K

Kafka Connector

Hi, This is Monisha. I am a Netsuite Developer. I want to connect Netsuite and Apache Kafka. It would be great if you provide me information about how to connect Kafka and Netsuite. Looking forward to your reply. -- thank you. Monisha Kodi Phone: +49 15124770514

Dose kafka connector rest aoi support multiple thread access?

Dear teams, We use Kafka-1.1.0 connector to load data,And start a connector using rest api by application. Before we start a connector,we'll check it was not  existed and then create it. This was  encapsulated in a Quartz job.And each connector  had a job. We use spring resttemplate as below

Problem with Kafka Connector

Hello! I have question. We have cluster with several connect workers. And we have many different connectors. We need to set for each connector its own settings, max.in.flight.requests.per.connection , partitioner.class, acks. But I have difficulties. How can I do that? Thanks

How to setting https to the Kafka connector worker

Hi: I am using the Kafka connector version is 2.0.0 and below is setting the Kafka connector worker for https protocol. 1. Create the SSL key keytool -keystore kafka.server.keystore.jks -alias localhost -validity 365 -genkey openssl req -new -x509 -keyout ca-key -out ca-cert -days 365 keytool

[jira] [Created] (KAFKA-7217) Loading dynamic topic data into kafka connector sink using regex

Pratik Gaglani created KAFKA-7217: - Summary: Loading dynamic topic data into kafka connector sink using regex Key: KAFKA-7217 URL: https://issues.apache.org/jira/browse/KAFKA-7217 Project: Kafka

[jira] [Created] (KAFKA-5518) General Kafka connector performanc workload

Chen He created KAFKA-5518: -- Summary: General Kafka connector performanc workload Key: KAFKA-5518 URL: https://issues.apache.org/jira/browse/KAFKA-5518 Project: Kafka Issue Type: Bug

Re: kafka-connector sink task flush() interval

, victory_zgh wrote: > Hi, > Recently, I am working on kafka connector implement. According to the > connector sink task document, the connect platform invoke flush method > periodically, But the doc does not metition the flush interval. > I don't know the flush interval default v

kafka-connector sink task flush() interval

Hi, Recently, I am working on kafka connector implement. According to the connector sink task document, the connect platform invoke flush method periodically, But the doc does not metition the flush interval. I don't know the flush interval default value or Where we can set this int

Open source Mysql -> Kafka connector

I thought this would be of interest: https://developer.zendesk.com/blog/introducing-maxwell-a-mysql-to-kafka-binlog-processor A copycat connector that parses MySQL binlogs would be rather useful I think. Streaming connectors using jdbc are tricky to implement because they rely on an indexed timest