text: \i test/sql/setup.inc
  CREATE FOREIGN TABLE kafka_test_junk (
      part int OPTIONS (partition 'true'),
      offs bigint OPTIONS (offset 'true'),
      some_int int,
      some_text text,
      some_date date,
      some_time timestamp,
      junk text OPTIONS (junk 'true'),
      junk_err text OPTIONS (junk_error 'true')
  )
  SERVER kafka_server OPTIONS
      (format 'csv', topic 'contrib_regress_junk', batch_size '30', buffer_delay '100');
  
  CREATE FOREIGN TABLE kafka_test_junk_json (
      part int OPTIONS (partition 'true'),
      offs bigint OPTIONS (offset 'true'),
      int_val int,
      text_val text,
      date_val date,
      time_val timestamp,
      junk text OPTIONS (junk 'true'),
      junk_err text OPTIONS (junk_error 'true')
  )
  SERVER kafka_server OPTIONS
      (format 'json', topic 'contrib_regress_json_junk', batch_size '30', buffer_delay '100');
  
  \x on
  SELECT part, offs, some_int, some_text, some_date, some_time, junk, string_to_array(junk_err, E'\n')  FROM kafka_test_junk WHERE offs>=0 and part=0 ;
  
  SELECT part, offs, int_val, text_val, date_val, time_val, junk, string_to_array(junk_err, E'\n')  FROM kafka_test_junk_json WHERE offs>=0 and part=0 ;
  