Re: [I] [Bug] [connector-hive] sink hive AbstractWriteStrategy.buildSchemaWithRowType NullPointerException [seatunnel]

["zengqinchris (via GitHub)" <gi...@apache.org>]

zengqinchris commented on issue #4549:
URL: https://github.com/apache/seatunnel/issues/4549#issuecomment-1855281676

   大佬们，你们指定 start_mode = "group_offsets" 可以消费数据吗，我的一直不能消费数据，换成新的消费者组也是不行的，只能消费新的数据，之前的历史数据，只能消费新的数据
   env {
   parallelism = 1
   job.mode = "STREAMING"
   checkpoint.interval = 15
   }
   source {
     Kafka {
       format = json
       field_delimiter = ","
   	json.fail-on-missing-field = false
       json.ignore-parse-errors = true
       format_error_handle_way = "fail"
       topic = "kv_info"
       consumer.group = "kv_info_client_12"
   	commit_on_checkpoint = true
   	start_mode = "group_offsets"
       bootstrap.servers = "bd212:9092,bd213:9092,bd214:9092"
       kafka.config = {
         client.id = kv_info_client_12
         max.poll.records = 50000
   	  enable.auto.commit = false
       }
     }
   }
   transform {
   }
   sink {
   Console {
       } 
   }


-- 
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.

To unsubscribe, e-mail: commits-unsubscribe@seatunnel.apache.org

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