Catalog(Kafka Connectors 的ddl)持久化到hive metastore，groupid一样的问题

[孙啸龙]

Hi:
        版本：1.12.0
        DDL 语句持久化到hive metastore，
        创建语句如下，
        CREATE TABLE KafkaTable (
  `user_id` BIGINT,
  `item_id` BIGINT,
  `behavior` STRING,
  `ts` TIMESTAMP(3) METADATA FROM 'timestamp'
) WITH (
  'connector' = 'kafka',
  'topic' = 'user_behavior',
  'properties.bootstrap.servers' = 'localhost:9092',
  'properties.group.id' = 'testGroup',
  'scan.startup.mode' = 'earliest-offset',
  'format' = 'csv'
)
    那多个应用使用的时候，groupid都是一样的，'properties.group.id' = ‘testGroup’
   这个是不是会有问题，大家是怎么处理的？
       

[JasonLee]

hi

社区以及提供了动态修改表属性的功能,具体使用可以参考 https://mp.weixin.qq.com/s/nWKVGmAtENlQ80mdETZzDw



-----
Best Wishes
JasonLee
--
Sent from: http://apache-flink.147419.n8.nabble.com/

[孙啸龙]

非常谢谢

> 在 2021年1月30日，下午9:18，JasonLee <[hidden email]> 写道：
>
> hi
>
> 社区以及提供了动态修改表属性的功能,具体使用可以参考 https://mp.weixin.qq.com/s/nWKVGmAtENlQ80mdETZzDw
>
>
>
> -----
> Best Wishes
> JasonLee
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/