kafka connector distributed mode balance stratety

:8083/.", the two instance api is completely equivalent? Or i need I a cname for this two instances? Thanks, Lei wangl...@geekplus.com.cn

How to config multiple tables in kafka jdbc sink connector?

pk.mode=record_value pk.fields=id If I want to config many tables and every table has different primary key, how can i do that? Thanks, Lei wangl...@geekplus.com.cn

How actually jdbc sink connetor run

to implement it using java code instead of kafka connect configuration. Receive avro serialized kafka record and sent to JdbcSinkTask. Is there any document that will tells me some details or some example code? Thanks, Lei wangl...@geekplus.com.cn

Re: Re: Write to database directly by referencing schema registry, no jdbc sink connector

ricRecord value = record.value(); change the GenericRecord to sinkRecord task.put(Arrays.asList(sinkRecord)); } } Thanks， Lei wangl...@geekplus.com.cn From: Robin Moffatt Date: 2020-05-11 16:40 To: users Subject: Re: Write to database directly by referencing schema re

Re: Re: Write to database directly by referencing schema registry, no jdbc sink connector

omatically genterate the sql according the record schema and execute it, no matter what the table is. But i have no idea how to get it. Thanks, Lei wangl...@geekplus.com.cn From: Liam Clarke-Hutchinson Date: 2020-05-09 18:20 To: users Subject: Re: Re: Write to database directly by referenc

Re: Re: kafka-console-consumer.sh: Port already in use Exception after enable JMX

Hi rohit， Surely unset jmx report can solve my issue Exit and login again not work. But i can execute the consumer.sh on others hosts. Thanks, Lei wangl...@geekplus.com.cn From: rohit garg Date: 2020-05-11 13:24 To: users CC: wanglei2 Subject: Re: kafka-console-consumer.sh: Port

Re: Re: kafka-console-consumer.sh: Port already in use Exception after enable JMX

bin/kafka-console-consumer.sh --bootstrap-server 172.19.78.32:9092 --topic tapicName I am using kafka_2.11-2.4.1 wangl...@geekplus.com.cn From: manoj.agraw...@cognizant.com Date: 2020-05-11 12:39 To: wangl...@geekplus.com.cn; users@kafka.apache.org Subject: Re: kafka-console-consumer.sh

Re: Re: kafka-console-consumer.sh: Port already in use Exception after enable JMX

Hi Manoj， I have tried, not work. When i changed to 9998, the consumer.sh tells me Port already in use: 9998 Thanks, Lei wangl...@geekplus.com.cn From: manoj.agraw...@cognizant.com Date: 2020-05-11 12:04 To: users@kafka.apache.org Subject: Re: kafka-console-consumer.sh: Port already in

kafka-console-consumer.sh: Port already in use Exception after enable JMX

use (Bind failed) wangl...@geekplus.com.cn

Re: Re: Write to database directly by referencing schema registry, no jdbc sink connector

kafka jdbc sink connector (https://docs.confluent.io/current/connect/kafka-connect-jdbc/sink-connector/index.html) can achieve this function. But i have no idea how to write with java code. Is there any code example to achieve this? Thanks, Lei wangl...@geekplus.com.cn From: Liam Clarke

Is there any difference between conflunt kafka and apache kafka？

I want to know if there's any difference between apache kafka and the open sourced confluent kafka ? Thanks, Lei wangl...@geekplus.com.cn

Write to database directly by referencing schema registry, no jdbc sink connector

message to corresponding table record and write to corresponding table? Is there any example code to do this ? Thanks, Lei wangl...@geekplus.com.cn

Re: Re: Is it possible to send avro serialized data to kafka using kafka-console-producer.sh

, confluent kafka-avro-console-producer send to apache kafka, apache kafka-console-consumer.sh can read it. Thanks, Lei wangl...@geekplus.com.cn From: Miguel Silvestre Date: 2020-05-08 19:41 To: users Subject: Re: Is it possible to send avro serialized data to kafka using

Is it possible to send avro serialized data to kafka using kafka-console-producer.sh

serialized data to kafka using kafka-console-producer.sh? Thanks, Lei wangl...@geekplus.com.cn