You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by adrien ruffie <ad...@hotmail.fr> on 2018/02/17 19:04:04 UTC
Kafka connect mysql
Hello all,
In Kafka the definitive guide, on page 146 I found the following command:
curl http://localhost:8083/connector-plugins [{"class":"org.apache.kafka.connect.file.FileStreamSourceConnector"},{"class":"io.confluent.connect.elasticsearch.ElasticsearchSinkConnector"},{"class":"org.apache.kafka.connect.file.FileStreamSinkConnector"},{"class":"io.confluent.connect.jdbc.JdbcSourceConnector"}]
But when I try it, and its return me the following line: curl: (3) [globbing] bad range specification in column 2
~/Java/kafka_2.11-1.0.0$ curl http://localhost:8083/connector-plugins [{"class":"org.apache.kafka.connect.file.FileStreamSourceConnector"},{"class":"io.confluent.connect.elasticsearch.ElasticsearchSinkConnector"},{"class":"org.apache.kafka.connect.file.FileStreamSinkConnector"},{"class":"io.confluent.connect.jdbc.JdbcSourceConnector"}]
[{"class":"io.confluent.connect.elasticsearch.ElasticsearchSinkConnector","type":"sink","version":"4.1.0-SNAPSHOT"},{"class":"io.confluent.connect.jdbc.JdbcSinkConnector","type":"sink","version":"4.1.0-SNAPSHOT"},{"class":"io.confluent.connect.jdbc.JdbcSourceConnector","type":"source","version":"4.1.0-SNAPSHOT"},{"class":"org.apache.kafka.connect.file.FileStreamSinkConnector","type":"sink","version":"1.0.0"},{"class":"org.apache.kafka.connect.file.FileStreamSourceConnector","type":"source","version":"1.0.0"}]curl: (3) [globbing] bad range specification in column 2
And it seems that my jdbc connector is not deployed ... do you have an idea ?
Best regars,
Adrien
RE: Kafka connect mysql
Posted by adrien ruffie <ad...@hotmail.fr>.
Thanl Ted,
but I have found the solution 😊
It works well by adding -d '' and -H json type for arguments
curl -H "Content-Type: application/json" -d '[{"class":"org.apache.kafka.connect.file.FileStreamSourceConnector"},{"class":"io.confluent.connect.elasticsearch.ElasticsearchSinkConnector"},{"class":"org.apache.kafka.connect.file.FileStreamSinkConnector"},{"class":"io.confluent.connect.jdbc.JdbcSourceConnector"}]' http://localhost:8083/connector-plugins
great thank !
Adrien
________________________________
De : Ted Yu <yu...@gmail.com>
Envoyé : samedi 17 février 2018 23:57:04
À : users@kafka.apache.org
Objet : Re: Kafka connect mysql
In your first email, there are two pairs of brackets following
connector-plugins <http://localhost:8083/connector-plugins>
They were output of the curl command, right ?
On page 146, commands for Mac were given.
What commands did you use to install mysql, etc on Debian ?
Thanks
On Sat, Feb 17, 2018 at 2:51 PM, adrien ruffie <ad...@hotmail.fr>
wrote:
> yes the fact that my jdbcSourceConnector wasn't installd 😊
>
>
> By checking with the REST api connect list and status, no connector was
> deployed
>
> ________________________________
> De : Ted Yu <yu...@gmail.com>
> Envoyé : samedi 17 février 2018 23:46:18
> À : users@kafka.apache.org
> Objet : Re: Kafka connect mysql
>
> From your first email: {"class":"io.confluent.connect.jdbc.
> JdbcSourceConnector","type":"source","version":"4.1.0-SNAPSHOT"}
>
> It seems the JdbcSourceConnector was installed.
>
> Did you encounter any other error apart from the globbing complaint ?
>
> Cheers
>
> On Sat, Feb 17, 2018 at 1:59 PM, adrien ruffie <ad...@hotmail.fr>
> wrote:
>
> > yes like suggested :-) but nothing,
> >
> > Debian 9 for the OS
> >
> >
> > thx Ted
> >
> > ________________________________
> > De : Ted Yu <yu...@gmail.com>
> > Envoyé : samedi 17 février 2018 22:10:19
> > À : users@kafka.apache.org
> > Objet : Re: Kafka connect mysql
> >
> > Have you tried adding -g/--globoff ?
> >
> > What is the OS you use ?
> >
> > Cheers
> >
> > On Sat, Feb 17, 2018 at 11:04 AM, adrien ruffie <
> adriennolarsen@hotmail.fr
> > >
> > wrote:
> >
> > > Hello all,
> > >
> > >
> > > In Kafka the definitive guide, on page 146 I found the following
> command:
> > >
> > >
> > > curl http://localhost:8083/connector-plugins
> > [{"class":"org.apache.kafka.
> > > connect.file.FileStreamSourceConnector"},{"
> class":"io.confluent.connect.
> > > elasticsearch.ElasticsearchSinkConnector"},{"class":"org.apache.kafka.
> > > connect.file.FileStreamSinkConnector"},{"class":"io.confluent.connect.
> > > jdbc.JdbcSourceConnector"}]
> > >
> > > But when I try it, and its return me the following line: curl: (3)
> > > [globbing] bad range specification in column 2
> > >
> > >
> > > ~/Java/kafka_2.11-1.0.0$ curl http://localhost:8083/connector-plugins
> > > [{"class":"org.apache.kafka.connect.file.
> FileStreamSourceConnector"},{"
> > > class":"io.confluent.connect.elasticsearch.
> > ElasticsearchSinkConnector"},{
> > > "class":"org.apache.kafka.connect.file.FileStreamSinkConnector"},{"
> > > class":"io.confluent.connect.jdbc.JdbcSourceConnector"}]
> > > [{"class":"io.confluent.connect.elasticsearch.
> > > ElasticsearchSinkConnector","type":"sink","version":"4.1.0-
> > > SNAPSHOT"},{"class":"io.confluent.connect.jdbc.
> > JdbcSinkConnector","type":"
> > > sink","version":"4.1.0-SNAPSHOT"},{"class":"io.confluent.connect.jdbc.
> > > JdbcSourceConnector","type":"source","version":"4.1.0-
> > > SNAPSHOT"},{"class":"org.apache.kafka.connect.file.
> > > FileStreamSinkConnector","type":"sink","version":"1.0.0"
> > > },{"class":"org.apache.kafka.connect.file.FileStreamSourceConnector","
> > > type":"source","version":"1.0.0"}]curl: (3) [globbing] bad range
> > > specification in column 2
> > >
> > >
> > > And it seems that my jdbc connector is not deployed ... do you have an
> > > idea ?
> > >
> > > Best regars,
> > > Adrien
> > >
> > >
> >
>
Re: Kafka connect mysql
Posted by Ted Yu <yu...@gmail.com>.
In your first email, there are two pairs of brackets following
connector-plugins <http://localhost:8083/connector-plugins>
They were output of the curl command, right ?
On page 146, commands for Mac were given.
What commands did you use to install mysql, etc on Debian ?
Thanks
On Sat, Feb 17, 2018 at 2:51 PM, adrien ruffie <ad...@hotmail.fr>
wrote:
> yes the fact that my jdbcSourceConnector wasn't installd 😊
>
>
> By checking with the REST api connect list and status, no connector was
> deployed
>
> ________________________________
> De : Ted Yu <yu...@gmail.com>
> Envoyé : samedi 17 février 2018 23:46:18
> À : users@kafka.apache.org
> Objet : Re: Kafka connect mysql
>
> From your first email: {"class":"io.confluent.connect.jdbc.
> JdbcSourceConnector","type":"source","version":"4.1.0-SNAPSHOT"}
>
> It seems the JdbcSourceConnector was installed.
>
> Did you encounter any other error apart from the globbing complaint ?
>
> Cheers
>
> On Sat, Feb 17, 2018 at 1:59 PM, adrien ruffie <ad...@hotmail.fr>
> wrote:
>
> > yes like suggested :-) but nothing,
> >
> > Debian 9 for the OS
> >
> >
> > thx Ted
> >
> > ________________________________
> > De : Ted Yu <yu...@gmail.com>
> > Envoyé : samedi 17 février 2018 22:10:19
> > À : users@kafka.apache.org
> > Objet : Re: Kafka connect mysql
> >
> > Have you tried adding -g/--globoff ?
> >
> > What is the OS you use ?
> >
> > Cheers
> >
> > On Sat, Feb 17, 2018 at 11:04 AM, adrien ruffie <
> adriennolarsen@hotmail.fr
> > >
> > wrote:
> >
> > > Hello all,
> > >
> > >
> > > In Kafka the definitive guide, on page 146 I found the following
> command:
> > >
> > >
> > > curl http://localhost:8083/connector-plugins
> > [{"class":"org.apache.kafka.
> > > connect.file.FileStreamSourceConnector"},{"
> class":"io.confluent.connect.
> > > elasticsearch.ElasticsearchSinkConnector"},{"class":"org.apache.kafka.
> > > connect.file.FileStreamSinkConnector"},{"class":"io.confluent.connect.
> > > jdbc.JdbcSourceConnector"}]
> > >
> > > But when I try it, and its return me the following line: curl: (3)
> > > [globbing] bad range specification in column 2
> > >
> > >
> > > ~/Java/kafka_2.11-1.0.0$ curl http://localhost:8083/connector-plugins
> > > [{"class":"org.apache.kafka.connect.file.
> FileStreamSourceConnector"},{"
> > > class":"io.confluent.connect.elasticsearch.
> > ElasticsearchSinkConnector"},{
> > > "class":"org.apache.kafka.connect.file.FileStreamSinkConnector"},{"
> > > class":"io.confluent.connect.jdbc.JdbcSourceConnector"}]
> > > [{"class":"io.confluent.connect.elasticsearch.
> > > ElasticsearchSinkConnector","type":"sink","version":"4.1.0-
> > > SNAPSHOT"},{"class":"io.confluent.connect.jdbc.
> > JdbcSinkConnector","type":"
> > > sink","version":"4.1.0-SNAPSHOT"},{"class":"io.confluent.connect.jdbc.
> > > JdbcSourceConnector","type":"source","version":"4.1.0-
> > > SNAPSHOT"},{"class":"org.apache.kafka.connect.file.
> > > FileStreamSinkConnector","type":"sink","version":"1.0.0"
> > > },{"class":"org.apache.kafka.connect.file.FileStreamSourceConnector","
> > > type":"source","version":"1.0.0"}]curl: (3) [globbing] bad range
> > > specification in column 2
> > >
> > >
> > > And it seems that my jdbc connector is not deployed ... do you have an
> > > idea ?
> > >
> > > Best regars,
> > > Adrien
> > >
> > >
> >
>
RE: Kafka connect mysql
Posted by adrien ruffie <ad...@hotmail.fr>.
yes the fact that my jdbcSourceConnector wasn't installd 😊
By checking with the REST api connect list and status, no connector was deployed
________________________________
De : Ted Yu <yu...@gmail.com>
Envoyé : samedi 17 février 2018 23:46:18
À : users@kafka.apache.org
Objet : Re: Kafka connect mysql
From your first email: {"class":"io.confluent.connect.jdbc.
JdbcSourceConnector","type":"source","version":"4.1.0-SNAPSHOT"}
It seems the JdbcSourceConnector was installed.
Did you encounter any other error apart from the globbing complaint ?
Cheers
On Sat, Feb 17, 2018 at 1:59 PM, adrien ruffie <ad...@hotmail.fr>
wrote:
> yes like suggested :-) but nothing,
>
> Debian 9 for the OS
>
>
> thx Ted
>
> ________________________________
> De : Ted Yu <yu...@gmail.com>
> Envoyé : samedi 17 février 2018 22:10:19
> À : users@kafka.apache.org
> Objet : Re: Kafka connect mysql
>
> Have you tried adding -g/--globoff ?
>
> What is the OS you use ?
>
> Cheers
>
> On Sat, Feb 17, 2018 at 11:04 AM, adrien ruffie <adriennolarsen@hotmail.fr
> >
> wrote:
>
> > Hello all,
> >
> >
> > In Kafka the definitive guide, on page 146 I found the following command:
> >
> >
> > curl http://localhost:8083/connector-plugins
> [{"class":"org.apache.kafka.
> > connect.file.FileStreamSourceConnector"},{"class":"io.confluent.connect.
> > elasticsearch.ElasticsearchSinkConnector"},{"class":"org.apache.kafka.
> > connect.file.FileStreamSinkConnector"},{"class":"io.confluent.connect.
> > jdbc.JdbcSourceConnector"}]
> >
> > But when I try it, and its return me the following line: curl: (3)
> > [globbing] bad range specification in column 2
> >
> >
> > ~/Java/kafka_2.11-1.0.0$ curl http://localhost:8083/connector-plugins
> > [{"class":"org.apache.kafka.connect.file.FileStreamSourceConnector"},{"
> > class":"io.confluent.connect.elasticsearch.
> ElasticsearchSinkConnector"},{
> > "class":"org.apache.kafka.connect.file.FileStreamSinkConnector"},{"
> > class":"io.confluent.connect.jdbc.JdbcSourceConnector"}]
> > [{"class":"io.confluent.connect.elasticsearch.
> > ElasticsearchSinkConnector","type":"sink","version":"4.1.0-
> > SNAPSHOT"},{"class":"io.confluent.connect.jdbc.
> JdbcSinkConnector","type":"
> > sink","version":"4.1.0-SNAPSHOT"},{"class":"io.confluent.connect.jdbc.
> > JdbcSourceConnector","type":"source","version":"4.1.0-
> > SNAPSHOT"},{"class":"org.apache.kafka.connect.file.
> > FileStreamSinkConnector","type":"sink","version":"1.0.0"
> > },{"class":"org.apache.kafka.connect.file.FileStreamSourceConnector","
> > type":"source","version":"1.0.0"}]curl: (3) [globbing] bad range
> > specification in column 2
> >
> >
> > And it seems that my jdbc connector is not deployed ... do you have an
> > idea ?
> >
> > Best regars,
> > Adrien
> >
> >
>
Re: Kafka connect mysql
Posted by Ted Yu <yu...@gmail.com>.
From your first email: {"class":"io.confluent.connect.jdbc.
JdbcSourceConnector","type":"source","version":"4.1.0-SNAPSHOT"}
It seems the JdbcSourceConnector was installed.
Did you encounter any other error apart from the globbing complaint ?
Cheers
On Sat, Feb 17, 2018 at 1:59 PM, adrien ruffie <ad...@hotmail.fr>
wrote:
> yes like suggested :-) but nothing,
>
> Debian 9 for the OS
>
>
> thx Ted
>
> ________________________________
> De : Ted Yu <yu...@gmail.com>
> Envoyé : samedi 17 février 2018 22:10:19
> À : users@kafka.apache.org
> Objet : Re: Kafka connect mysql
>
> Have you tried adding -g/--globoff ?
>
> What is the OS you use ?
>
> Cheers
>
> On Sat, Feb 17, 2018 at 11:04 AM, adrien ruffie <adriennolarsen@hotmail.fr
> >
> wrote:
>
> > Hello all,
> >
> >
> > In Kafka the definitive guide, on page 146 I found the following command:
> >
> >
> > curl http://localhost:8083/connector-plugins
> [{"class":"org.apache.kafka.
> > connect.file.FileStreamSourceConnector"},{"class":"io.confluent.connect.
> > elasticsearch.ElasticsearchSinkConnector"},{"class":"org.apache.kafka.
> > connect.file.FileStreamSinkConnector"},{"class":"io.confluent.connect.
> > jdbc.JdbcSourceConnector"}]
> >
> > But when I try it, and its return me the following line: curl: (3)
> > [globbing] bad range specification in column 2
> >
> >
> > ~/Java/kafka_2.11-1.0.0$ curl http://localhost:8083/connector-plugins
> > [{"class":"org.apache.kafka.connect.file.FileStreamSourceConnector"},{"
> > class":"io.confluent.connect.elasticsearch.
> ElasticsearchSinkConnector"},{
> > "class":"org.apache.kafka.connect.file.FileStreamSinkConnector"},{"
> > class":"io.confluent.connect.jdbc.JdbcSourceConnector"}]
> > [{"class":"io.confluent.connect.elasticsearch.
> > ElasticsearchSinkConnector","type":"sink","version":"4.1.0-
> > SNAPSHOT"},{"class":"io.confluent.connect.jdbc.
> JdbcSinkConnector","type":"
> > sink","version":"4.1.0-SNAPSHOT"},{"class":"io.confluent.connect.jdbc.
> > JdbcSourceConnector","type":"source","version":"4.1.0-
> > SNAPSHOT"},{"class":"org.apache.kafka.connect.file.
> > FileStreamSinkConnector","type":"sink","version":"1.0.0"
> > },{"class":"org.apache.kafka.connect.file.FileStreamSourceConnector","
> > type":"source","version":"1.0.0"}]curl: (3) [globbing] bad range
> > specification in column 2
> >
> >
> > And it seems that my jdbc connector is not deployed ... do you have an
> > idea ?
> >
> > Best regars,
> > Adrien
> >
> >
>
RE: Kafka connect mysql
Posted by adrien ruffie <ad...@hotmail.fr>.
yes like suggested :-) but nothing,
Debian 9 for the OS
thx Ted
________________________________
De : Ted Yu <yu...@gmail.com>
Envoyé : samedi 17 février 2018 22:10:19
À : users@kafka.apache.org
Objet : Re: Kafka connect mysql
Have you tried adding -g/--globoff ?
What is the OS you use ?
Cheers
On Sat, Feb 17, 2018 at 11:04 AM, adrien ruffie <ad...@hotmail.fr>
wrote:
> Hello all,
>
>
> In Kafka the definitive guide, on page 146 I found the following command:
>
>
> curl http://localhost:8083/connector-plugins [{"class":"org.apache.kafka.
> connect.file.FileStreamSourceConnector"},{"class":"io.confluent.connect.
> elasticsearch.ElasticsearchSinkConnector"},{"class":"org.apache.kafka.
> connect.file.FileStreamSinkConnector"},{"class":"io.confluent.connect.
> jdbc.JdbcSourceConnector"}]
>
> But when I try it, and its return me the following line: curl: (3)
> [globbing] bad range specification in column 2
>
>
> ~/Java/kafka_2.11-1.0.0$ curl http://localhost:8083/connector-plugins
> [{"class":"org.apache.kafka.connect.file.FileStreamSourceConnector"},{"
> class":"io.confluent.connect.elasticsearch.ElasticsearchSinkConnector"},{
> "class":"org.apache.kafka.connect.file.FileStreamSinkConnector"},{"
> class":"io.confluent.connect.jdbc.JdbcSourceConnector"}]
> [{"class":"io.confluent.connect.elasticsearch.
> ElasticsearchSinkConnector","type":"sink","version":"4.1.0-
> SNAPSHOT"},{"class":"io.confluent.connect.jdbc.JdbcSinkConnector","type":"
> sink","version":"4.1.0-SNAPSHOT"},{"class":"io.confluent.connect.jdbc.
> JdbcSourceConnector","type":"source","version":"4.1.0-
> SNAPSHOT"},{"class":"org.apache.kafka.connect.file.
> FileStreamSinkConnector","type":"sink","version":"1.0.0"
> },{"class":"org.apache.kafka.connect.file.FileStreamSourceConnector","
> type":"source","version":"1.0.0"}]curl: (3) [globbing] bad range
> specification in column 2
>
>
> And it seems that my jdbc connector is not deployed ... do you have an
> idea ?
>
> Best regars,
> Adrien
>
>
Re: Kafka connect mysql
Posted by Ted Yu <yu...@gmail.com>.
Have you tried adding -g/--globoff ?
What is the OS you use ?
Cheers
On Sat, Feb 17, 2018 at 11:04 AM, adrien ruffie <ad...@hotmail.fr>
wrote:
> Hello all,
>
>
> In Kafka the definitive guide, on page 146 I found the following command:
>
>
> curl http://localhost:8083/connector-plugins [{"class":"org.apache.kafka.
> connect.file.FileStreamSourceConnector"},{"class":"io.confluent.connect.
> elasticsearch.ElasticsearchSinkConnector"},{"class":"org.apache.kafka.
> connect.file.FileStreamSinkConnector"},{"class":"io.confluent.connect.
> jdbc.JdbcSourceConnector"}]
>
> But when I try it, and its return me the following line: curl: (3)
> [globbing] bad range specification in column 2
>
>
> ~/Java/kafka_2.11-1.0.0$ curl http://localhost:8083/connector-plugins
> [{"class":"org.apache.kafka.connect.file.FileStreamSourceConnector"},{"
> class":"io.confluent.connect.elasticsearch.ElasticsearchSinkConnector"},{
> "class":"org.apache.kafka.connect.file.FileStreamSinkConnector"},{"
> class":"io.confluent.connect.jdbc.JdbcSourceConnector"}]
> [{"class":"io.confluent.connect.elasticsearch.
> ElasticsearchSinkConnector","type":"sink","version":"4.1.0-
> SNAPSHOT"},{"class":"io.confluent.connect.jdbc.JdbcSinkConnector","type":"
> sink","version":"4.1.0-SNAPSHOT"},{"class":"io.confluent.connect.jdbc.
> JdbcSourceConnector","type":"source","version":"4.1.0-
> SNAPSHOT"},{"class":"org.apache.kafka.connect.file.
> FileStreamSinkConnector","type":"sink","version":"1.0.0"
> },{"class":"org.apache.kafka.connect.file.FileStreamSourceConnector","
> type":"source","version":"1.0.0"}]curl: (3) [globbing] bad range
> specification in column 2
>
>
> And it seems that my jdbc connector is not deployed ... do you have an
> idea ?
>
> Best regars,
> Adrien
>
>