[GitHub] [pulsar] wolfstudy commented on issue #4787: Sink ignores inputSpecs in configuration yaml on create

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

wolfstudy commented on issue #4787: Sink ignores inputSpecs in configuration yaml on create
URL: https://github.com/apache/pulsar/issues/4787#issuecomment-515862872
 
 
   Hello, according to the information you provided, we have reproduced your process, and the `receiverQueueSize` can be assigned normally.
   
   solr-config.yml as follows:
   
   ```
   tenant: public
   namespace: default
   name: solr_kerberos
   inputSpecs:
     sample_topic_name:
       receiverQueueSize: 1000000
   configs:
     solrUrl: http://sample-solr:8983/solr
     loginConfigurationLocation: "/data/connectors/solr_kerberos_io_jaas.conf"
     collectionName: sample_collection
     documentQueueSize: 5000
     concurrentThreadCount: 25
   parallelism: 3
   processingGuarantees: ATLEAST_ONCE
   retainOrdering: false
   autoAck: true
   ```
   
   ### To Reproduce
   
   ```
   ➜  pulsar git:(master) ✗docker run -it -d  -p 8983:8983 --name pulsar-solr-docker solr solr-precreate gettingstarted
   
   ➜  pulsar git:(master) ✗ ./bin/pulsar-admin sink create --sink-config-file connectors/solr-config.yaml -a pulsar-io/solr/target/pulsar-io-solr-2.4.0.nar
   "Created successfully"
   ➜  pulsar git:(master) ✗ ./bin/pulsar-admin sink get --tenant public --namespace default --name solr_kerberos
   {
    "tenant": "public",
    "namespace": "default",
    "name": "solr_kerberos",
    "className": "org.apache.pulsar.io.solr.SolrGenericRecordSink",
    "inputSpecs": {
      "sample_topic_name": {
        "isRegexPattern": false,
        "receiverQueueSize": 1000000
      }
    },
    "configs": {
      "solrUrl": "http://localhost:8983/solr",
      "documentQueueSize": 5000,
      "concurrentThreadCount": 25,
      "collectionName": "sample_collection"
    },
    "parallelism": 3,
    "processingGuarantees": "ATLEAST_ONCE",
    "retainOrdering": false,
    "autoAck": true
   }
   ```

----------------------------------------------------------------
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.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services