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’
   这个是不是会有问题,大家是怎么处理的?
        

回复