You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2020/09/07 07:05:18 UTC

[GitHub] [rocketmq-externals] RoadOfShang opened a new issue #631: [rocketmq-flink] flinksql connector rocketmq

RoadOfShang opened a new issue #631:
URL: https://github.com/apache/rocketmq-externals/issues/631


   hope the community provide a connection that can be well integrated with FlinkSQL。
   be similar to kafka:
   
   CREATE TABLE kafkaTable (
    user_id BIGINT,
    item_id BIGINT,
    category_id BIGINT,
    behavior STRING,
    ts TIMESTAMP(3)
   ) WITH (
    'connector' = 'kafka',
    'topic' = 'user_behavior',
    'properties.bootstrap.servers' = 'localhost:9092',
    'properties.group.id' = 'testGroup',
    'format' = 'csv',
    'scan.startup.mode' = 'earliest-offset'
   )


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [rocketmq-externals] RoadOfShang commented on issue #631: [rocketmq-flink] flinksql connector rocketmq

Posted by GitBox <gi...@apache.org>.
RoadOfShang commented on issue #631:
URL: https://github.com/apache/rocketmq-externals/issues/631#issuecomment-690897845






----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [rocketmq-externals] francisoliverlee commented on issue #631: [rocketmq-flink] flinksql connector rocketmq

Posted by GitBox <gi...@apache.org>.
francisoliverlee commented on issue #631:
URL: https://github.com/apache/rocketmq-externals/issues/631#issuecomment-689583222


   do u like to submit a PR to do with it?


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [rocketmq-externals] vongosling commented on issue #631: [rocketmq-flink] flinksql connector rocketmq

Posted by GitBox <gi...@apache.org>.
vongosling commented on issue #631:
URL: https://github.com/apache/rocketmq-externals/issues/631#issuecomment-706023425


   Just do it. We just link pr and issue.


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [rocketmq-externals] vongosling commented on issue #631: [rocketmq-flink] flinksql connector rocketmq

Posted by GitBox <gi...@apache.org>.
vongosling commented on issue #631:
URL: https://github.com/apache/rocketmq-externals/issues/631#issuecomment-705939203






----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [rocketmq-externals] stevenchange edited a comment on issue #631: [rocketmq-flink] flinksql connector rocketmq

Posted by GitBox <gi...@apache.org>.
stevenchange edited a comment on issue #631:
URL: https://github.com/apache/rocketmq-externals/issues/631#issuecomment-704761971


   hello，do you solve this problem?
   I'm working on this.
   
   can I try this?@francisoliverlee @RoadOfShang


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [rocketmq-externals] stevenchange commented on issue #631: [rocketmq-flink] flinksql connector rocketmq

Posted by GitBox <gi...@apache.org>.
stevenchange commented on issue #631:
URL: https://github.com/apache/rocketmq-externals/issues/631#issuecomment-704761971


   hello，do you solve this problem?
   I'm working on this.
   
   can I try this?


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [rocketmq-externals] stevenchange commented on issue #631: [rocketmq-flink] flinksql connector rocketmq

Posted by GitBox <gi...@apache.org>.
stevenchange commented on issue #631:
URL: https://github.com/apache/rocketmq-externals/issues/631#issuecomment-705950117


   thanks， @vongosling 
   I will create a new issue ,please assign this issue to me.


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [rocketmq-externals] vongosling closed issue #631: [rocketmq-flink] flinksql connector rocketmq

Posted by GitBox <gi...@apache.org>.
vongosling closed issue #631:
URL: https://github.com/apache/rocketmq-externals/issues/631


   


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [rocketmq-externals] stevenchange commented on issue #631: [rocketmq-flink] flinksql connector rocketmq

Posted by GitBox <gi...@apache.org>.
stevenchange commented on issue #631:
URL: https://github.com/apache/rocketmq-externals/issues/631#issuecomment-705950117


   thanks， @vongosling 
   I will create a new issue ,please assign this issue to me.


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [rocketmq-externals] vongosling commented on issue #631: [rocketmq-flink] flinksql connector rocketmq

Posted by GitBox <gi...@apache.org>.
vongosling commented on issue #631:
URL: https://github.com/apache/rocketmq-externals/issues/631#issuecomment-705939203


   sure @stevenchange  I am glad to follow your pr.


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [rocketmq-externals] RoadOfShang commented on issue #631: [rocketmq-flink] flinksql connector rocketmq

Posted by GitBox <gi...@apache.org>.
RoadOfShang commented on issue #631:
URL: https://github.com/apache/rocketmq-externals/issues/631#issuecomment-690897845






----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [rocketmq-externals] RoadOfShang commented on issue #631: [rocketmq-flink] flinksql connector rocketmq

Posted by GitBox <gi...@apache.org>.
RoadOfShang commented on issue #631:
URL: https://github.com/apache/rocketmq-externals/issues/631#issuecomment-690897845


   > do u like to submit a PR to do with it?
   
   
   I'm solving this problem, but I don't know if I can get a good result


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [rocketmq-externals] stevenchange edited a comment on issue #631: [rocketmq-flink] flinksql connector rocketmq

Posted by GitBox <gi...@apache.org>.
stevenchange edited a comment on issue #631:
URL: https://github.com/apache/rocketmq-externals/issues/631#issuecomment-705950117


   thanks， @vongosling 
   I will create a new issue ,please assign this issue to me.
   
   the new issue is #638


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [rocketmq-externals] stevenchange commented on issue #631: [rocketmq-flink] flinksql connector rocketmq

Posted by GitBox <gi...@apache.org>.
stevenchange commented on issue #631:
URL: https://github.com/apache/rocketmq-externals/issues/631#issuecomment-704762580


   the demo like this:
   "CREATE TABLE datagen ( \n" +
   "  f_sequence INT, \n" +
   "  f_random INT, \n" +
   "  f_random_str STRING \n" +
   ") WITH ( \n" +
   "  'connector' = 'rmq-flink',\n" +
   "  'topic' = '" + topic + "', \n" +
   "  'nameserver.address' = '" + nameServer + "', \n" +
   "  'group' = 'connector', \n" +
   "  'format' = 'rmq-json' \n" +
   ")";


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [rocketmq-externals] stevenchange edited a comment on issue #631: [rocketmq-flink] flinksql connector rocketmq

Posted by GitBox <gi...@apache.org>.
stevenchange edited a comment on issue #631:
URL: https://github.com/apache/rocketmq-externals/issues/631#issuecomment-705950117


   thanks， @vongosling 
   I will create a new issue ,please assign this issue to me.
   
   the new issue is #638


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [rocketmq-externals] RoadOfShang commented on issue #631: [rocketmq-flink] flinksql connector rocketmq

Posted by GitBox <gi...@apache.org>.
RoadOfShang commented on issue #631:
URL: https://github.com/apache/rocketmq-externals/issues/631#issuecomment-690897845


   > do u like to submit a PR to do with it?
   
   
   I'm solving this problem, but I don't know if I can get a good result


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org