[GitHub] [pulsar] dmcarver commented on issue #11288: 2.8.0 sink can no longer process batched records from Python producer

[GitBox <gi...@apache.org>]

dmcarver commented on issue #11288:
URL: https://github.com/apache/pulsar/issues/11288#issuecomment-879181410


   If I start from a clean slate (new topic, new sink connector) and send data from the producer with `batching_enabled=True`, the schema isn't written to the logs. The only thing logged is the error above, even with the logging level for the connector set to FULL.
   
   However, I can retrieve the schema with `bin/pulsar-admin schemas get mytopic`:
   
   ```
   {
     "version": 0,
     "schemaInfo": {
       "name": "mytopic",
       "schema": {
         "name": "Test_Schema",
         "type": "record",
         "fields": [
           {
             "name": "field1",
             "type": [
               "null",
               "string"
             ]
           },
           {
             "name": "measurement",
             "type": "string"
           }
         ]
       },
       "type": "JSON",
       "properties": {}
     }
   }
   ```


-- 
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@pulsar.apache.org

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