You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by GitBox <gi...@apache.org> on 2020/07/23 08:29:02 UTC

[GitHub] [camel-kafka-connector] nidhijwt edited a comment on issue #324: The committed block count cannot exceed the maximum limit of 50,000 blocks.

nidhijwt edited a comment on issue #324:
URL: https://github.com/apache/camel-kafka-connector/issues/324#issuecomment-662882951


   Thanks, guys,
   
   Another error in the above configuration I see is "camel._bean_.aggregate" it should be "camel._beans_.aggregate".
   
   I did above as per suggestions but it is still not working. Then I checked logs and there I found following
   
   ```
   INFO Using properties from: classpath:application.properties;optional=true (org.apache.camel.main.BaseMainSupport)
   [2020-07-23 08:06:33,294] WARN Property not auto-configured: camel.beans.aggregation.timeout=5000L (org.apache.camel.main.BaseMainSupport)
   [2020-07-23 08:06:33,294] WARN Property not auto-configured: camel.beans.aggregation.size=1000 (org.apache.camel.main.BaseMainSupport)
   [2020-07-23 08:06:33,296] INFO Auto-configuration summary: (org.apache.camel.main.BaseMainSupport)
   [2020-07-23 08:06:33,296] INFO  camel.component.azure-storage-blob.operation=commitAppendBlob (org.apache.camel.main.BaseMainSupport)
   [2020-07-23 08:06:33,297] INFO No additional Camel XML routes discovered from: classpath:camel/*.xml (org.apache.camel.main.DefaultRoutesCollector)
   ```
   The configuration I am using is 
   
   ```
   {
       "name": "CamelAzure-storage",
       "config": {
           "connector.class": "org.apache.camel.kafkaconnector.azurestorageblob.CamelAzurestorageblobSinkConnector",
           "tasks.max": "1",
           "value.converter": "org.apache.kafka.connect.storage.StringConverter",
           "topics": "my-topic",
           "camel.sink.path.containerName": "storageaccount/container-name",
           "camel.sink.endpoint.blobName": "file.txt",
           "camel.sink.endpoint.accessKey": "my-access-key",
           "camel.component.azure-storage-blob.operation": "commitAppendBlob",
           "camel.beans.aggregate": "org.apache.camel.kafkaconnector.aggregator.StringAggregator",
           "camel.beans.aggregation.size": "1000",
           "camel.beans.aggregation.timeout": "5000L"
       }
   }
   ```
   Observation: It does not say _Property not auto-configured:_ for _camel.beans.aggregate_
   
   


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