date:20180217

RE: Kafka connect mysql

2018-02-17 Thread adrien ruffie

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 
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 
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 
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 
> 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 
> wrote:
>
> > yes like suggested :-) but nothing,
> >
> > Debian 9 for the OS
> >
> >
> > thx Ted
> >
> > 
> > De : Ted Yu 
> > 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 <
> adriennolar...@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: Zookeeper Error

2018-02-17 Thread Maria Pilar

Yes, i have included the server.id into zookeeper.properties

and it´s working fine.

Thanks

On 18 February 2018 at 03:15, Ted Yu  wrote:

> What are the entries in /etc/hosts w.r.t. localhost ?
>
> I wonder if the exception had something to do with ipv6.
>
> On Sat, Feb 17, 2018 at 5:49 PM, Maria Pilar  wrote:
>
> > When i try to create a topic in that multicluster,
> >
> > kafka-topics.bat --create --topic my-kafka-topic --zookeeper
> locahost:2181
> > --replication-factor 2 --partitions 3
> >
> >
> > i have received the same error
> >
> > Exception in thread "main" org.I0Itec.zkclient.exception.ZkException:
> > Unable to connect to locahost:2181
> > at org.I0Itec.zkclient.ZkConnection.connect(
> ZkConnection.java:72)
> > at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:1228)
> > at org.I0Itec.zkclient.ZkClient.(ZkClient.java:157)
> > at org.I0Itec.zkclient.ZkClient.(ZkClient.java:131)
> > at
> > kafka.utils.ZkUtils$.createZkClientAndConnection(ZkUtils.scala:115)
> > at kafka.utils.ZkUtils$.apply(ZkUtils.scala:97)
> > at kafka.admin.TopicCommand$.main(TopicCommand.scala:56)
> > at kafka.admin.TopicCommand.main(TopicCommand.scala)
> > Caused by: java.net.UnknownHostException: locahost
> > at java.net.Inet6AddressImpl.lookupAllHostAddr(Native Method)
> > at java.net.InetAddress$2.lookupAllHostAddr(InetAddress.
> java:928)
> > at
> > java.net.InetAddress.getAddressesFromNameService(InetAddress.java:1323)
> > at java.net.InetAddress.getAllByName0(InetAddress.java:1276)
> > at java.net.InetAddress.getAllByName(InetAddress.java:1192)
> > at java.net.InetAddress.getAllByName(InetAddress.java:1126)
> > at
> > org.apache.zookeeper.client.StaticHostProvider.(
> > StaticHostProvider.java:61)
> > at org.apache.zookeeper.ZooKeeper.(ZooKeeper.java:445)
> > at org.apache.zookeeper.ZooKeeper.(ZooKeeper.java:380)
> > at org.I0Itec.zkclient.ZkConnection.connect(
> ZkConnection.java:70)
> > ... 7 more
> >
> > Thanks
> >
> > On 18 February 2018 at 02:45, Maria Pilar  wrote:
> >
> > > Hi
> > >
> > > I´m trying to configure a multinode cluster in kafka. I have configured
> > > each server.properties according with the new properties for each
> server.
> > >
> > > When i start each server, the zookeeper console shows that error.
> > >
> > >  INFO Got user-level KeeperException when processing
> > > sessionid:0x161a690f731 type:create cxid:0xd8 zxid:0x11f txntype:-1
> > > reqpath:n/a Error Path:/brokers/ids Error:KeeperErrorCode = NodeExists
> > for
> > > /brokers/ids (org.apache.zookeeper.server.PrepRequestProcessor)
> > >
> > > I have configured each broker.id
> > >
> > >
> > > Anybody knows what is the error?
> > >
> > > Thanks
> > >
> >
>

Re: Zookeeper Error

2018-02-17 Thread Ted Yu

What are the entries in /etc/hosts w.r.t. localhost ?

I wonder if the exception had something to do with ipv6.

On Sat, Feb 17, 2018 at 5:49 PM, Maria Pilar  wrote:

> When i try to create a topic in that multicluster,
>
> kafka-topics.bat --create --topic my-kafka-topic --zookeeper locahost:2181
> --replication-factor 2 --partitions 3
>
>
> i have received the same error
>
> Exception in thread "main" org.I0Itec.zkclient.exception.ZkException:
> Unable to connect to locahost:2181
> at org.I0Itec.zkclient.ZkConnection.connect(ZkConnection.java:72)
> at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:1228)
> at org.I0Itec.zkclient.ZkClient.(ZkClient.java:157)
> at org.I0Itec.zkclient.ZkClient.(ZkClient.java:131)
> at
> kafka.utils.ZkUtils$.createZkClientAndConnection(ZkUtils.scala:115)
> at kafka.utils.ZkUtils$.apply(ZkUtils.scala:97)
> at kafka.admin.TopicCommand$.main(TopicCommand.scala:56)
> at kafka.admin.TopicCommand.main(TopicCommand.scala)
> Caused by: java.net.UnknownHostException: locahost
> at java.net.Inet6AddressImpl.lookupAllHostAddr(Native Method)
> at java.net.InetAddress$2.lookupAllHostAddr(InetAddress.java:928)
> at
> java.net.InetAddress.getAddressesFromNameService(InetAddress.java:1323)
> at java.net.InetAddress.getAllByName0(InetAddress.java:1276)
> at java.net.InetAddress.getAllByName(InetAddress.java:1192)
> at java.net.InetAddress.getAllByName(InetAddress.java:1126)
> at
> org.apache.zookeeper.client.StaticHostProvider.(
> StaticHostProvider.java:61)
> at org.apache.zookeeper.ZooKeeper.(ZooKeeper.java:445)
> at org.apache.zookeeper.ZooKeeper.(ZooKeeper.java:380)
> at org.I0Itec.zkclient.ZkConnection.connect(ZkConnection.java:70)
> ... 7 more
>
> Thanks
>
> On 18 February 2018 at 02:45, Maria Pilar  wrote:
>
> > Hi
> >
> > I´m trying to configure a multinode cluster in kafka. I have configured
> > each server.properties according with the new properties for each server.
> >
> > When i start each server, the zookeeper console shows that error.
> >
> >  INFO Got user-level KeeperException when processing
> > sessionid:0x161a690f731 type:create cxid:0xd8 zxid:0x11f txntype:-1
> > reqpath:n/a Error Path:/brokers/ids Error:KeeperErrorCode = NodeExists
> for
> > /brokers/ids (org.apache.zookeeper.server.PrepRequestProcessor)
> >
> > I have configured each broker.id
> >
> >
> > Anybody knows what is the error?
> >
> > Thanks
> >
>

Re: Zookeeper Error

2018-02-17 Thread Maria Pilar

When i try to create a topic in that multicluster,

kafka-topics.bat --create --topic my-kafka-topic --zookeeper locahost:2181
--replication-factor 2 --partitions 3

i have received the same error

Exception in thread "main" org.I0Itec.zkclient.exception.ZkException:
Unable to connect to locahost:2181
at org.I0Itec.zkclient.ZkConnection.connect(ZkConnection.java:72)
at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:1228)
at org.I0Itec.zkclient.ZkClient.(ZkClient.java:157)
at org.I0Itec.zkclient.ZkClient.(ZkClient.java:131)
at
kafka.utils.ZkUtils$.createZkClientAndConnection(ZkUtils.scala:115)
at kafka.utils.ZkUtils$.apply(ZkUtils.scala:97)
at kafka.admin.TopicCommand$.main(TopicCommand.scala:56)
at kafka.admin.TopicCommand.main(TopicCommand.scala)
Caused by: java.net.UnknownHostException: locahost
at java.net.Inet6AddressImpl.lookupAllHostAddr(Native Method)
at java.net.InetAddress$2.lookupAllHostAddr(InetAddress.java:928)
at
java.net.InetAddress.getAddressesFromNameService(InetAddress.java:1323)
at java.net.InetAddress.getAllByName0(InetAddress.java:1276)
at java.net.InetAddress.getAllByName(InetAddress.java:1192)
at java.net.InetAddress.getAllByName(InetAddress.java:1126)
at
org.apache.zookeeper.client.StaticHostProvider.(StaticHostProvider.java:61)
at org.apache.zookeeper.ZooKeeper.(ZooKeeper.java:445)
at org.apache.zookeeper.ZooKeeper.(ZooKeeper.java:380)
at org.I0Itec.zkclient.ZkConnection.connect(ZkConnection.java:70)
... 7 more

Thanks

On 18 February 2018 at 02:45, Maria Pilar  wrote:

> Hi
>
> I´m trying to configure a multinode cluster in kafka. I have configured
> each server.properties according with the new properties for each server.
>
> When i start each server, the zookeeper console shows that error.
>
>  INFO Got user-level KeeperException when processing
> sessionid:0x161a690f731 type:create cxid:0xd8 zxid:0x11f txntype:-1
> reqpath:n/a Error Path:/brokers/ids Error:KeeperErrorCode = NodeExists for
> /brokers/ids (org.apache.zookeeper.server.PrepRequestProcessor)
>
> I have configured each broker.id
>
>
> Anybody knows what is the error?
>
> Thanks
>

Zookeeper Error

2018-02-17 Thread Maria Pilar

Hi

I´m trying to configure a multinode cluster in kafka. I have configured
each server.properties according with the new properties for each server.

When i start each server, the zookeeper console shows that error.

 INFO Got user-level KeeperException when processing
sessionid:0x161a690f731 type:create cxid:0xd8 zxid:0x11f txntype:-1
reqpath:n/a Error Path:/brokers/ids Error:KeeperErrorCode = NodeExists for
/brokers/ids (org.apache.zookeeper.server.PrepRequestProcessor)

I have configured each broker.id


Anybody knows what is the error?

Thanks

Re: Kafka connect mysql

2018-02-17 Thread Ted Yu

In your first email, there are two pairs of brackets following
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 
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 
> 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 
> wrote:
>
> > yes like suggested :-) but nothing,
> >
> > Debian 9 for the OS
> >
> >
> > thx Ted
> >
> > 
> > De : Ted Yu 
> > 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 <
> adriennolar...@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

2018-02-17 Thread adrien ruffie

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 
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 
wrote:

> yes like suggested :-) but nothing,
>
> Debian 9 for the OS
>
>
> thx Ted
>
> 
> De : Ted Yu 
> 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  >
> 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

2018-02-17 Thread Ted Yu

>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 
wrote:

> yes like suggested :-) but nothing,
>
> Debian 9 for the OS
>
>
> thx Ted
>
> 
> De : Ted Yu 
> 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  >
> 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

2018-02-17 Thread adrien ruffie

yes like suggested :-) but nothing,

Debian 9 for the OS


thx Ted


De : Ted Yu 
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 
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

2018-02-17 Thread Ted Yu

Have you tried adding -g/--globoff ?

What is the OS you use ?

Cheers

On Sat, Feb 17, 2018 at 11:04 AM, adrien ruffie 
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
>
>

Kafka connect mysql

2018-02-17 Thread adrien ruffie

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

Re: Zookeeper Error

Re: Zookeeper Error

Re: Zookeeper Error

Zookeeper Error

Re: Kafka connect mysql

RE: Kafka connect mysql

Re: Kafka connect mysql

RE: Kafka connect mysql

Re: Kafka connect mysql

Kafka connect mysql

11 matches

Site Navigation

Mail list logo

Footer information