[camel] branch regen_bot updated (a591415 -> d966575)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. from a591415 CAMEL-17247: camel-atlasmap - Allow to reload file to pickup updates (#6492) add 8c8d4ff Upgrade AWS SDK v2 to version 2.17.91 add d966575 Sync deps No new revisions were added by this update. Summary of changes: camel-dependencies/pom.xml | 2 +- parent/pom.xml | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-)
[camel-website] branch linkedin updated (6e8cfb8 -> 2999078)
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a change to branch linkedin in repository https://gitbox.apache.org/repos/asf/camel-website.git. from 6e8cfb8 #686: Add icon to Apache Camel group on Linkedin add 2999078 #686: Add icon to Apache Camel group on Linkedin No new revisions were added by this update. Summary of changes: antora-ui-camel/src/img/brand-logos.svg | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)
[camel-k] branch main updated (13dadf1 -> 21d4e0a)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/camel-k.git. from 13dadf1 Updated CHANGELOG.md add 21d4e0a Makefile: for the generate-doc target don't use show-progress for wget No new revisions were added by this update. Summary of changes: script/gen_crd/gen_crd_api.sh | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-)
[camel] branch regen_bot updated (e5ec3b3 -> a591415)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. from e5ec3b3 CAMEL-17248: added camel-kamelets as a runtime dependency for camel-jbang add a591415 CAMEL-17247: camel-atlasmap - Allow to reload file to pickup updates (#6492) No new revisions were added by this update. Summary of changes: .../apache/camel/catalog/components/atlasmap.json | 1 + .../atlasmap/AtlasMapEndpointConfigurer.java | 6 ++ .../atlasmap/AtlasMapEndpointUriFactory.java | 3 +- .../apache/camel/component/atlasmap/atlasmap.json | 1 + .../src/main/docs/atlasmap-component.adoc | 5 +- .../component/atlasmap/AtlasMapComponent.java | 2 + .../camel/component/atlasmap/AtlasMapEndpoint.java | 21 - .../atlasmap/AtlasMapForceReloadTest.java | 102 + ...ext.xml => AtlasMapForceReloadTest-context.xml} | 8 +- .../dsl/AtlasMapEndpointBuilderFactory.java| 39 10 files changed, 179 insertions(+), 9 deletions(-) create mode 100644 components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapForceReloadTest.java copy components/camel-atlasmap/src/test/resources/context/{AtlasMapExtractMappingsTest-context.xml => AtlasMapForceReloadTest-context.xml} (86%)
[GitHub] [camel-k] oscerd closed issue #2791: Makefile: for the generate-doc target don't use show-progress for wget
oscerd closed issue #2791: URL: https://github.com/apache/camel-k/issues/2791 -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-k] oscerd merged pull request #2792: Makefile: for the generate-doc target don't use show-progress for wget
oscerd merged pull request #2792: URL: https://github.com/apache/camel-k/pull/2792 -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kamelets] oscerd opened a new issue #592: Kamelet YAML files links are broken
oscerd opened a new issue #592: URL: https://github.com/apache/camel-kamelets/issues/592 Since we moved all Kamelets to Kamelets folder. -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-k] oscerd commented on issue #2725: Camel K SEDA Queue full Issue
oscerd commented on issue #2725: URL: https://github.com/apache/camel-k/issues/2725#issuecomment-982333465 This was explained. -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-k] oscerd closed issue #2725: Camel K SEDA Queue full Issue
oscerd closed issue #2725: URL: https://github.com/apache/camel-k/issues/2725 -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-k] branch 2791-fix created (now 45b8801)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch 2791-fix in repository https://gitbox.apache.org/repos/asf/camel-k.git. at 45b8801 Makefile: for the generate-doc target don't use show-progress for wget No new revisions were added by this update.
[GitHub] [camel-k] oscerd commented on issue #2759: Document dependency on camel-quarkus (and camel)
oscerd commented on issue #2759: URL: https://github.com/apache/camel-k/issues/2759#issuecomment-982332870 I think this is already solved. -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-k] oscerd opened a new pull request #2792: Makefile: for the generate-doc target don't use show-progress for wget
oscerd opened a new pull request #2792: URL: https://github.com/apache/camel-k/pull/2792 Fixes #2791 -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch main updated (a591415 -> d966575)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/camel.git. from a591415 CAMEL-17247: camel-atlasmap - Allow to reload file to pickup updates (#6492) add 8c8d4ff Upgrade AWS SDK v2 to version 2.17.91 add d966575 Sync deps No new revisions were added by this update. Summary of changes: camel-dependencies/pom.xml | 2 +- parent/pom.xml | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-)
[GitHub] [camel] orpiske commented on a change in pull request #6491: CAMEL-17240: cleanup the camel-kafka producer code
orpiske commented on a change in pull request #6491: URL: https://github.com/apache/camel/pull/6491#discussion_r758967315 ## File path: components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaProducer.java ## @@ -143,167 +145,260 @@ protected void doStop() throws Exception { } if (shutdownWorkerPool && workerPool != null) { -int timeout = endpoint.getConfiguration().getShutdownTimeout(); +int timeout = configuration.getShutdownTimeout(); LOG.debug("Shutting down Kafka producer worker threads with timeout {} millis", timeout); endpoint.getCamelContext().getExecutorServiceManager().shutdownGraceful(workerPool, timeout); workerPool = null; } } -@SuppressWarnings({ "unchecked", "rawtypes" }) -protected Iterator> createRecorder(Exchange exchange) throws Exception { -String topic = endpoint.getConfiguration().getTopic(); -Long timeStamp = null; +protected Iterator>> createRecordIterable( +Exchange exchange, Message message) { +String topic = evaluateTopic(message); -// must remove header so its not propagated -Object overrideTopic = exchange.getIn().removeHeader(KafkaConstants.OVERRIDE_TOPIC); -if (overrideTopic != null) { -LOG.debug("Using override topic: {}", overrideTopic); -topic = overrideTopic.toString(); -} +// extracting headers which need to be propagated +List propagatedHeaders = getPropagatedHeaders(exchange, message); -if (topic == null) { -// if topic property was not received from configuration or header -// parameters take it from the remaining URI -topic = URISupport.extractRemainderPath(new URI(endpoint.getEndpointUri()), true); -} +Object body = message.getBody(); + +Iterator iterator = getObjectIterator(body); + +return new KeyValueHolderIterator(iterator, exchange, configuration, topic, propagatedHeaders); +} + +protected ProducerRecord createRecord(Exchange exchange, Message message) { +String topic = evaluateTopic(message); -Object overrideTimeStamp = exchange.getIn().removeHeader(KafkaConstants.OVERRIDE_TIMESTAMP); +Long timeStamp = null; +Object overrideTimeStamp = message.removeHeader(KafkaConstants.OVERRIDE_TIMESTAMP); if (overrideTimeStamp instanceof Long) { LOG.debug("Using override TimeStamp: {}", overrideTimeStamp); timeStamp = (Long) overrideTimeStamp; } // extracting headers which need to be propagated -List propagatedHeaders = getPropagatedHeaders(exchange, endpoint.getConfiguration()); - -Object msg = exchange.getIn().getBody(); - -// is the message body a list or something that contains multiple values -Iterator iterator = null; -if (msg instanceof Iterable) { -iterator = ((Iterable) msg).iterator(); -} else if (msg instanceof Iterator) { -iterator = (Iterator) msg; -} -if (iterator != null) { -final Iterator msgList = iterator; -final String msgTopic = topic; - -return new KeyValueHolderIterator(msgList, exchange, endpoint.getConfiguration(), msgTopic, propagatedHeaders); -} +List propagatedHeaders = getPropagatedHeaders(exchange, message); // endpoint take precedence over header configuration -final Integer partitionKey = ObjectHelper.supplyIfEmpty(endpoint.getConfiguration().getPartitionKey(), -() -> exchange.getIn().getHeader(KafkaConstants.PARTITION_KEY, Integer.class)); +final Integer partitionKey = ObjectHelper.supplyIfEmpty(configuration.getPartitionKey(), +() -> message.getHeader(KafkaConstants.PARTITION_KEY, Integer.class)); // endpoint take precedence over header configuration -Object key = ObjectHelper.supplyIfEmpty(endpoint.getConfiguration().getKey(), -() -> exchange.getIn().getHeader(KafkaConstants.KEY)); +Object key = ObjectHelper.supplyIfEmpty(configuration.getKey(), +() -> message.getHeader(KafkaConstants.KEY)); if (key != null) { -key = tryConvertToSerializedType(exchange, key, endpoint.getConfiguration().getKeySerializer()); +key = tryConvertToSerializedType(exchange, key, configuration.getKeySerializer()); } // must convert each entry of the iterator into the value according to // the serializer -Object value = tryConvertToSerializedType(exchange, msg, endpoint.getConfiguration().getValueSerializer()); +Object value = tryConvertToSerializedType(exchange, message.getBody(), configuration.getValueSerializer()); + +return new ProducerRecord<>(topic, partitionKey,
[GitHub] [camel] orpiske commented on a change in pull request #6491: CAMEL-17240: cleanup the camel-kafka producer code
orpiske commented on a change in pull request #6491: URL: https://github.com/apache/camel/pull/6491#discussion_r758965780 ## File path: components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaProducer.java ## @@ -143,167 +145,260 @@ protected void doStop() throws Exception { } if (shutdownWorkerPool && workerPool != null) { -int timeout = endpoint.getConfiguration().getShutdownTimeout(); +int timeout = configuration.getShutdownTimeout(); LOG.debug("Shutting down Kafka producer worker threads with timeout {} millis", timeout); endpoint.getCamelContext().getExecutorServiceManager().shutdownGraceful(workerPool, timeout); workerPool = null; } } -@SuppressWarnings({ "unchecked", "rawtypes" }) -protected Iterator> createRecorder(Exchange exchange) throws Exception { -String topic = endpoint.getConfiguration().getTopic(); -Long timeStamp = null; +protected Iterator>> createRecordIterable( +Exchange exchange, Message message) { +String topic = evaluateTopic(message); -// must remove header so its not propagated -Object overrideTopic = exchange.getIn().removeHeader(KafkaConstants.OVERRIDE_TOPIC); -if (overrideTopic != null) { -LOG.debug("Using override topic: {}", overrideTopic); -topic = overrideTopic.toString(); -} +// extracting headers which need to be propagated +List propagatedHeaders = getPropagatedHeaders(exchange, message); -if (topic == null) { -// if topic property was not received from configuration or header -// parameters take it from the remaining URI -topic = URISupport.extractRemainderPath(new URI(endpoint.getEndpointUri()), true); -} +Object body = message.getBody(); + +Iterator iterator = getObjectIterator(body); + +return new KeyValueHolderIterator(iterator, exchange, configuration, topic, propagatedHeaders); +} + +protected ProducerRecord createRecord(Exchange exchange, Message message) { +String topic = evaluateTopic(message); -Object overrideTimeStamp = exchange.getIn().removeHeader(KafkaConstants.OVERRIDE_TIMESTAMP); +Long timeStamp = null; +Object overrideTimeStamp = message.removeHeader(KafkaConstants.OVERRIDE_TIMESTAMP); if (overrideTimeStamp instanceof Long) { LOG.debug("Using override TimeStamp: {}", overrideTimeStamp); timeStamp = (Long) overrideTimeStamp; } // extracting headers which need to be propagated -List propagatedHeaders = getPropagatedHeaders(exchange, endpoint.getConfiguration()); - -Object msg = exchange.getIn().getBody(); - -// is the message body a list or something that contains multiple values -Iterator iterator = null; -if (msg instanceof Iterable) { -iterator = ((Iterable) msg).iterator(); -} else if (msg instanceof Iterator) { -iterator = (Iterator) msg; -} -if (iterator != null) { -final Iterator msgList = iterator; -final String msgTopic = topic; - -return new KeyValueHolderIterator(msgList, exchange, endpoint.getConfiguration(), msgTopic, propagatedHeaders); -} +List propagatedHeaders = getPropagatedHeaders(exchange, message); // endpoint take precedence over header configuration -final Integer partitionKey = ObjectHelper.supplyIfEmpty(endpoint.getConfiguration().getPartitionKey(), -() -> exchange.getIn().getHeader(KafkaConstants.PARTITION_KEY, Integer.class)); +final Integer partitionKey = ObjectHelper.supplyIfEmpty(configuration.getPartitionKey(), Review comment: +1. This one did not appear much on the async profiler, but let's squeeze it as much as we can. -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] orpiske commented on a change in pull request #6491: CAMEL-17240: cleanup the camel-kafka producer code
orpiske commented on a change in pull request #6491: URL: https://github.com/apache/camel/pull/6491#discussion_r758964299 ## File path: components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaProducer.java ## @@ -143,167 +145,260 @@ protected void doStop() throws Exception { } if (shutdownWorkerPool && workerPool != null) { -int timeout = endpoint.getConfiguration().getShutdownTimeout(); +int timeout = configuration.getShutdownTimeout(); LOG.debug("Shutting down Kafka producer worker threads with timeout {} millis", timeout); endpoint.getCamelContext().getExecutorServiceManager().shutdownGraceful(workerPool, timeout); workerPool = null; } } -@SuppressWarnings({ "unchecked", "rawtypes" }) -protected Iterator> createRecorder(Exchange exchange) throws Exception { -String topic = endpoint.getConfiguration().getTopic(); -Long timeStamp = null; +protected Iterator>> createRecordIterable( +Exchange exchange, Message message) { +String topic = evaluateTopic(message); -// must remove header so its not propagated -Object overrideTopic = exchange.getIn().removeHeader(KafkaConstants.OVERRIDE_TOPIC); -if (overrideTopic != null) { -LOG.debug("Using override topic: {}", overrideTopic); -topic = overrideTopic.toString(); -} +// extracting headers which need to be propagated +List propagatedHeaders = getPropagatedHeaders(exchange, message); -if (topic == null) { -// if topic property was not received from configuration or header -// parameters take it from the remaining URI -topic = URISupport.extractRemainderPath(new URI(endpoint.getEndpointUri()), true); -} +Object body = message.getBody(); + +Iterator iterator = getObjectIterator(body); + +return new KeyValueHolderIterator(iterator, exchange, configuration, topic, propagatedHeaders); +} + +protected ProducerRecord createRecord(Exchange exchange, Message message) { +String topic = evaluateTopic(message); -Object overrideTimeStamp = exchange.getIn().removeHeader(KafkaConstants.OVERRIDE_TIMESTAMP); +Long timeStamp = null; +Object overrideTimeStamp = message.removeHeader(KafkaConstants.OVERRIDE_TIMESTAMP); if (overrideTimeStamp instanceof Long) { LOG.debug("Using override TimeStamp: {}", overrideTimeStamp); timeStamp = (Long) overrideTimeStamp; } // extracting headers which need to be propagated -List propagatedHeaders = getPropagatedHeaders(exchange, endpoint.getConfiguration()); - -Object msg = exchange.getIn().getBody(); - -// is the message body a list or something that contains multiple values -Iterator iterator = null; -if (msg instanceof Iterable) { -iterator = ((Iterable) msg).iterator(); -} else if (msg instanceof Iterator) { -iterator = (Iterator) msg; -} -if (iterator != null) { -final Iterator msgList = iterator; -final String msgTopic = topic; - -return new KeyValueHolderIterator(msgList, exchange, endpoint.getConfiguration(), msgTopic, propagatedHeaders); -} +List propagatedHeaders = getPropagatedHeaders(exchange, message); // endpoint take precedence over header configuration -final Integer partitionKey = ObjectHelper.supplyIfEmpty(endpoint.getConfiguration().getPartitionKey(), -() -> exchange.getIn().getHeader(KafkaConstants.PARTITION_KEY, Integer.class)); +final Integer partitionKey = ObjectHelper.supplyIfEmpty(configuration.getPartitionKey(), +() -> message.getHeader(KafkaConstants.PARTITION_KEY, Integer.class)); // endpoint take precedence over header configuration -Object key = ObjectHelper.supplyIfEmpty(endpoint.getConfiguration().getKey(), -() -> exchange.getIn().getHeader(KafkaConstants.KEY)); +Object key = ObjectHelper.supplyIfEmpty(configuration.getKey(), +() -> message.getHeader(KafkaConstants.KEY)); if (key != null) { -key = tryConvertToSerializedType(exchange, key, endpoint.getConfiguration().getKeySerializer()); +key = tryConvertToSerializedType(exchange, key, configuration.getKeySerializer()); } // must convert each entry of the iterator into the value according to // the serializer -Object value = tryConvertToSerializedType(exchange, msg, endpoint.getConfiguration().getValueSerializer()); +Object value = tryConvertToSerializedType(exchange, message.getBody(), configuration.getValueSerializer()); + +return new ProducerRecord<>(topic, partitionKey,
[GitHub] [camel] orpiske commented on a change in pull request #6491: CAMEL-17240: cleanup the camel-kafka producer code
orpiske commented on a change in pull request #6491: URL: https://github.com/apache/camel/pull/6491#discussion_r758963800 ## File path: components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaProducer.java ## @@ -143,167 +145,260 @@ protected void doStop() throws Exception { } if (shutdownWorkerPool && workerPool != null) { -int timeout = endpoint.getConfiguration().getShutdownTimeout(); +int timeout = configuration.getShutdownTimeout(); LOG.debug("Shutting down Kafka producer worker threads with timeout {} millis", timeout); endpoint.getCamelContext().getExecutorServiceManager().shutdownGraceful(workerPool, timeout); workerPool = null; } } -@SuppressWarnings({ "unchecked", "rawtypes" }) -protected Iterator> createRecorder(Exchange exchange) throws Exception { -String topic = endpoint.getConfiguration().getTopic(); -Long timeStamp = null; +protected Iterator>> createRecordIterable( +Exchange exchange, Message message) { +String topic = evaluateTopic(message); -// must remove header so its not propagated -Object overrideTopic = exchange.getIn().removeHeader(KafkaConstants.OVERRIDE_TOPIC); -if (overrideTopic != null) { -LOG.debug("Using override topic: {}", overrideTopic); -topic = overrideTopic.toString(); -} +// extracting headers which need to be propagated +List propagatedHeaders = getPropagatedHeaders(exchange, message); -if (topic == null) { -// if topic property was not received from configuration or header -// parameters take it from the remaining URI -topic = URISupport.extractRemainderPath(new URI(endpoint.getEndpointUri()), true); -} +Object body = message.getBody(); + +Iterator iterator = getObjectIterator(body); + +return new KeyValueHolderIterator(iterator, exchange, configuration, topic, propagatedHeaders); +} + +protected ProducerRecord createRecord(Exchange exchange, Message message) { +String topic = evaluateTopic(message); -Object overrideTimeStamp = exchange.getIn().removeHeader(KafkaConstants.OVERRIDE_TIMESTAMP); +Long timeStamp = null; +Object overrideTimeStamp = message.removeHeader(KafkaConstants.OVERRIDE_TIMESTAMP); if (overrideTimeStamp instanceof Long) { LOG.debug("Using override TimeStamp: {}", overrideTimeStamp); timeStamp = (Long) overrideTimeStamp; } // extracting headers which need to be propagated -List propagatedHeaders = getPropagatedHeaders(exchange, endpoint.getConfiguration()); - -Object msg = exchange.getIn().getBody(); - -// is the message body a list or something that contains multiple values -Iterator iterator = null; -if (msg instanceof Iterable) { -iterator = ((Iterable) msg).iterator(); -} else if (msg instanceof Iterator) { -iterator = (Iterator) msg; -} -if (iterator != null) { -final Iterator msgList = iterator; -final String msgTopic = topic; - -return new KeyValueHolderIterator(msgList, exchange, endpoint.getConfiguration(), msgTopic, propagatedHeaders); -} +List propagatedHeaders = getPropagatedHeaders(exchange, message); // endpoint take precedence over header configuration -final Integer partitionKey = ObjectHelper.supplyIfEmpty(endpoint.getConfiguration().getPartitionKey(), -() -> exchange.getIn().getHeader(KafkaConstants.PARTITION_KEY, Integer.class)); +final Integer partitionKey = ObjectHelper.supplyIfEmpty(configuration.getPartitionKey(), +() -> message.getHeader(KafkaConstants.PARTITION_KEY, Integer.class)); // endpoint take precedence over header configuration -Object key = ObjectHelper.supplyIfEmpty(endpoint.getConfiguration().getKey(), -() -> exchange.getIn().getHeader(KafkaConstants.KEY)); +Object key = ObjectHelper.supplyIfEmpty(configuration.getKey(), +() -> message.getHeader(KafkaConstants.KEY)); if (key != null) { -key = tryConvertToSerializedType(exchange, key, endpoint.getConfiguration().getKeySerializer()); +key = tryConvertToSerializedType(exchange, key, configuration.getKeySerializer()); } // must convert each entry of the iterator into the value according to // the serializer -Object value = tryConvertToSerializedType(exchange, msg, endpoint.getConfiguration().getValueSerializer()); +Object value = tryConvertToSerializedType(exchange, message.getBody(), configuration.getValueSerializer()); + +return new ProducerRecord<>(topic, partitionKey,
[camel] branch main updated (e5ec3b3 -> a591415)
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/camel.git. from e5ec3b3 CAMEL-17248: added camel-kamelets as a runtime dependency for camel-jbang add a591415 CAMEL-17247: camel-atlasmap - Allow to reload file to pickup updates (#6492) No new revisions were added by this update. Summary of changes: .../apache/camel/catalog/components/atlasmap.json | 1 + .../atlasmap/AtlasMapEndpointConfigurer.java | 6 ++ .../atlasmap/AtlasMapEndpointUriFactory.java | 3 +- .../apache/camel/component/atlasmap/atlasmap.json | 1 + .../src/main/docs/atlasmap-component.adoc | 5 +- .../component/atlasmap/AtlasMapComponent.java | 2 + .../camel/component/atlasmap/AtlasMapEndpoint.java | 21 - .../atlasmap/AtlasMapForceReloadTest.java | 102 + ...ext.xml => AtlasMapForceReloadTest-context.xml} | 8 +- .../dsl/AtlasMapEndpointBuilderFactory.java| 39 10 files changed, 179 insertions(+), 9 deletions(-) create mode 100644 components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapForceReloadTest.java copy components/camel-atlasmap/src/test/resources/context/{AtlasMapExtractMappingsTest-context.xml => AtlasMapForceReloadTest-context.xml} (86%)
[GitHub] [camel] davsclaus merged pull request #6492: CAMEL-17247: camel-atlasmap - Allow to reload file to pickup updates
davsclaus merged pull request #6492: URL: https://github.com/apache/camel/pull/6492 -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] davsclaus commented on a change in pull request #6491: CAMEL-17240: cleanup the camel-kafka producer code
davsclaus commented on a change in pull request #6491: URL: https://github.com/apache/camel/pull/6491#discussion_r758957892 ## File path: components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaProducer.java ## @@ -143,167 +145,260 @@ protected void doStop() throws Exception { } if (shutdownWorkerPool && workerPool != null) { -int timeout = endpoint.getConfiguration().getShutdownTimeout(); +int timeout = configuration.getShutdownTimeout(); LOG.debug("Shutting down Kafka producer worker threads with timeout {} millis", timeout); endpoint.getCamelContext().getExecutorServiceManager().shutdownGraceful(workerPool, timeout); workerPool = null; } } -@SuppressWarnings({ "unchecked", "rawtypes" }) -protected Iterator> createRecorder(Exchange exchange) throws Exception { -String topic = endpoint.getConfiguration().getTopic(); -Long timeStamp = null; +protected Iterator>> createRecordIterable( +Exchange exchange, Message message) { +String topic = evaluateTopic(message); -// must remove header so its not propagated -Object overrideTopic = exchange.getIn().removeHeader(KafkaConstants.OVERRIDE_TOPIC); -if (overrideTopic != null) { -LOG.debug("Using override topic: {}", overrideTopic); -topic = overrideTopic.toString(); -} +// extracting headers which need to be propagated +List propagatedHeaders = getPropagatedHeaders(exchange, message); -if (topic == null) { -// if topic property was not received from configuration or header -// parameters take it from the remaining URI -topic = URISupport.extractRemainderPath(new URI(endpoint.getEndpointUri()), true); -} +Object body = message.getBody(); + +Iterator iterator = getObjectIterator(body); + +return new KeyValueHolderIterator(iterator, exchange, configuration, topic, propagatedHeaders); +} + +protected ProducerRecord createRecord(Exchange exchange, Message message) { +String topic = evaluateTopic(message); -Object overrideTimeStamp = exchange.getIn().removeHeader(KafkaConstants.OVERRIDE_TIMESTAMP); +Long timeStamp = null; +Object overrideTimeStamp = message.removeHeader(KafkaConstants.OVERRIDE_TIMESTAMP); if (overrideTimeStamp instanceof Long) { LOG.debug("Using override TimeStamp: {}", overrideTimeStamp); timeStamp = (Long) overrideTimeStamp; } // extracting headers which need to be propagated -List propagatedHeaders = getPropagatedHeaders(exchange, endpoint.getConfiguration()); - -Object msg = exchange.getIn().getBody(); - -// is the message body a list or something that contains multiple values -Iterator iterator = null; -if (msg instanceof Iterable) { -iterator = ((Iterable) msg).iterator(); -} else if (msg instanceof Iterator) { -iterator = (Iterator) msg; -} -if (iterator != null) { -final Iterator msgList = iterator; -final String msgTopic = topic; - -return new KeyValueHolderIterator(msgList, exchange, endpoint.getConfiguration(), msgTopic, propagatedHeaders); -} +List propagatedHeaders = getPropagatedHeaders(exchange, message); // endpoint take precedence over header configuration -final Integer partitionKey = ObjectHelper.supplyIfEmpty(endpoint.getConfiguration().getPartitionKey(), -() -> exchange.getIn().getHeader(KafkaConstants.PARTITION_KEY, Integer.class)); +final Integer partitionKey = ObjectHelper.supplyIfEmpty(configuration.getPartitionKey(), Review comment: You can optimize and avoid creating these suppliers for such code where a if { } is faster ## File path: components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaProducer.java ## @@ -143,167 +145,260 @@ protected void doStop() throws Exception { } if (shutdownWorkerPool && workerPool != null) { -int timeout = endpoint.getConfiguration().getShutdownTimeout(); +int timeout = configuration.getShutdownTimeout(); LOG.debug("Shutting down Kafka producer worker threads with timeout {} millis", timeout); endpoint.getCamelContext().getExecutorServiceManager().shutdownGraceful(workerPool, timeout); workerPool = null; } } -@SuppressWarnings({ "unchecked", "rawtypes" }) -protected Iterator> createRecorder(Exchange exchange) throws Exception { -String topic = endpoint.getConfiguration().getTopic(); -Long timeStamp = null; +protected Iterator>> createRecordIterable( +Exchange exchange, Message
[camel-spring-boot] branch main updated: [create-pull-request] automated change
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git The following commit(s) were added to refs/heads/main by this push: new 112bf1f [create-pull-request] automated change 112bf1f is described below commit 112bf1febe5e8fa5b6de9fe0c39894d86ee13c42 Author: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com> AuthorDate: Tue Nov 30 00:57:56 2021 + [create-pull-request] automated change --- .../camel/springboot/catalog/components/azure-storage-datalake.json | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/azure-storage-datalake.json b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/azure-storage-datalake.json index f1aca33..2fbf7f2 100644 --- a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/azure-storage-datalake.json +++ b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/azure-storage-datalake.json @@ -2,7 +2,7 @@ "component": { "kind": "component", "name": "azure-storage-datalake", -"title": "Azure storage datalake service", +"title": "Azure Storage Datalake Service", "description": "Camel Azure Datalake Gen2 Component", "deprecated": false, "firstVersion": "3.8.0",
[GitHub] [camel-spring-boot] oscerd merged pull request #417: [Github Actions] Periodic Sync Camel Spring Boot Main Branch
oscerd merged pull request #417: URL: https://github.com/apache/camel-spring-boot/pull/417 -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-k] branch main updated: Updated CHANGELOG.md
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-k.git The following commit(s) were added to refs/heads/main by this push: new 13dadf1 Updated CHANGELOG.md 13dadf1 is described below commit 13dadf1a4cdc22fa3f42ac82bc8f24e86a4a8a1c Author: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com> AuthorDate: Tue Nov 30 03:09:17 2021 + Updated CHANGELOG.md --- CHANGELOG.md | 2 ++ 1 file changed, 2 insertions(+) diff --git a/CHANGELOG.md b/CHANGELOG.md index af34bd6..5d38f24 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -11,6 +11,7 @@ - Is there any resources requirements for camel-k operator Deployment? [\#2768](https://github.com/apache/camel-k/issues/2768) - Jitpack still configured with `master` branch [\#2764](https://github.com/apache/camel-k/issues/2764) - How can I find the log file location in the integration pod? [\#2762](https://github.com/apache/camel-k/issues/2762) +- Default value of trait container.port-name is missing from catalog [\#2761](https://github.com/apache/camel-k/issues/2761) - Add 1.7.x documentation tag [\#2753](https://github.com/apache/camel-k/issues/2753) - Could not pull base image - Build kit failed \(No matching credentials were found, falling back on anonymous\) [\#2748](https://github.com/apache/camel-k/issues/2748) - Cannot deploy XML integration with undertow [\#2746](https://github.com/apache/camel-k/issues/2746) @@ -30,6 +31,7 @@ **Merged pull requests:** +- Fix doc port name [\#2790](https://github.com/apache/camel-k/pull/2790) ([oscerd](https://github.com/oscerd)) - fix\(doc\): header complain [\#2787](https://github.com/apache/camel-k/pull/2787) ([squakez](https://github.com/squakez)) - fix\(lint\): error return value are not checked [\#2786](https://github.com/apache/camel-k/pull/2786) ([lburgazzoli](https://github.com/lburgazzoli)) - doc: no CLI integration run [\#2783](https://github.com/apache/camel-k/pull/2783) ([squakez](https://github.com/squakez))
[GitHub] [camel-quarkus] github-actions[bot] commented on issue #2927: [CI] - Camel Main Branch Build Failure
github-actions[bot] commented on issue #2927: URL: https://github.com/apache/camel-quarkus/issues/2927#issuecomment-982226211 The [camel-main](https://github.com/apache/camel-quarkus/tree/camel-main) branch build has failed: * Build ID: 1518470042-482-3ce7d3d3-cc61-40f2-a7d8-ca09265dab9f * Camel Quarkus Commit: a5f9f2a2dad33ba85e41d96b82844672fc439390 * Camel Main Commit: 5c269bdc42377988d89925afd005400fb2d49977 * Link to build: https://github.com/apache/camel-quarkus/actions/runs/1518470042 -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-spring-boot] branch automatic-periodic-sync updated (3f43713 -> 779a72b)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch automatic-periodic-sync in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git. omit 3f43713 [create-pull-request] automated change add eea97a4 [create-pull-request] automated change add 779a72b [create-pull-request] automated change This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the branch are not in the new version. This situation occurs when a user --force pushes a change and generates a repository containing something like this: * -- * -- B -- O -- O -- O (3f43713) \ N -- N -- N refs/heads/automatic-periodic-sync (779a72b) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. No new revisions were added by this update. Summary of changes: .../camel/springboot/catalog/components/azure-storage-datalake.json | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)
[GitHub] [camel-spring-boot] github-actions[bot] opened a new pull request #417: [Github Actions] Periodic Sync Camel Spring Boot Main Branch
github-actions[bot] opened a new pull request #417: URL: https://github.com/apache/camel-spring-boot/pull/417 Periodic Sync of Camel Spring Boot Main Branch with main Camel Main. see https://github.com/apache/camel-spring-boot/blob/main/.github/workflows/automatic-sync-main.yml -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-k] github-actions[bot] commented on issue #2598: Provide a way to specify exclusions for a dependency
github-actions[bot] commented on issue #2598: URL: https://github.com/apache/camel-k/issues/2598#issuecomment-982149001 This issue has been automatically marked as stale due to 90 days of inactivity. It will be closed if no further activity occurs within 15 days. If you think that’s incorrect or the issue should never stale, please simply write any comment. Thanks for your contributions! -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] igarashitm opened a new pull request #6492: CAMEL-17247: camel-atlasmap - Allow to reload file to pickup updates
igarashitm opened a new pull request #6492: URL: https://github.com/apache/camel/pull/6492 Added `forceReload` option to achieve ADM hot reload. Also fixed the adoc, plain JSON mapping definition file is not recommended other than test purpose. - [x] Make sure there is a [JIRA issue](https://issues.apache.org/jira/browse/CAMEL) filed for the change (usually before you start working on it). Trivial changes like typos do not require a JIRA issue. Your pull request should address just this issue, without pulling in other changes. - [x] Each commit in the pull request should have a meaningful subject line and body. - [x] If you're unsure, you can format the pull request title like `[CAMEL-XXX] Fixes bug in camel-file component`, where you replace `CAMEL-XXX` with the appropriate JIRA issue. - [x] Write a pull request description that is detailed enough to understand what the pull request does, how, and why. - [x] Run `mvn clean install -Psourcecheck` in your module with source check enabled to make sure basic checks pass and there are no checkstyle violations. A more thorough check will be performed on your pull request automatically. Below are the contribution guidelines: https://github.com/apache/camel/blob/main/CONTRIBUTING.md -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] github-actions[bot] commented on pull request #698: add kamelets 0.5.x
github-actions[bot] commented on pull request #698: URL: https://github.com/apache/camel-website/pull/698#issuecomment-982096112 Preview is available at https://pr-698--camel.netlify.app -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] djencks opened a new pull request #700: Resolves #699 hugo docs page directs to latest not next docs
djencks opened a new pull request #700: URL: https://github.com/apache/camel-website/pull/700 See #699. -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] djencks opened a new issue #699: /docs/ page should direct to latest, not next, versions of docs
djencks opened a new issue #699: URL: https://github.com/apache/camel-website/issues/699 Directing users to the 'next' documentation implies that the unreleased 'next' version of code can be used for purposes other than development of camel, against Apache policy. -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kamelets] djencks merged pull request #591: 0.5.x update versions for publication
djencks merged pull request #591: URL: https://github.com/apache/camel-kamelets/pull/591 -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-kamelets] branch 0.5.x updated: update versions for publication
This is an automated email from the ASF dual-hosted git repository. djencks pushed a commit to branch 0.5.x in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git The following commit(s) were added to refs/heads/0.5.x by this push: new d9768be update versions for publication d9768be is described below commit d9768be35d7ae759d1b76a89eb34e32085e1f8b2 Author: David Jencks AuthorDate: Mon Nov 29 11:13:36 2021 -0800 update versions for publication --- docs/antora.yml | 6 ++ 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/docs/antora.yml b/docs/antora.yml index 763c601..e43a601 100644 --- a/docs/antora.yml +++ b/docs/antora.yml @@ -17,9 +17,7 @@ name: camel-kamelets title: Kamelet Catalog -version: next -prerelease: true -display-version: Next (Pre-release) +version: 0.5.x nav: - modules/ROOT/nav.adoc @@ -27,4 +25,4 @@ nav: # Update to appropriate released camel-k version on release asciidoc: attributes: -camel-k-version: next +camel-k-version: 1.7.x
[camel-website] branch asf-site updated (ac1944c -> a6731a4)
This is an automated email from the ASF dual-hosted git repository. git-site-role pushed a change to branch asf-site in repository https://gitbox.apache.org/repos/asf/camel-website.git. discard ac1944c Website updated to d9ec5591a433557fa61a4cf8b502a39c01550311 discard 886a56f Website updated to 325e929157412b27394080f4d4dba3d821476ddf new b940224 Website updated to 325e929157412b27394080f4d4dba3d821476ddf new a6731a4 Website updated to d9ec5591a433557fa61a4cf8b502a39c01550311 This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the branch are not in the new version. This situation occurs when a user --force pushes a change and generates a repository containing something like this: * -- * -- B -- O -- O -- O (ac1944c) \ N -- N -- N refs/heads/asf-site (a6731a4) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .htaccess |4 +- sitemap-camel-k.xml | 822 ++--- sitemap-camel-kafka-connector.xml | 2218 ++-- sitemap-camel-kamelets.xml| 282 +- sitemap-camel-karaf.xml | 70 +- sitemap-camel-quarkus.xml | 2078 ++-- sitemap-camel-spring-boot.xml | 54 +- sitemap-components.xml| 6712 ++--- sitemap-manual.xml| 382 +-- 9 files changed, 6311 insertions(+), 6311 deletions(-)
[camel] branch regen_bot updated (a1cd467 -> e5ec3b3)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. from a1cd467 CAMEL-17245: prevent bogus commit calls when shutting down camel-kafka add e5ec3b3 CAMEL-17248: added camel-kamelets as a runtime dependency for camel-jbang No new revisions were added by this update. Summary of changes: dsl/camel-jbang/camel-jbang-main/dist/CamelJBang.java| 1 + dsl/camel-jbang/camel-jbang-main/src/main/jbang/main/CamelJBang.java | 1 + 2 files changed, 2 insertions(+)
[GitHub] [camel-website] github-actions[bot] commented on pull request #698: (currently for preview) add kamelets 0.5.x
github-actions[bot] commented on pull request #698: URL: https://github.com/apache/camel-website/pull/698#issuecomment-982011921 Preview is available at https://pr-698--camel.netlify.app -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] orpiske commented on pull request #6491: CAMEL-17240: cleanup the camel-kafka producer code
orpiske commented on pull request #6491: URL: https://github.com/apache/camel/pull/6491#issuecomment-981997431 Unfortunately I did not have a completely adequate system to test, but in two of the hosts I tested the performance was between 1% to 3% better with this. -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] orpiske commented on pull request #6491: CAMEL-17240: cleanup the camel-kafka producer code
orpiske commented on pull request #6491: URL: https://github.com/apache/camel/pull/6491#issuecomment-981992864 This is a large change, so sending it early to get some feedback. I'll be on PTO after tomorrow, so I may take a bit longer than usual to reply. -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] orpiske opened a new pull request #6491: CAMEL-17240: cleanup the camel-kafka producer code
orpiske opened a new pull request #6491: URL: https://github.com/apache/camel/pull/6491 Includes: - rework the producer to reduce the number of allocations and GC pressure - replace AtomicInteger with LongAdder to reduce risk of contention in AtomicInteger (and a minor improvement in performance) - logging improvements in the hot path - rework the callbacks to prevent creating threads unnecessarily - avoid creating arrays/collections for the delegating callback - use collection singleton for single-item arrays when possible - cleanup to use generics in some of the code - use an assert to check the internal worker pool for not being null as it seems faster - do a single pass of the set when iterating over it to get the propagated headers - cleanup the record iterator to simplify and reduce calls to getHeader -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch main updated: CAMEL-17248: added camel-kamelets as a runtime dependency for camel-jbang
This is an automated email from the ASF dual-hosted git repository. orpiske pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git The following commit(s) were added to refs/heads/main by this push: new e5ec3b3 CAMEL-17248: added camel-kamelets as a runtime dependency for camel-jbang e5ec3b3 is described below commit e5ec3b3ff9e2e1c8ffe7ee0cd480f85a0fcd9c0d Author: Otavio Rodolfo Piske AuthorDate: Mon Nov 29 18:38:37 2021 +0100 CAMEL-17248: added camel-kamelets as a runtime dependency for camel-jbang --- dsl/camel-jbang/camel-jbang-main/dist/CamelJBang.java| 1 + dsl/camel-jbang/camel-jbang-main/src/main/jbang/main/CamelJBang.java | 1 + 2 files changed, 2 insertions(+) diff --git a/dsl/camel-jbang/camel-jbang-main/dist/CamelJBang.java b/dsl/camel-jbang/camel-jbang-main/dist/CamelJBang.java index a52dcb0..9e36eca 100755 --- a/dsl/camel-jbang/camel-jbang-main/dist/CamelJBang.java +++ b/dsl/camel-jbang/camel-jbang-main/dist/CamelJBang.java @@ -20,6 +20,7 @@ //REPOS mavencentral,apache=https://repository.apache.org/snapshots //DEPS org.apache.camel:camel-bom:${camel.jbang.version:RELEASE}@pom //DEPS org.apache.camel:camel-jbang-core:${camel.jbang.version:RELEASE} +//DEPS org.apache.camel.kamelets:camel-kamelets:${camel-kamelets.version:RELEASE} package main; diff --git a/dsl/camel-jbang/camel-jbang-main/src/main/jbang/main/CamelJBang.java b/dsl/camel-jbang/camel-jbang-main/src/main/jbang/main/CamelJBang.java index a52dcb0..9e36eca 100755 --- a/dsl/camel-jbang/camel-jbang-main/src/main/jbang/main/CamelJBang.java +++ b/dsl/camel-jbang/camel-jbang-main/src/main/jbang/main/CamelJBang.java @@ -20,6 +20,7 @@ //REPOS mavencentral,apache=https://repository.apache.org/snapshots //DEPS org.apache.camel:camel-bom:${camel.jbang.version:RELEASE}@pom //DEPS org.apache.camel:camel-jbang-core:${camel.jbang.version:RELEASE} +//DEPS org.apache.camel.kamelets:camel-kamelets:${camel-kamelets.version:RELEASE} package main;
[GitHub] [camel] orpiske merged pull request #6490: CAMEL-17248: added camel-kamelets as a runtime dependency for camel-jbang
orpiske merged pull request #6490: URL: https://github.com/apache/camel/pull/6490 -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-karavan] mgubaidullin merged pull request #135: App dev folders
mgubaidullin merged pull request #135: URL: https://github.com/apache/camel-karavan/pull/135 -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-karavan] branch main updated: App dev folders (#135)
This is an automated email from the ASF dual-hosted git repository. marat pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-karavan.git The following commit(s) were added to refs/heads/main by this push: new 049079c App dev folders (#135) 049079c is described below commit 049079c2342015d586ab7a82c53877b13b42c7d1 Author: Marat Gubaidullin AuthorDate: Mon Nov 29 14:34:36 2021 -0500 App dev folders (#135) * App dev folders * App dev folders --- karavan-app/src/main/resources/application.properties | 2 ++ 1 file changed, 2 insertions(+) diff --git a/karavan-app/src/main/resources/application.properties b/karavan-app/src/main/resources/application.properties index 41e6fbc..b0e72de 100644 --- a/karavan-app/src/main/resources/application.properties +++ b/karavan-app/src/main/resources/application.properties @@ -2,10 +2,12 @@ karavan.version=${project.version} karavan.folder.components=components karavan.folder.kamelets-buildin=kamelets-buildin +%dev.karavan.folder.kamelets-buildin=target/classes/kamelets karavan.folder.kamelets-custom=kamelets karavan.mode=local karavan.folder.integrations=integrations +%dev.karavan.folder.integrations=target/classes/integrations #karavan.mode=serverless
[GitHub] [camel-website] djencks opened a new pull request #698: (currently for preview) add kamelets 0.5.x
djencks opened a new pull request #698: URL: https://github.com/apache/camel-website/pull/698 Add 0.5.x kamelets to docs. I think there are more versions being used, e.g. I think camel-kaka-connector uses version 0.3.x, but lets start here. -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kamelets] djencks opened a new pull request #591: 0.5.x update versions for publication
djencks opened a new pull request #591: URL: https://github.com/apache/camel-kamelets/pull/591 See https://github.com/apache/camel-website/issues/693 -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] orpiske opened a new pull request #6490: CAMEL-17248: added camel-kamelets as a runtime dependency for camel-jbang
orpiske opened a new pull request #6490: URL: https://github.com/apache/camel/pull/6490 -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] ppalaga commented on issue #3302: Better control what we manage in our BOM
ppalaga commented on issue #3302: URL: https://github.com/apache/camel-quarkus/issues/3302#issuecomment-981851249 4. We should get more control over the transitive dependencies. We should probably manage as much as possible, perhaps on cost of removing some extensions that are hard to adapt. E.g. our extensions are currently pulling as much as six different versions of `org.xerial.snappy:snappy-java`. It could probably be one by managing it properly in our BOM. -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] ppalaga opened a new issue #3347: Allow Camel K to use Quarkus Platform BOMs
ppalaga opened a new issue #3347: URL: https://github.com/apache/camel-quarkus/issues/3347 It might be practical for Camel K to rely on Quarkus Platform BOMs instead of Camel Quarkus BOM, mainly to be able to consume security updates that are available only via Quarkus Platform. To make this possible, we need to: 1. Manage org.jooq:joor in Camel Quarkus BOM 2. Pass camel-quarkus-integration-test-java-joor-dsl to the platform in spite it is JVM-only (the platform will have to be able to handle the fact) 3. Manage camel-quarkus-catalog in camel-quarkus-bom -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] zbendhiba commented on pull request #3311: Bump Optaplanner version to 8.13.0.Final
zbendhiba commented on pull request #3311: URL: https://github.com/apache/camel-quarkus/pull/3311#issuecomment-981748794 If we are okay to merge this. I will upgrade to the latest version bumped into platform, which is 8.14.0.Final, and rebase main. -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch regen_bot updated (e012412 -> a1cd467)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. from e012412 CAMEL-17241: fixed incorrect exception test add a1cd467 CAMEL-17245: prevent bogus commit calls when shutting down camel-kafka No new revisions were added by this update. Summary of changes: .../java/org/apache/camel/component/kafka/KafkaFetchRecords.java| 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-)
[camel] branch regen_bot updated (073aa49 -> e012412)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. from 073aa49 CAMEL-17244: avoid creating multiple consumers if already connected add e012412 CAMEL-17241: fixed incorrect exception test No new revisions were added by this update. Summary of changes: .../java/org/apache/camel/component/kafka/KafkaProducerTest.java | 7 --- 1 file changed, 4 insertions(+), 3 deletions(-)
[camel-website] branch asf-site updated (58bcc6d -> ac1944c)
This is an automated email from the ASF dual-hosted git repository. git-site-role pushed a change to branch asf-site in repository https://gitbox.apache.org/repos/asf/camel-website.git. discard 58bcc6d Website updated to 49b7cb8e17c33e82c0b4e297c23ee1156da90365 discard 5279092 Website updated to 325e929157412b27394080f4d4dba3d821476ddf new 886a56f Website updated to 325e929157412b27394080f4d4dba3d821476ddf new ac1944c Website updated to d9ec5591a433557fa61a4cf8b502a39c01550311 This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the branch are not in the new version. This situation occurs when a user --force pushes a change and generates a repository containing something like this: * -- * -- B -- O -- O -- O (58bcc6d) \ N -- N -- N refs/heads/asf-site (ac1944c) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .htaccess | 52 +- download/index.html|2 +- index.xml | 27 + releases/index.html|2 +- releases/index.xml | 27 + releases/kamelets-0.3.0/index.html |4 + releases/kamelets-0.4.0/index.html |4 + releases/kamelets-0.5.0/index.html |4 + sitemap-camel-k.xml| 822 ++--- sitemap-camel-kafka-connector.xml | 2218 ++-- sitemap-camel-kamelets.xml | 282 +- sitemap-camel-karaf.xml| 70 +- sitemap-camel-quarkus.xml | 2078 +-- sitemap-camel-spring-boot.xml | 54 +- sitemap-components.xml | 6712 ++-- sitemap-manual.xml | 382 +- sitemap-website.xml|9 + 17 files changed, 6412 insertions(+), 6337 deletions(-) create mode 100644 releases/kamelets-0.3.0/index.html create mode 100644 releases/kamelets-0.4.0/index.html create mode 100644 releases/kamelets-0.5.0/index.html
[camel-website] branch asf-site updated (44d2aa1 -> 58bcc6d)
This is an automated email from the ASF dual-hosted git repository. git-site-role pushed a change to branch asf-site in repository https://gitbox.apache.org/repos/asf/camel-website.git. discard 44d2aa1 Website updated to 700c6a779b32b161ae76dd396d6fd129a7d0f614 discard ee294a7 Website updated to 325e929157412b27394080f4d4dba3d821476ddf new 5279092 Website updated to 325e929157412b27394080f4d4dba3d821476ddf new 58bcc6d Website updated to 49b7cb8e17c33e82c0b4e297c23ee1156da90365 This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the branch are not in the new version. This situation occurs when a user --force pushes a change and generates a repository containing something like this: * -- * -- B -- O -- O -- O (44d2aa1) \ N -- N -- N refs/heads/asf-site (58bcc6d) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .htaccess | 52 +- camel-k/next/traits/container.html |2 +- camel-k/next/traits/gc.html|2 +- camel-k/next/traits/quarkus.html |2 +- camel-spring-boot/next/list.html |2 +- components/next/activemq-component.html|2 +- components/next/ahc-component.html |2 +- components/next/ahc-ws-component.html |2 +- components/next/amqp-component.html|2 +- components/next/arangodb-component.html|2 +- components/next/as2-component.html |2 +- components/next/asterisk-component.html|2 +- components/next/atlasmap-component.html|2 +- components/next/atmos-component.html |2 +- .../next/atmosphere-websocket-component.html |2 +- components/next/atom-component.html|2 +- components/next/atomix-map-component.html |2 +- components/next/atomix-messaging-component.html|2 +- components/next/atomix-multimap-component.html |2 +- components/next/atomix-queue-component.html|2 +- components/next/atomix-set-component.html |2 +- components/next/atomix-value-component.html|2 +- components/next/avro-component.html|2 +- components/next/aws-secrets-manager-component.html |2 +- components/next/aws-summary.html |2 +- components/next/aws2-athena-component.html |2 +- components/next/aws2-cw-component.html |2 +- components/next/aws2-ddb-component.html|2 +- components/next/aws2-ddbstream-component.html |2 +- components/next/aws2-ec2-component.html|2 +- components/next/aws2-ecs-component.html|2 +- components/next/aws2-eks-component.html|2 +- components/next/aws2-eventbridge-component.html|2 +- components/next/aws2-iam-component.html|2 +- components/next/aws2-kinesis-component.html|2 +- .../next/aws2-kinesis-firehose-component.html |2 +- components/next/aws2-kms-component.html|2 +- components/next/aws2-lambda-component.html |2 +- components/next/aws2-mq-component.html |2 +- components/next/aws2-msk-component.html|2 +- components/next/aws2-s3-component.html |2 +- components/next/aws2-ses-component.html|2 +- components/next/aws2-sns-component.html|2 +- components/next/aws2-sqs-component.html|2 +- components/next/aws2-sts-component.html|2 +- components/next/aws2-translate-component.html |2 +- components/next/azure-cosmosdb-component.html |2 +- components/next/azure-eventhubs-component.html |2 +- components/next/azure-servicebus-component.html|2 +- components/next/azure-storage-blob-component.html |2 +- .../next/azure-storage-datalake-component.html |6 +- components/next/azure-storage-queue-component.html |2 +- components/next/azure-summary.html |2 +- components/next/bean-component.html|2 +- components/next/bean-validator-component.html |2 +- components/next/beanstalk-component.html |2 +- components/next/bonita-component.html |2 +-
[camel] branch main updated: CAMEL-17245: prevent bogus commit calls when shutting down camel-kafka
This is an automated email from the ASF dual-hosted git repository. orpiske pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git The following commit(s) were added to refs/heads/main by this push: new a1cd467 CAMEL-17245: prevent bogus commit calls when shutting down camel-kafka a1cd467 is described below commit a1cd4677f38cd73ee3bebd2f1011efa821fada1a Author: Otavio Rodolfo Piske AuthorDate: Mon Nov 29 14:08:26 2021 +0100 CAMEL-17245: prevent bogus commit calls when shutting down camel-kafka --- .../java/org/apache/camel/component/kafka/KafkaFetchRecords.java| 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java index ec51f5d..61fb686 100644 --- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java +++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java @@ -99,7 +99,7 @@ class KafkaFetchRecords implements Runnable { } startPolling(); -} while (isRetrying() || isReconnect()); +} while ((isRetrying() || isReconnect()) && isKafkaConsumerRunnable()); LOG.info("Terminating KafkaConsumer thread: {} receiving from topic: {}", threadId, topicName); safeUnsubscribe(); @@ -166,7 +166,7 @@ class KafkaFetchRecords implements Runnable { KafkaRecordProcessor kafkaRecordProcessor = buildKafkaRecordProcessor(); Duration pollDuration = Duration.ofMillis(pollTimeoutMs); -while (isKafkaConsumerRunnable() && isRetrying() && !isReconnect()) { +while (isKafkaConsumerRunnable() && isRetrying() && isConnected()) { ConsumerRecords allRecords = consumer.poll(pollDuration); processAsyncCommits(); @@ -174,7 +174,7 @@ class KafkaFetchRecords implements Runnable { partitionLastOffset = processPolledRecords(allRecords, kafkaRecordProcessor); } -if (!isReconnect()) { +if (!isConnected()) { LOG.debug("Not reconnecting, check whether to auto-commit or not ..."); commit(); }
[GitHub] [camel] orpiske merged pull request #6489: CAMEL-17245: prevent bogus commit calls when shutting down camel-kafka
orpiske merged pull request #6489: URL: https://github.com/apache/camel/pull/6489 -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] zregvart merged pull request #697: chore: add releases for Kamelets subproject
zregvart merged pull request #697: URL: https://github.com/apache/camel-website/pull/697 -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] zregvart closed issue #694: Show kamelets on the download page
zregvart closed issue #694: URL: https://github.com/apache/camel-website/issues/694 -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-website] branch main updated: chore: add releases for Kamelets subproject
This is an automated email from the ASF dual-hosted git repository. zregvart pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-website.git The following commit(s) were added to refs/heads/main by this push: new d9ec559 chore: add releases for Kamelets subproject d9ec559 is described below commit d9ec5591a433557fa61a4cf8b502a39c01550311 Author: Zoran Regvart AuthorDate: Mon Nov 29 13:54:16 2021 +0100 chore: add releases for Kamelets subproject Fixes #694 --- content/releases/kamelets/release-0.3.0.md| 10 ++ content/releases/kamelets/release-0.4.0.md| 10 ++ content/releases/kamelets/release-0.5.0.md| 10 ++ data/release-categories.yaml | 15 +-- layouts/partials/releases/camel-kamelets.html | 11 +++ 5 files changed, 54 insertions(+), 2 deletions(-) diff --git a/content/releases/kamelets/release-0.3.0.md b/content/releases/kamelets/release-0.3.0.md new file mode 100644 index 000..d36a124 --- /dev/null +++ b/content/releases/kamelets/release-0.3.0.md @@ -0,0 +1,10 @@ +--- +url: "/releases/kamelets-0.3.0/" +date: 2021-07-01 +type: release-note +version: "0.3.0" +title: "Kamelets 0.3.0" +preview: "" +changelog: "" +category: "camel-kamelets" +--- diff --git a/content/releases/kamelets/release-0.4.0.md b/content/releases/kamelets/release-0.4.0.md new file mode 100644 index 000..9526974 --- /dev/null +++ b/content/releases/kamelets/release-0.4.0.md @@ -0,0 +1,10 @@ +--- +url: "/releases/kamelets-0.4.0/" +date: 2021-09-01 +type: release-note +version: "0.4.0" +title: "Kamelets 0.4.0" +preview: "" +changelog: "" +category: "camel-kamelets" +--- diff --git a/content/releases/kamelets/release-0.5.0.md b/content/releases/kamelets/release-0.5.0.md new file mode 100644 index 000..f65b9d2 --- /dev/null +++ b/content/releases/kamelets/release-0.5.0.md @@ -0,0 +1,10 @@ +--- +url: "/releases/kamelets-0.5.0/" +date: 2021-11-09 +type: release-note +version: "0.5.0" +title: "Kamelets 0.5.0" +preview: "" +changelog: "" +category: "camel-kamelets" +--- diff --git a/data/release-categories.yaml b/data/release-categories.yaml index 5a1dc06..6330dd0 100644 --- a/data/release-categories.yaml +++ b/data/release-categories.yaml @@ -70,10 +70,21 @@ camel-k-runtime: - name: 'Sources' path_format: 'camel/camel-k-runtime/{version}/apache-camel-k-runtime-{version}-source-release.zip' filename_format: 'apache-camel-k-runtime-{version}-source-release.zip' +camel-kamelets: + id: 'camel-kamelets' + name: 'Apache Camel Kamelets' + order: 4 + kinds: +- name: 'latest' + filter: 'latest' + downloads: +- name: 'Sources' + path_format: 'camel/camel-kamelets/{version}/camel-kamelets-sources-{version}.tar.gz' + filename_format: 'camel-kamelets-sources-{version}.tar.gz' camel-kafka-connector: id: 'camel-kafka-connector' name: 'Apache Camel Kafka Connector' - order: 4 + order: 5 kinds: - name: 'latest' filter: 'latest' @@ -87,7 +98,7 @@ camel-kafka-connector: camel-quarkus: id: 'camel-quarkus' name: 'Apache Camel Quarkus' - order: 5 + order: 6 kinds: - name: 'latest' filter: 'latest' diff --git a/layouts/partials/releases/camel-kamelets.html b/layouts/partials/releases/camel-kamelets.html new file mode 100644 index 000..71ba3f4 --- /dev/null +++ b/layouts/partials/releases/camel-kamelets.html @@ -0,0 +1,11 @@ +{{ partial "releases/downloads.html" (dict "Category" (index (index $.Site.Data "release-categories") "camel-kamelets") "Pages" $.Site.Pages "Version" .Params.version) }} + +Git tag checkout + + Release is tagged with v{{ .Params.version }} in the Git, to fetch it use: + + +git clone https://git-wip-us.apache.org/repos/asf/camel-kamelets.git +cd camel-kamelets +git checkout v{{ .Params.version }} +
[GitHub] [camel-website] zregvart commented on pull request #697: chore: add releases for Kamelets subproject
zregvart commented on pull request #697: URL: https://github.com/apache/camel-website/pull/697#issuecomment-981666392 Preview looks good. -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] github-actions[bot] commented on pull request #697: chore: add releases for Kamelets subproject
github-actions[bot] commented on pull request #697: URL: https://github.com/apache/camel-website/pull/697#issuecomment-981665140 Preview is available at https://pr-697--camel.netlify.app -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] zregvart merged pull request #696: fix: GitHub API authantication
zregvart merged pull request #696: URL: https://github.com/apache/camel-website/pull/696 -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-website] branch main updated: fix: GitHub API authantication
This is an automated email from the ASF dual-hosted git repository. zregvart pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-website.git The following commit(s) were added to refs/heads/main by this push: new 49b7cb8 fix: GitHub API authantication 49b7cb8 is described below commit 49b7cb8e17c33e82c0b4e297c23ee1156da90365 Author: Zoran Regvart AuthorDate: Mon Nov 29 13:49:11 2021 +0100 fix: GitHub API authantication Seems that we're sending the `Authorization` header without the leading `Basic ` in the header value. For some reason this seems to have worked in the past and it most recently stopped working, leading to issues with running previews locally. This adds the leading `Basic ` to the `Authorization` header. --- layouts/blog/post.html | 2 +- layouts/blog/summary.html| 2 +- layouts/partials/releases/camel-k-runtime.html | 2 +- layouts/partials/releases/camel-k.html | 2 +- layouts/partials/releases/camel-kafka-connector.html | 2 +- layouts/partials/releases/camel-quarkus.html | 2 +- 6 files changed, 6 insertions(+), 6 deletions(-) diff --git a/layouts/blog/post.html b/layouts/blog/post.html index 7f47c48..87e615b 100644 --- a/layouts/blog/post.html +++ b/layouts/blog/post.html @@ -13,7 +13,7 @@ Posted on {{ dateFormat "January 2, 2006" .PublishDate }}, by {{ range $author := .Params.authors }} -{{ with getJSON "https://api.github.com/users/; $author (dict "Authorization" (printf "%s:%s" $.Site.Params.GitHubUsername $.Site.Params.GitHubToken | base64Encode)) }} +{{ with getJSON "https://api.github.com/users/; $author (dict "Authorization" (printf "Basic %s" (printf "%s:%s" $.Site.Params.GitHubUsername $.Site.Params.GitHubToken | base64Encode))) }} {{ .name }} diff --git a/layouts/blog/summary.html b/layouts/blog/summary.html index c566544..b260ffc 100644 --- a/layouts/blog/summary.html +++ b/layouts/blog/summary.html @@ -2,7 +2,7 @@ {{ .Title }} -{{ dateFormat "January 2, 2006" .PublishDate }}, by {{ range $idx, $author := .Params.authors }}{{ if gt $idx 0 }}, {{ end }}{{ (getJSON "https://api.github.com/users/; $author (dict "Authorization" (printf "%s:%s" $.Site.Params.GitHubUsername $.Site.Params.GitHubToken | base64Encode))).name }}{{ end }} +{{ dateFormat "January 2, 2006" .PublishDate }}, by {{ range $idx, $author := .Params.authors }}{{ if gt $idx 0 }}, {{ end }}{{ (getJSON "https://api.github.com/users/; $author (dict "Authorization" (printf "Basic %s" (printf "%s:%s" $.Site.Params.GitHubUsername $.Site.Params.GitHubToken | base64Encode.name [...] {{ .Summary }} Continue reading diff --git a/layouts/partials/releases/camel-k-runtime.html b/layouts/partials/releases/camel-k-runtime.html index 5c2e04f..379e880 100644 --- a/layouts/partials/releases/camel-k-runtime.html +++ b/layouts/partials/releases/camel-k-runtime.html @@ -11,7 +11,7 @@ git checkout camel-k-runtime-parent-{{ .Params.version }} Resolved issues Here is a list of all the issues that have been resolved for this release -{{ $issues := getJSON "https://api.github.com/repos/apache/camel-k-runtime/issues?state=closed=; (string .Params.milestone ) (dict "Authorization" (printf "%s:%s" $.Site.Params.GitHubUsername $.Site.Params.GitHubToken | base64Encode)) }} +{{ $issues := getJSON "https://api.github.com/repos/apache/camel-k-runtime/issues?state=closed=; (string .Params.milestone ) (dict "Authorization" (printf "Basic %s" (printf "%s:%s" $.Site.Params.GitHubUsername $.Site.Params.GitHubToken | base64Encode))) }} {{ range $issues }} #{{ .number }}{{ .title }} diff --git a/layouts/partials/releases/camel-k.html b/layouts/partials/releases/camel-k.html index 0f5cce7..7478c5c 100644 --- a/layouts/partials/releases/camel-k.html +++ b/layouts/partials/releases/camel-k.html @@ -11,7 +11,7 @@ git checkout v{{ .Params.version }} Resolved issues Here is a list of all the issues that have been resolved for this release -{{ $issues := getJSON "https://api.github.com/repos/apache/camel-k/issues?state=closed=; (string .Params.milestone) (dict "Authorization" (printf "%s:%s" $.Site.Params.GitHubUsername $.Site.Params.GitHubToken | base64Encode)) }} +{{ $issues := getJSON "https://api.github.com/repos/apache/camel-k/issues?state=closed=; (string .Params.milestone) (dict "Authorization" (printf "Basic %s" (printf "%s:%s" $.Site.Params.GitHubUsername $.Site.Params.GitHubToken | base64Encode))) }} {{ range $issues }} #{{ .number }}{{ .title }} diff --git a/layouts/partials/releases/camel-kafka-connector.html b/layouts/partials/releases/camel-kafka-connector.html index 1a98aae..acad116 100644 --- a/layouts/partials/releases/camel-kafka-connector.html +++
[GitHub] [camel-website] github-actions[bot] commented on pull request #696: fix: GitHub API authantication
github-actions[bot] commented on pull request #696: URL: https://github.com/apache/camel-website/pull/696#issuecomment-981656703 Preview is available at https://pr-696--camel.netlify.app -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch main updated: CAMEL-17241: fixed incorrect exception test
This is an automated email from the ASF dual-hosted git repository. orpiske pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git The following commit(s) were added to refs/heads/main by this push: new e012412 CAMEL-17241: fixed incorrect exception test e012412 is described below commit e0124120e119c516b97f6235a16b8b07d91412b5 Author: Otavio Rodolfo Piske AuthorDate: Fri Nov 26 13:28:56 2021 +0100 CAMEL-17241: fixed incorrect exception test --- .../java/org/apache/camel/component/kafka/KafkaProducerTest.java | 7 --- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java index aac2425..3e287ee 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java @@ -128,15 +128,16 @@ public class KafkaProducerTest { @Test @SuppressWarnings({ "unchecked" }) -public void processSendsMessageWithException() throws Exception { +public void processSendsMessageWithException() { endpoint.getConfiguration().setTopic("sometopic"); // setup the exception here org.apache.kafka.clients.producer.KafkaProducer kp = producer.getKafkaProducer(); Mockito.when(kp.send(any(ProducerRecord.class))).thenThrow(new ApiException()); Mockito.when(exchange.getIn()).thenReturn(in); +Mockito.when(exchange.getMessage()).thenReturn(in); in.setHeader(KafkaConstants.PARTITION_KEY, 4); -assertThrows(Exception.class, +assertThrows(ApiException.class, () -> producer.process(exchange)); } @@ -158,7 +159,7 @@ public class KafkaProducerTest { } @Test -public void processAsyncSendsMessageWithException() throws Exception { +public void processAsyncSendsMessageWithException() { endpoint.getConfiguration().setTopic("sometopic"); Mockito.when(exchange.getIn()).thenReturn(in); Mockito.when(exchange.getMessage()).thenReturn(in);
[GitHub] [camel] orpiske merged pull request #6488: CAMEL-17241: fixed incorrect exception test
orpiske merged pull request #6488: URL: https://github.com/apache/camel/pull/6488 -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch regen_bot updated (507ecfb -> 073aa49)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. from 507ecfb CAMEL-17246: camel-health - Failure endpoint uri should be sanitized. add 073aa49 CAMEL-17244: avoid creating multiple consumers if already connected No new revisions were added by this update. Summary of changes: .../camel/component/kafka/KafkaFetchRecords.java | 32 -- 1 file changed, 23 insertions(+), 9 deletions(-)
[GitHub] [camel-k] squakez commented on issue #2791: Makefile: for the generate-doc target don't use show-progress for wget
squakez commented on issue #2791: URL: https://github.com/apache/camel-k/issues/2791#issuecomment-981636968 No problem. I introduced it just for the sake of debugging, we can remove. -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] orpiske opened a new pull request #6489: CAMEL-17245: prevent bogus commit calls when shutting down camel-kafka
orpiske opened a new pull request #6489: URL: https://github.com/apache/camel/pull/6489 -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-k] oscerd merged pull request #2790: Fix doc port name
oscerd merged pull request #2790: URL: https://github.com/apache/camel-k/pull/2790 -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-k] branch main updated (00de85f -> f883a6c)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/camel-k.git. from 00de85f Updated CHANGELOG.md new 5648e46 Default value of trait container.port-name is missing from catalog new f883a6c Regen docs The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: docs/modules/traits/pages/container.adoc | 2 +- docs/modules/traits/pages/gc.adoc| 2 +- docs/modules/traits/pages/quarkus.adoc | 2 +- pkg/trait/container.go | 2 +- resources/traits.yaml| 8 5 files changed, 8 insertions(+), 8 deletions(-)
[GitHub] [camel-k] oscerd closed issue #2761: Default value of trait container.port-name is missing from catalog
oscerd closed issue #2761: URL: https://github.com/apache/camel-k/issues/2761 -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-k] 01/02: Default value of trait container.port-name is missing from catalog
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-k.git commit 5648e465c712502e7cabd98efd6ce041aaddf7d9 Author: Andrea Cosentino AuthorDate: Mon Nov 29 12:49:31 2021 +0100 Default value of trait container.port-name is missing from catalog --- pkg/trait/container.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/trait/container.go b/pkg/trait/container.go index 7ae6164..cefacf8 100644 --- a/pkg/trait/container.go +++ b/pkg/trait/container.go @@ -68,7 +68,7 @@ type containerTrait struct { Expose *bool `property:"expose" json:"expose,omitempty"` // To configure a different port exposed by the container (default `8080`). Port int `property:"port" json:"port,omitempty"` - // To configure a different port name for the port exposed by the container (default `http`). + // To configure a different port name for the port exposed by the container. it defaults to `http` only when the `expose` parameter is true. PortName string `property:"port-name" json:"portName,omitempty"` // To configure under which service port the container port is to be exposed (default `80`). ServicePort int `property:"service-port" json:"servicePort,omitempty"`
[camel-k] 02/02: Regen docs
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-k.git commit f883a6c55b3a2852b3b44af9146a072f46c9bfb9 Author: Andrea Cosentino AuthorDate: Mon Nov 29 12:58:55 2021 +0100 Regen docs --- docs/modules/traits/pages/container.adoc | 2 +- docs/modules/traits/pages/gc.adoc| 2 +- docs/modules/traits/pages/quarkus.adoc | 2 +- pkg/trait/container.go | 2 +- resources/traits.yaml| 8 5 files changed, 8 insertions(+), 8 deletions(-) diff --git a/docs/modules/traits/pages/container.adoc b/docs/modules/traits/pages/container.adoc index a214ccf..1934134 100755 --- a/docs/modules/traits/pages/container.adoc +++ b/docs/modules/traits/pages/container.adoc @@ -60,7 +60,7 @@ The following configuration options are available: | container.port-name | string -| To configure a different port name for the port exposed by the container (default `http`). +| To configure a different port name for the port exposed by the container. It defaults to `http` only when the `expose` parameter is true. | container.service-port | int diff --git a/docs/modules/traits/pages/gc.adoc b/docs/modules/traits/pages/gc.adoc index 375057d..c7a9ee8 100755 --- a/docs/modules/traits/pages/gc.adoc +++ b/docs/modules/traits/pages/gc.adoc @@ -26,7 +26,7 @@ The following configuration options are available: | Can be used to enable or disable a trait. All traits share this common property. | gc.discovery-cache -| ./pkg/trait.discoveryCacheType +| github.com/apache/camel-k/pkg/trait.discoveryCacheType | Discovery client cache to be used, either `disabled`, `disk` or `memory` (default `memory`) |=== diff --git a/docs/modules/traits/pages/quarkus.adoc b/docs/modules/traits/pages/quarkus.adoc index 0ddf3ef..e9d579e 100755 --- a/docs/modules/traits/pages/quarkus.adoc +++ b/docs/modules/traits/pages/quarkus.adoc @@ -36,7 +36,7 @@ The following configuration options are available: | Can be used to enable or disable a trait. All traits share this common property. | quarkus.package-type -| []./pkg/trait.quarkusPackageType +| []github.com/apache/camel-k/pkg/trait.quarkusPackageType | The Quarkus package types, either `fast-jar` or `native` (default `fast-jar`). In case both `fast-jar` and `native` are specified, two `IntegrationKit` resources are created, with the `native` kit having precedence over the `fast-jar` one once ready. diff --git a/pkg/trait/container.go b/pkg/trait/container.go index cefacf8..d9eae9e 100644 --- a/pkg/trait/container.go +++ b/pkg/trait/container.go @@ -68,7 +68,7 @@ type containerTrait struct { Expose *bool `property:"expose" json:"expose,omitempty"` // To configure a different port exposed by the container (default `8080`). Port int `property:"port" json:"port,omitempty"` - // To configure a different port name for the port exposed by the container. it defaults to `http` only when the `expose` parameter is true. + // To configure a different port name for the port exposed by the container. It defaults to `http` only when the `expose` parameter is true. PortName string `property:"port-name" json:"portName,omitempty"` // To configure under which service port the container port is to be exposed (default `80`). ServicePort int `property:"service-port" json:"servicePort,omitempty"` diff --git a/resources/traits.yaml b/resources/traits.yaml index a19f164..b2041ba 100755 --- a/resources/traits.yaml +++ b/resources/traits.yaml @@ -113,8 +113,8 @@ traits: description: To configure a different port exposed by the container (default `8080`). - name: port-name type: string -description: To configure a different port name for the port exposed by the container - (default `http`). +description: To configure a different port name for the port exposed by the container. + It defaults to `http` only when the `expose` parameter is true. - name: service-port type: int description: To configure under which service port the container port is to be @@ -349,7 +349,7 @@ traits: description: Can be used to enable or disable a trait. All traits share this common property. - name: discovery-cache -type: ./pkg/trait.discoveryCacheType +type: github.com/apache/camel-k/pkg/trait.discoveryCacheType description: Discovery client cache to be used, either `disabled`, `disk` or `memory` (default `memory`) - name: health @@ -919,7 +919,7 @@ traits: description: Can be used to enable or disable a trait. All traits share this common property. - name: package-type -type: '[]./pkg/trait.quarkusPackageType' +type: '[]github.com/apache/camel-k/pkg/trait.quarkusPackageType' description: The Quarkus package types, either `fast-jar` or `native` (default `fast-jar`).In case both
[GitHub] [camel-website] zregvart opened a new pull request #697: chore: add releases for Kamelets subproject
zregvart opened a new pull request #697: URL: https://github.com/apache/camel-website/pull/697 Fixes #694 -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] davsclaus commented on a change in pull request #695: #686: Add icon to Apache Camel group on Linkedin
davsclaus commented on a change in pull request #695: URL: https://github.com/apache/camel-website/pull/695#discussion_r758333662 ## File path: antora-ui-camel/src/img/brand-logos.svg ## @@ -20,4 +20,9 @@ Chat on Zulip + +Linkedin +Apache Camel group on Linkedin + Review comment: Okay so the icon works - and we can replace it with an actual linkedin icon. -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] zregvart commented on a change in pull request #695: #686: Add icon to Apache Camel group on Linkedin
zregvart commented on a change in pull request #695: URL: https://github.com/apache/camel-website/pull/695#discussion_r758332313 ## File path: antora-ui-camel/src/img/brand-logos.svg ## @@ -20,4 +20,9 @@ Chat on Zulip + +Linkedin +Apache Camel group on Linkedin + Review comment: Preview is correct. The copy pasted Zulip icon has geometry that is outside of the viewbox, even if it was shown it would be confusing to the users to see two icons for Zulip. -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] zregvart opened a new pull request #696: fix: GitHub API authantication
zregvart opened a new pull request #696: URL: https://github.com/apache/camel-website/pull/696 Seems that we're sending the `Authorization` header without the leading `Basic ` in the header value. For some reason this seems to have worked in the past and it most recently stopped working, leading to issues with running previews locally. This adds the leading `Basic ` to the `Authorization` header. -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-website] 01/01: fix: GitHub API authantication
This is an automated email from the ASF dual-hosted git repository. zregvart pushed a commit to branch pr/fix-github-auth in repository https://gitbox.apache.org/repos/asf/camel-website.git commit 10d21fa4be74e7c595cf050c906cf0db39bfd41e Author: Zoran Regvart AuthorDate: Mon Nov 29 13:49:11 2021 +0100 fix: GitHub API authantication Seems that we're sending the `Authorization` header without the leading `Basic ` in the header value. For some reason this seems to have worked in the past and it most recently stopped working, leading to issues with running previews locally. This adds the leading `Basic ` to the `Authorization` header. --- layouts/blog/post.html | 2 +- layouts/blog/summary.html| 2 +- layouts/partials/releases/camel-k-runtime.html | 2 +- layouts/partials/releases/camel-k.html | 2 +- layouts/partials/releases/camel-kafka-connector.html | 2 +- layouts/partials/releases/camel-quarkus.html | 2 +- 6 files changed, 6 insertions(+), 6 deletions(-) diff --git a/layouts/blog/post.html b/layouts/blog/post.html index 7f47c48..87e615b 100644 --- a/layouts/blog/post.html +++ b/layouts/blog/post.html @@ -13,7 +13,7 @@ Posted on {{ dateFormat "January 2, 2006" .PublishDate }}, by {{ range $author := .Params.authors }} -{{ with getJSON "https://api.github.com/users/; $author (dict "Authorization" (printf "%s:%s" $.Site.Params.GitHubUsername $.Site.Params.GitHubToken | base64Encode)) }} +{{ with getJSON "https://api.github.com/users/; $author (dict "Authorization" (printf "Basic %s" (printf "%s:%s" $.Site.Params.GitHubUsername $.Site.Params.GitHubToken | base64Encode))) }} {{ .name }} diff --git a/layouts/blog/summary.html b/layouts/blog/summary.html index c566544..b260ffc 100644 --- a/layouts/blog/summary.html +++ b/layouts/blog/summary.html @@ -2,7 +2,7 @@ {{ .Title }} -{{ dateFormat "January 2, 2006" .PublishDate }}, by {{ range $idx, $author := .Params.authors }}{{ if gt $idx 0 }}, {{ end }}{{ (getJSON "https://api.github.com/users/; $author (dict "Authorization" (printf "%s:%s" $.Site.Params.GitHubUsername $.Site.Params.GitHubToken | base64Encode))).name }}{{ end }} +{{ dateFormat "January 2, 2006" .PublishDate }}, by {{ range $idx, $author := .Params.authors }}{{ if gt $idx 0 }}, {{ end }}{{ (getJSON "https://api.github.com/users/; $author (dict "Authorization" (printf "Basic %s" (printf "%s:%s" $.Site.Params.GitHubUsername $.Site.Params.GitHubToken | base64Encode.name [...] {{ .Summary }} Continue reading diff --git a/layouts/partials/releases/camel-k-runtime.html b/layouts/partials/releases/camel-k-runtime.html index 5c2e04f..379e880 100644 --- a/layouts/partials/releases/camel-k-runtime.html +++ b/layouts/partials/releases/camel-k-runtime.html @@ -11,7 +11,7 @@ git checkout camel-k-runtime-parent-{{ .Params.version }} Resolved issues Here is a list of all the issues that have been resolved for this release -{{ $issues := getJSON "https://api.github.com/repos/apache/camel-k-runtime/issues?state=closed=; (string .Params.milestone ) (dict "Authorization" (printf "%s:%s" $.Site.Params.GitHubUsername $.Site.Params.GitHubToken | base64Encode)) }} +{{ $issues := getJSON "https://api.github.com/repos/apache/camel-k-runtime/issues?state=closed=; (string .Params.milestone ) (dict "Authorization" (printf "Basic %s" (printf "%s:%s" $.Site.Params.GitHubUsername $.Site.Params.GitHubToken | base64Encode))) }} {{ range $issues }} #{{ .number }}{{ .title }} diff --git a/layouts/partials/releases/camel-k.html b/layouts/partials/releases/camel-k.html index 0f5cce7..7478c5c 100644 --- a/layouts/partials/releases/camel-k.html +++ b/layouts/partials/releases/camel-k.html @@ -11,7 +11,7 @@ git checkout v{{ .Params.version }} Resolved issues Here is a list of all the issues that have been resolved for this release -{{ $issues := getJSON "https://api.github.com/repos/apache/camel-k/issues?state=closed=; (string .Params.milestone) (dict "Authorization" (printf "%s:%s" $.Site.Params.GitHubUsername $.Site.Params.GitHubToken | base64Encode)) }} +{{ $issues := getJSON "https://api.github.com/repos/apache/camel-k/issues?state=closed=; (string .Params.milestone) (dict "Authorization" (printf "Basic %s" (printf "%s:%s" $.Site.Params.GitHubUsername $.Site.Params.GitHubToken | base64Encode))) }} {{ range $issues }} #{{ .number }}{{ .title }} diff --git a/layouts/partials/releases/camel-kafka-connector.html b/layouts/partials/releases/camel-kafka-connector.html index 1a98aae..acad116 100644 --- a/layouts/partials/releases/camel-kafka-connector.html +++ b/layouts/partials/releases/camel-kafka-connector.html @@ -26,7 +26,7 @@ git checkout camel-kafka-connector-{{ .Params.version }} Resolved issues Here is a
[camel-website] branch pr/fix-github-auth created (now 10d21fa)
This is an automated email from the ASF dual-hosted git repository. zregvart pushed a change to branch pr/fix-github-auth in repository https://gitbox.apache.org/repos/asf/camel-website.git. at 10d21fa fix: GitHub API authantication This branch includes the following new commits: new 10d21fa fix: GitHub API authantication The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[GitHub] [camel] orpiske opened a new pull request #6488: CAMEL-17241: fixed incorrect exception test
orpiske opened a new pull request #6488: URL: https://github.com/apache/camel/pull/6488 -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] davsclaus commented on a change in pull request #695: #686: Add icon to Apache Camel group on Linkedin
davsclaus commented on a change in pull request #695: URL: https://github.com/apache/camel-website/pull/695#discussion_r758323709 ## File path: antora-ui-camel/src/img/brand-logos.svg ## @@ -20,4 +20,9 @@ Chat on Zulip + +Linkedin +Apache Camel group on Linkedin + Review comment: Since the icon is not shown on your end too, it may be something wrong with the preview mode, and that its shown on the real website. -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] davsclaus commented on a change in pull request #695: #686: Add icon to Apache Camel group on Linkedin
davsclaus commented on a change in pull request #695: URL: https://github.com/apache/camel-website/pull/695#discussion_r758322950 ## File path: antora-ui-camel/src/img/brand-logos.svg ## @@ -20,4 +20,9 @@ Chat on Zulip + +Linkedin +Apache Camel group on Linkedin + Review comment: Yes its a copy/paste of that icon, to ensure that a icon is shown. As I could not get it to show the linkedin icon. -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-k] oscerd opened a new issue #2791: Makefile: for the generate-doc target don't use show-progress for wget
oscerd opened a new issue #2791: URL: https://github.com/apache/camel-k/issues/2791 On old wget version show-progress won't work, it has been introduced on 1.16.2. I think it would be better to simply use the verbose option and removing the -q one. @astefanutti @squakez @nicolaferraro any thoughts? -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch main updated: CAMEL-17244: avoid creating multiple consumers if already connected
This is an automated email from the ASF dual-hosted git repository. orpiske pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git The following commit(s) were added to refs/heads/main by this push: new 073aa49 CAMEL-17244: avoid creating multiple consumers if already connected 073aa49 is described below commit 073aa4993086891fcd73421b11106e9a35945de2 Author: Otavio Rodolfo Piske AuthorDate: Mon Nov 29 10:59:11 2021 +0100 CAMEL-17244: avoid creating multiple consumers if already connected --- .../camel/component/kafka/KafkaFetchRecords.java | 32 -- 1 file changed, 23 insertions(+), 9 deletions(-) diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java index 2cc7e59..ec51f5d 100644 --- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java +++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java @@ -62,7 +62,8 @@ class KafkaFetchRecords implements Runnable { private final ConcurrentLinkedQueue asyncCommits = new ConcurrentLinkedQueue<>(); private boolean retry = true; -private boolean reconnect; // must be false at init +private boolean reconnect; // must be false at init (this is the policy whether to reconnect) +private boolean connected; // this is the state (connected or not) KafkaFetchRecords(KafkaConsumer kafkaConsumer, PollExceptionStrategy pollExceptionStrategy, BridgeExceptionHandlerToErrorHandler bridge, String topicName, Pattern topicPattern, String id, @@ -84,17 +85,21 @@ class KafkaFetchRecords implements Runnable { do { try { -createConsumer(); +if (!isConnected()) { +createConsumer(); -initializeConsumer(); +initializeConsumer(); +setConnected(true); +} } catch (Exception e) { +setConnected(false); // ensure this is logged so users can see the problem LOG.warn("Error creating org.apache.kafka.clients.consumer.KafkaConsumer due {}", e.getMessage(), e); continue; } startPolling(); -} while (isRetrying() || isReconnecting()); +} while (isRetrying() || isReconnect()); LOG.info("Terminating KafkaConsumer thread: {} receiving from topic: {}", threadId, topicName); safeUnsubscribe(); @@ -125,7 +130,7 @@ class KafkaFetchRecords implements Runnable { subscribe(); // set reconnect to false as the connection and resume is done at this point -setReconnect(false); +setConnected(false); // set retry to true to continue polling setRetry(true); @@ -161,7 +166,7 @@ class KafkaFetchRecords implements Runnable { KafkaRecordProcessor kafkaRecordProcessor = buildKafkaRecordProcessor(); Duration pollDuration = Duration.ofMillis(pollTimeoutMs); -while (isKafkaConsumerRunnable() && isRetrying() && !isReconnecting()) { +while (isKafkaConsumerRunnable() && isRetrying() && !isReconnect()) { ConsumerRecords allRecords = consumer.poll(pollDuration); processAsyncCommits(); @@ -169,7 +174,7 @@ class KafkaFetchRecords implements Runnable { partitionLastOffset = processPolledRecords(allRecords, kafkaRecordProcessor); } -if (!isReconnecting()) { +if (!isReconnect()) { LOG.debug("Not reconnecting, check whether to auto-commit or not ..."); commit(); } @@ -259,7 +264,7 @@ class KafkaFetchRecords implements Runnable { LOG.warn("Requesting the consumer to stop based on polling exception strategy"); setRetry(false); -setReconnect(false); +setConnected(false); } private void handlePollDiscard(long partitionLastOffset) { @@ -283,6 +288,7 @@ class KafkaFetchRecords implements Runnable { // re-connect so the consumer can try the same message again setReconnect(true); +setConnected(false); // to close the current consumer setRetry(false); @@ -339,6 +345,7 @@ class KafkaFetchRecords implements Runnable { LOG.debug("We hit an error ... setting flags to force reconnect"); // force re-connect setReconnect(true); +setConnected(false); setRetry(false); // to close the current consumer } @@ -430,7 +437,7 @@ class KafkaFetchRecords implements Runnable { retry = value; } -private boolean isReconnecting() { +private boolean isReconnect() {
[GitHub] [camel] orpiske merged pull request #6487: CAMEL-17244: avoid creating multiple consumers if already connected
orpiske merged pull request #6487: URL: https://github.com/apache/camel/pull/6487 -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch regen_bot updated (07bbdad -> 507ecfb)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. from 07bbdad Regen add 875f275 Polished add 7bd9eb0 CAMEL-17141: camel-health - Include error details for HTTP status code. add 876f871 CAMEL-17141: camel-health - Include error details for HTTP status code. add 1de2c6e CAMEL-17141: camel-health - Include error details for HTTP status code. add 507ecfb CAMEL-17246: camel-health - Failure endpoint uri should be sanitized. No new revisions were added by this update. Summary of changes: .../http/base/HttpOperationFailedException.java| 22 +++- .../component/telegram/TelegramException.java | 64 ++ .../service/TelegramServiceRestBotAPIAdapter.java | 7 ++- .../TelegramConsumerHealthCheckErrorTest.java | 29 ++ .../java/org/apache/camel/health/HealthCheck.java | 8 ++- .../org/apache/camel/health/HealthCheckHelper.java | 11 ++-- .../camel/health/HealthCheckResultBuilder.java | 1 + .../org/apache/camel/spi/HttpResponseAware.java| 23 .../camel/impl/health/ConsumerHealthCheck.java | 18 +- .../camel/management/mbean/ManagedCamelHealth.java | 2 +- .../camel/support/ScheduledPollConsumer.java | 57 +++ .../support/ScheduledPollConsumerHealthCheck.java | 26 ++--- 12 files changed, 226 insertions(+), 42 deletions(-) create mode 100644 components/camel-telegram/src/main/java/org/apache/camel/component/telegram/TelegramException.java copy components/camel-thrift/src/main/java/org/apache/camel/component/thrift/ThriftExchangeProtocol.java => core/camel-api/src/main/java/org/apache/camel/spi/HttpResponseAware.java (68%)
[GitHub] [camel-k] oscerd commented on a change in pull request #2790: Fix doc port name
oscerd commented on a change in pull request #2790: URL: https://github.com/apache/camel-k/pull/2790#discussion_r758304111 ## File path: pkg/trait/container.go ## @@ -68,7 +68,7 @@ type containerTrait struct { Expose *bool `property:"expose" json:"expose,omitempty"` // To configure a different port exposed by the container (default `8080`). Port int `property:"port" json:"port,omitempty"` - // To configure a different port name for the port exposed by the container (default `http`). + // To configure a different port name for the port exposed by the container. it defaults to `http` only when the `expose` parameter is true. Review comment: should be fine now. -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-k] branch fix-doc-port-name updated (dc4c2ce -> ad836fa)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch fix-doc-port-name in repository https://gitbox.apache.org/repos/asf/camel-k.git. omit dc4c2ce Regen documentation add ad836fa Regen docs This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the branch are not in the new version. This situation occurs when a user --force pushes a change and generates a repository containing something like this: * -- * -- B -- O -- O -- O (dc4c2ce) \ N -- N -- N refs/heads/fix-doc-port-name (ad836fa) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. No new revisions were added by this update. Summary of changes: docs/modules/traits/pages/container.adoc | 2 +- pkg/trait/container.go | 2 +- resources/traits.yaml| 2 +- 3 files changed, 3 insertions(+), 3 deletions(-)
[GitHub] [camel-k] squakez commented on a change in pull request #2790: Fix doc port name
squakez commented on a change in pull request #2790: URL: https://github.com/apache/camel-k/pull/2790#discussion_r758299429 ## File path: pkg/trait/container.go ## @@ -68,7 +68,7 @@ type containerTrait struct { Expose *bool `property:"expose" json:"expose,omitempty"` // To configure a different port exposed by the container (default `8080`). Port int `property:"port" json:"port,omitempty"` - // To configure a different port name for the port exposed by the container (default `http`). + // To configure a different port name for the port exposed by the container. it defaults to `http` only when the `expose` parameter is true. Review comment: Maybe uppercase here. "It defaults ..." -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-k] oscerd opened a new pull request #2790: Fix doc port name
oscerd opened a new pull request #2790: URL: https://github.com/apache/camel-k/pull/2790 Fixes #2761 **Release Note** ```release-note NONE ``` -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-k] branch fix-doc-port-name created (now dc4c2ce)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch fix-doc-port-name in repository https://gitbox.apache.org/repos/asf/camel-k.git. at dc4c2ce Regen documentation This branch includes the following new commits: new 265ffd1 Default value of trait container.port-name is missing from catalog new dc4c2ce Regen documentation The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[camel-k] 02/02: Regen documentation
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch fix-doc-port-name in repository https://gitbox.apache.org/repos/asf/camel-k.git commit dc4c2ce92e129fd4538b42df8cafaab47d6d1039 Author: Andrea Cosentino AuthorDate: Mon Nov 29 12:58:55 2021 +0100 Regen documentation --- docs/modules/traits/pages/container.adoc | 2 +- docs/modules/traits/pages/gc.adoc| 2 +- docs/modules/traits/pages/quarkus.adoc | 2 +- resources/traits.yaml| 8 4 files changed, 7 insertions(+), 7 deletions(-) diff --git a/docs/modules/traits/pages/container.adoc b/docs/modules/traits/pages/container.adoc index a214ccf..2618a64 100755 --- a/docs/modules/traits/pages/container.adoc +++ b/docs/modules/traits/pages/container.adoc @@ -60,7 +60,7 @@ The following configuration options are available: | container.port-name | string -| To configure a different port name for the port exposed by the container (default `http`). +| To configure a different port name for the port exposed by the container. it defaults to `http` only when the `expose` parameter is true. | container.service-port | int diff --git a/docs/modules/traits/pages/gc.adoc b/docs/modules/traits/pages/gc.adoc index 375057d..c7a9ee8 100755 --- a/docs/modules/traits/pages/gc.adoc +++ b/docs/modules/traits/pages/gc.adoc @@ -26,7 +26,7 @@ The following configuration options are available: | Can be used to enable or disable a trait. All traits share this common property. | gc.discovery-cache -| ./pkg/trait.discoveryCacheType +| github.com/apache/camel-k/pkg/trait.discoveryCacheType | Discovery client cache to be used, either `disabled`, `disk` or `memory` (default `memory`) |=== diff --git a/docs/modules/traits/pages/quarkus.adoc b/docs/modules/traits/pages/quarkus.adoc index 0ddf3ef..e9d579e 100755 --- a/docs/modules/traits/pages/quarkus.adoc +++ b/docs/modules/traits/pages/quarkus.adoc @@ -36,7 +36,7 @@ The following configuration options are available: | Can be used to enable or disable a trait. All traits share this common property. | quarkus.package-type -| []./pkg/trait.quarkusPackageType +| []github.com/apache/camel-k/pkg/trait.quarkusPackageType | The Quarkus package types, either `fast-jar` or `native` (default `fast-jar`). In case both `fast-jar` and `native` are specified, two `IntegrationKit` resources are created, with the `native` kit having precedence over the `fast-jar` one once ready. diff --git a/resources/traits.yaml b/resources/traits.yaml index a19f164..f1fea59 100755 --- a/resources/traits.yaml +++ b/resources/traits.yaml @@ -113,8 +113,8 @@ traits: description: To configure a different port exposed by the container (default `8080`). - name: port-name type: string -description: To configure a different port name for the port exposed by the container - (default `http`). +description: To configure a different port name for the port exposed by the container. + it defaults to `http` only when the `expose` parameter is true. - name: service-port type: int description: To configure under which service port the container port is to be @@ -349,7 +349,7 @@ traits: description: Can be used to enable or disable a trait. All traits share this common property. - name: discovery-cache -type: ./pkg/trait.discoveryCacheType +type: github.com/apache/camel-k/pkg/trait.discoveryCacheType description: Discovery client cache to be used, either `disabled`, `disk` or `memory` (default `memory`) - name: health @@ -919,7 +919,7 @@ traits: description: Can be used to enable or disable a trait. All traits share this common property. - name: package-type -type: '[]./pkg/trait.quarkusPackageType' +type: '[]github.com/apache/camel-k/pkg/trait.quarkusPackageType' description: The Quarkus package types, either `fast-jar` or `native` (default `fast-jar`).In case both `fast-jar` and `native` are specified, two `IntegrationKit` resources are created,with the `native` kit having precedence over the `fast-jar`
[camel-k] 01/02: Default value of trait container.port-name is missing from catalog
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch fix-doc-port-name in repository https://gitbox.apache.org/repos/asf/camel-k.git commit 265ffd1e99300fa07216775c135f8237327b7e7d Author: Andrea Cosentino AuthorDate: Mon Nov 29 12:49:31 2021 +0100 Default value of trait container.port-name is missing from catalog --- pkg/trait/container.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/trait/container.go b/pkg/trait/container.go index 7ae6164..cefacf8 100644 --- a/pkg/trait/container.go +++ b/pkg/trait/container.go @@ -68,7 +68,7 @@ type containerTrait struct { Expose *bool `property:"expose" json:"expose,omitempty"` // To configure a different port exposed by the container (default `8080`). Port int `property:"port" json:"port,omitempty"` - // To configure a different port name for the port exposed by the container (default `http`). + // To configure a different port name for the port exposed by the container. it defaults to `http` only when the `expose` parameter is true. PortName string `property:"port-name" json:"portName,omitempty"` // To configure under which service port the container port is to be exposed (default `80`). ServicePort int `property:"service-port" json:"servicePort,omitempty"`
[GitHub] [camel-website] zregvart commented on issue #694: Show kamelets on the download page
zregvart commented on issue #694: URL: https://github.com/apache/camel-website/issues/694#issuecomment-981561522 Archives [are available](https://dlcdn.apache.org/camel/camel-kamelets/). -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kamelets] zregvart closed issue #590: Provide source code release package
zregvart closed issue #590: URL: https://github.com/apache/camel-kamelets/issues/590 -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kamelets] zregvart commented on issue #590: Provide source code release package
zregvart commented on issue #590: URL: https://github.com/apache/camel-kamelets/issues/590#issuecomment-981561241 I see the [archives have been uploaded](https://dlcdn.apache.org/camel/camel-kamelets/), sorry for the confusion. -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] zregvart commented on issue #694: Show kamelets on the download page
zregvart commented on issue #694: URL: https://github.com/apache/camel-website/issues/694#issuecomment-981559045 I agree, per [ASF policy](https://www.apache.org/legal/release-policy.html#artifacts) every release must be accompanied by a source release. Created https://github.com/apache/camel-kamelets/issues/590 to get that done in the Kamelets repository first. -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kamelets] zregvart opened a new issue #590: Provide source code release package
zregvart opened a new issue #590: URL: https://github.com/apache/camel-kamelets/issues/590 Per [ASF policy](https://www.apache.org/legal/release-policy.html#artifacts) we must generate signed source code release packages. This hasn't been done for the (currently) 3 voted upon releases that have been performed. -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] zregvart commented on a change in pull request #695: #686: Add icon to Apache Camel group on Linkedin
zregvart commented on a change in pull request #695: URL: https://github.com/apache/camel-website/pull/695#discussion_r758271532 ## File path: antora-ui-camel/src/img/brand-logos.svg ## @@ -20,4 +20,9 @@ Chat on Zulip + +Linkedin +Apache Camel group on Linkedin + Review comment: This seems to be copy-pasted icon of Zulip, there are icons available from [LinkedIn](https://brand.linkedin.com/downloads), though they seem to be in PNG and we want SVG icons here. We should also review that we comply with their [policies](https://brand.linkedin.com/policies). -- 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-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch regen_bot updated (60127b6 -> 07bbdad)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. from 60127b6 Sync deps add df5125f Align Azure Datalake Endpoint description to other Azure Components, for better documentation add 9b5e5cb Regen add 07bbdad Regen No new revisions were added by this update. Summary of changes: .../catalog/components/azure-storage-datalake.json | 2 +- .../storage/datalake/azure-storage-datalake.json | 2 +- .../main/docs/azure-storage-datalake-component.adoc | 4 ++-- .../azure/storage/datalake/DataLakeEndpoint.java | 2 +- .../builder/component/ComponentsBuilderFactory.java | 2 +- .../AzureStorageDatalakeComponentBuilderFactory.java | 4 ++-- .../src/generated/resources/metadata.json| 2 +- .../builder/endpoint/StaticEndpointBuilders.java | 4 ++-- .../endpoint/dsl/DataLakeEndpointBuilderFactory.java | 20 ++-- docs/components/modules/ROOT/nav.adoc| 2 +- 10 files changed, 22 insertions(+), 22 deletions(-)