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


   Running that against the existing topic, it does show the schema:
   
   ```
   15:48:36.802 [pulsar-client-io-1-1] INFO  
org.apache.pulsar.client.impl.PulsarClientImpl - Configuring schema for topic
   mytopic : {                                     
     "name": "public/default/mytopic",                   
     "schema": {           
       "name": "Test_Schema",
       "type": "record",         
       "fields": [       
         {                           
           "name": "field1",                          
           "type": [                                      
             "null",                
             "string"   
           ]                 
         },                                   
         {                             
           "name": "measurement",               
           "type": "string"    
         }                 
       ]                                                                        
                                          
     },                                         
     "type": "JSON",                                                            
                                          
     "properties": {}                                                           
                                          
   }                                                                            
                                          
   15:48:36.855 [pulsar-client-io-1-1] INFO  
org.apache.pulsar.client.impl.schema.AutoConsumeSchema - Configure topic schem
   a for topic mytopic : {                                                      
                                          
    "name": "Test_Schema", 
    "type": "record",               
    "fields": [
     {                                                                          
                                              "name": "field1",
      "type": [                                
       "null",                    
       "string"          
      ]                    
     },                           
     {                                                                          
                                          
      "name": "measurement",                                                    
                                          
      "type": "string"        
     }                                                                          
                                          
    ]                       
   }                                                                            
                                          
   ```
   
   And upon producing a new event, it is consumed:
   ```
   15:50:24.303 [pulsar-client-io-1-1] INFO  
com.scurrilous.circe.checksum.Crc32cIntChecksum - SSE4.2 CRC32C provider 
initialized              
   ----- got message -----                     
   key:[null], properties:[], content:{value={
    "measurement": "foo",
    "field1": "bar"        
   }, type=class java.lang.String}
   15:50:24.337 [main] INFO  org.apache.pulsar.client.impl.PulsarClientImpl - 
Client closing. URL: pulsar://localhost:6650/
   15:50:24.345 [pulsar-client-io-1-1] INFO  
org.apache.pulsar.client.impl.ConsumerImpl - [mytopic] [subscname] Closed cons
   umer                       
   15:50:24.349 [pulsar-client-io-1-1] INFO  
org.apache.pulsar.client.impl.ClientCnx - [id: 0x08a0758f, L:/127.0.0.1:40948
   ! R:localhost/127.0.0.1:6650] Disconnected
   15:50:24.353 [pulsar-client-io-1-1] INFO  
org.apache.pulsar.client.impl.ClientCnx - [id: 0xcaf87c1d, L:/127.0.0.1:40950
   ! R:localhost/127.0.0.1:6650] Disconnected                                   
                                           
   15:50:26.371 [main] INFO  org.apache.pulsar.client.cli.PulsarClientTool - 1 
messages successfully consumed
   ```
   


-- 
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: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


Reply via email to