This is an automated email from the ASF dual-hosted git repository.
Croway pushed a change to branch automated/upgrade-kafka-container-image-4.4.0
in repository https://gitbox.apache.org/repos/asf/camel.git
from 615f17405227 chore(camel-test-infra-kafka): upgrade
kafka.container.image to 4.4.0
add e48face394f1 CAMEL-25943: camel-jira - a consumer with maxResults 0 or
less searches forever (#28469)
add 847ee9affb4c CAMEL-25942: camel-aws2-kinesis - resume each shard from
its own entry of the resume cache (#28461)
add 6044f38166f9 CAMEL-25944: camel-paho-mqtt5, camel-paho - connect the
consumer's client after its callback is set (#28462)
add 2aef0593380d CAMEL-25945: camel-azure-storage-queue - the consumer
deletes the message it received, whatever the route did with its headers
(#28463)
add 5f10c225652e CAMEL-25946: camel-mongodb - the change streams consumer
goes on after its collection is dropped or renamed (#28464)
add 9886c7710017 CAMEL-25947: camel-spring-rabbitmq - confirm=auto waits
for the confirms of a connection factory with simple publisher confirms (#28465)
add 295b8d648cf2 CAMEL-26291: camel-core - ThrottlingExceptionRoutePolicy
must count the failures within failureWindow, and close the circuit on a
success in the half open state (#28467)
add 426c3f8a4cb8 CAMEL-26292: camel-core - ThrottlingInflightRoutePolicy
with the context scope must also throttle on failed exchanges (#28468)
add 3b66468d0a07 chore: camel-jbang - sync the bundled examples: values
for the route kept in variables, not headers (#28508)
add 55b266d9403f CAMEL-26108: camel-avro-rpc - the component should
configure all options on the endpoint
add aa2c0c3687da CAMEL-26108: camel-avro-rpc - address review comments
add 57d280450c45 Bump actions/setup-python from 7.0.0 to 7.1.0 (#28483)
add 071976d54346 Bump astral-sh/setup-uv from 10.3.0 to 10.3.2 (#28484)
add 08f90a248826 Bump the micrometer group with 9 updates (#28485)
add d58aea37f88b Bump com.uber.nullaway:nullaway from 0.14.2 to 0.14.3
(#28487)
add 7514442c4729 Bump com.gradle:develocity-maven-extension from 2.6.0 to
2.6.1 (#28488)
add 130ee8d38717 Bump aws-java-sdk2-version from 2.56.0 to 2.57.3 (#28490)
add 3e39fa431ee9 Bump infinispan-version from 16.3.0 to 16.3.1 (#28491)
add 9b7155ec4699 Bump io.projectreactor:reactor-core from 3.8.7 to 3.8.8
(#28492)
add 00d2c9e23999 Bump io.rest-assured:rest-assured from 6.0.1 to 6.2.0
(#28493)
add cd68bb6cfcec Bump org.mybatis:mybatis from 3.5.19 to 3.6.0 (#28495)
add 1d4186f6e293 CAMEL-25809: camel-aws2-sqs - count later visibility
extensions from the call, and skip the immediate extension of a batch that is
not routed (#28460)
add ffab48ea514b CAMEL-25984: docs - upgrade guide entries for the
camel-cometd CORS filter credentials in 4.22.3 and 4.18.6 (#28504)
add 318aba6f5c06 CAMEL-26301: tokenizer EIP: wrap tokenizer call to
prevent exchange hang on exception (#28486)
add 0ed098c20211 CAMEL-26065: camel-netty-http - key multiplex channel
handlers by listener address (#28352)
add 79caee6d97f1 Bump io.dapr:dapr-sdk-workflows from 1.18.1 to 1.19.0
(#28494)
add 681417c4b9f5 chore(camel-test-infra-qdrant): upgrade qdrant.container
to v1.20.0-unprivileged (#28482)
add f3d1519e1296 chore(camel-test-infra-opa): upgrade opa.container to
1.21.4-static (#28481)
add 2f9b1445106a chore(camel-test-infra-ollama): upgrade ollama.container
to 0.40.11 (#28480)
add 15a6360033fa chore(camel-test-infra-observability): upgrade
observability.perses.container to v0.55.0 (#28479)
add a1a68ff9279b chore(camel-test-infra-observability): upgrade
observability.victoriatraces.container to v0.12.1 (#28478)
add dc6ef0d9de60 chore(camel-test-infra-observability): upgrade
observability.prometheus.container to v3.15.1 (#28477)
add 13408a994883 chore(camel-test-infra-neo4j): upgrade neo4j.container to
2026.10-community-ubi10 (#28476)
add c20fc29edd8f chore(camel-test-infra-nats): upgrade
nats.container.ppc64le to 2.15.1 (#28475)
add ec50b5cebf2e chore(camel-test-infra-kafka): upgrade
redpanda.container.image to v26.2.5 (#28474)
add fc10e06ca5e1 chore(camel-test-infra-hashicorp-vault): upgrade
hashicorp.vault.container to 2.2.1 (#28472)
add ebcd5a5546d6 chore(camel-test-infra-docling): upgrade
docling.container to v1.38.1 (#28471)
add 8e0ce2d21371 chore(camel-test-infra-consul): upgrade consul.container
to 2.1.0 (#28470)
add d092726b2641 CAMEL-25917: docs - upgrade guide entries for the
camel-undertow WebSocket consumer handlers in 4.22.3 and 4.18.6 (#28507)
add 68a4188d8e48 CAMEL-24767: Add tool search support (#28354)
add fec49c3a6a78 CAMEL-26116: camel-jbang - Export should resolve the
consumer endpoint of a zookeeper-master: endpoint (#28489)
add 370f749b5116 Merge main into Kafka 4.4.0 image upgrade and retain
Redpanda v26.2.5
No new revisions were added by this update.
Summary of changes:
.github/workflows/check-container-versions.yml | 2 +-
.github/workflows/pr-ci-scripts-validation.yml | 2 +-
.mvn/extensions.xml | 2 +-
.../apache/camel/catalog/components/ai-tool.json | 22 +-
.../camel/catalog/components/aws2-polly.json | 6 +-
.../catalog/components/langchain4j-agent.json | 52 ++-
.../org/apache/camel/catalog/components/llm.json | 245 +++++------
.../apache/camel/catalog/components/openai.json | 245 +++++------
.../camel/catalog/components/spring-ai-chat.json | 62 +--
.../camel/catalog/docs/ai-tool-component.adoc | 22 +
.../camel/catalog/docs/aws2-kinesis-component.adoc | 5 +
.../catalog/docs/langchain4j-agent-component.adoc | 23 ++
.../org/apache/camel/catalog/docs/openai-mcp.adoc | 24 ++
.../catalog/docs/spring-ai-chat-component.adoc | 23 ++
.../apache/camel/catalog/test-infra/metadata.json | 16 +-
.../ai/tool/AiToolComponentConfigurer.java | 3 +
.../ai/tool/AiToolConfigurationConfigurer.java | 3 +
.../ai/tool/AiToolEndpointConfigurer.java | 3 +
.../ai/tool/AiToolEndpointUriFactory.java | 3 +-
.../apache/camel/component/ai/tool/ai-tool.json | 22 +-
.../src/main/docs/ai-tool-component.adoc | 22 +
.../component/ai/tool/AiToolConfiguration.java | 15 +
.../camel/component/ai/tool/AiToolConsumer.java | 3 +-
.../camel/component/ai/tool/AiToolSearch.java | 63 +++
.../component/ai/tool/AiToolSearchArguments.java | 78 ++++
.../component/ai/tool/AiToolSearchCandidate.java | 102 +++++
.../component/ai/tool/AiToolSearchEmbedder.java | 55 +++
.../camel/component/ai/tool/AiToolSearchIndex.java | 284 +++++++++++++
.../component/ai/tool/AiToolSearchSession.java | 107 +++++
.../component/ai/tool/AiToolSearchSessions.java | 236 +++++++++++
.../component/ai/tool/AiToolSearchStrategy.java} | 26 +-
.../apache/camel/component/ai/tool/AiToolSpec.java | 33 +-
.../ai/tool/AiToolSearchArgumentsTest.java | 71 ++++
.../component/ai/tool/AiToolSearchIndexTest.java | 290 +++++++++++++
.../component/ai/tool/AiToolSearchableUriTest.java | 45 ++
.../langchain4j/agent/api/AbstractAgent.java | 91 ++++-
.../langchain4j/agent/api/AgentConfiguration.java | 25 ++
.../AgentConfigurationToolCallingBehaviorTest.java | 26 ++
.../agent/LangChain4jAgentComponentConfigurer.java | 26 +-
.../LangChain4jAgentConfigurationConfigurer.java | 24 ++
.../agent/LangChain4jAgentEndpointConfigurer.java | 26 +-
.../agent/LangChain4jAgentEndpointUriFactory.java | 6 +-
.../langchain4j/agent/langchain4j-agent.json | 52 ++-
.../src/main/docs/langchain4j-agent-component.adoc | 23 ++
.../langchain4j/agent/AiToolSpecToLangChain4j.java | 13 +
.../langchain4j/agent/CamelToolSearchStrategy.java | 320 +++++++++++++++
.../agent/LangChain4jAgentConfiguration.java | 61 +++
.../agent/LangChain4jAgentProducer.java | 87 +++-
.../agent/CamelToolSearchStrategyTest.java | 283 +++++++++++++
.../agent/LangChain4jAgentToolSearchTest.java | 234 +++++++++++
.../tokenizer/AbstractLangChain4JTokenizer.java | 5 +
.../tokenizer/TokenizerBodyTypesTest.java | 9 +
.../component/openai/OpenAIEndpointConfigurer.java | 24 ++
.../component/openai/OpenAIEndpointUriFactory.java | 6 +-
.../org/apache/camel/component/openai/llm.json | 245 +++++------
.../org/apache/camel/component/openai/openai.json | 245 +++++------
.../camel-openai/src/main/docs/openai-mcp.adoc | 24 ++
.../camel/component/openai/AiToolSpecToOpenAI.java | 12 +
.../component/openai/McpToolCallExecutor.java | 34 +-
.../camel/component/openai/OpenAIComponent.java | 16 +
.../component/openai/OpenAIConfiguration.java | 58 +++
.../camel/component/openai/OpenAIConstants.java | 4 +
.../camel/component/openai/OpenAIEndpoint.java | 14 +
.../camel/component/openai/OpenAIProducer.java | 79 +++-
.../component/openai/OpenAIResponsesProducer.java | 129 ++++--
.../openai/OpenAIToolExecutionProducer.java | 23 +-
.../camel/component/openai/OpenAIToolSearch.java | 437 ++++++++++++++++++++
.../component/openai/McpToolCallExecutorTest.java | 21 +-
.../component/openai/OpenAIResponsesMockTest.java | 141 ++++---
.../component/openai/OpenAIToolSearchMockTest.java | 455 +++++++++++++++++++++
.../component/openai/OpenAIToolSearchTest.java | 424 +++++++++++++++++++
.../apache/camel/component/avro/AvroListener.java | 2 +-
.../component/avro/AvroHttpConsumerHostTest.java | 57 +++
.../component/avro/spi/JettyHttpServerFactory.java | 5 +
.../avro/spi/AvroRpcHttpServerFactory.java | 19 +
.../src/main/docs/aws2-kinesis-component.adoc | 5 +
.../component/aws2/kinesis/Kinesis2Consumer.java | 14 +-
.../aws2/kinesis/consumer/KinesisResumeAction.java | 20 +-
.../aws2/kinesis/KinesisConsumerPositionTest.java | 215 +++++++++-
.../camel/component/aws2/polly/aws2-polly.json | 6 +-
.../camel/component/aws2/sqs/Sqs2Consumer.java | 17 +-
...onsumerExtendMessageVisibilitySlowCallTest.java | 124 ++++++
.../azure/storage/queue/QueueConsumer.java | 31 +-
.../queue/QueueConsumerDeleteMessageTest.java | 211 ++++++++++
.../jira/consumer/AbstractJiraConsumer.java | 4 +-
.../WatchUpdatesConsumerMaxResultsZeroTest.java | 130 ++++++
.../mongodb/MongoDbChangeStreamsThread.java | 39 +-
.../MongoDbChangeStreamsInvalidateTest.java | 262 ++++++++++++
.../netty/http/HttpServerInitializerFactory.java | 4 +-
.../component/netty/http/NettyHttpComponent.java | 24 +-
.../http/NettyHttpDifferentHostSamePortTest.java | 72 ++++
.../component/paho/mqtt5/PahoMqtt5Consumer.java | 10 +-
.../PahoMqtt5ConsumerSessionMessagesTest.java | 106 +++++
.../apache/camel/component/paho/PahoConsumer.java | 10 +-
.../paho/PahoConsumerSessionMessagesTest.java | 105 +++++
.../chat/SpringAiChatEndpointConfigurer.java | 26 +-
.../chat/SpringAiChatEndpointUriFactory.java | 6 +-
.../component/springai/chat/spring-ai-chat.json | 62 +--
.../src/main/docs/spring-ai-chat-component.adoc | 23 ++
.../springai/chat/SpringAiChatConfiguration.java | 60 +++
.../springai/chat/SpringAiChatProducer.java | 61 ++-
.../springai/chat/SpringAiToolSearch.java | 379 +++++++++++++++++
.../springai/chat/SpringAiChatToolSearchTest.java | 224 ++++++++++
.../springrabbit/SpringRabbitMQProducer.java | 10 +-
.../SpringRabbitMQProducerConfirmTest.java | 154 +++++++
.../apache/camel/processor/TokenizerProcessor.java | 12 +-
...tlingExceptionRoutePolicyFailureWindowTest.java | 195 +++++++++
...xceptionRoutePolicyHalfOpenHandlerSedaTest.java | 2 +-
...ingExceptionRoutePolicyHalfOpenHandlerTest.java | 2 +-
...ThrottlingExceptionRoutePolicyHalfOpenTest.java | 2 +-
.../ThrottlingExceptionRoutePolicyTest.java | 2 +-
...RoutePolicyContextScopeFailedExchangesTest.java | 129 ++++++
.../throttling/ThrottlingExceptionRoutePolicy.java | 88 +++-
.../throttling/ThrottlingInflightRoutePolicy.java | 11 +-
.../ROOT/pages/camel-4x-upgrade-guide-4_18.adoc | 13 +
.../ROOT/pages/camel-4x-upgrade-guide-4_22.adoc | 21 +
.../ROOT/pages/camel-4x-upgrade-guide-4_24.adoc | 32 ++
.../dsl/AiToolComponentBuilderFactory.java | 22 +
.../Langchain4jAgentComponentBuilderFactory.java | 83 ++++
.../endpoint/dsl/AiToolEndpointBuilderFactory.java | 38 ++
.../LangChain4jAgentEndpointBuilderFactory.java | 146 +++++++
.../endpoint/dsl/OpenAIEndpointBuilderFactory.java | 403 ++++++++++++++++++
.../dsl/SpringAiChatEndpointBuilderFactory.java | 144 +++++++
.../examples/camel-jbang-example-catalog.json | 12 +-
.../resources/examples/route/aggregator/README.md | 6 +-
.../route/aggregator/aggregator.camel.yaml | 8 +-
.../examples/route/enrich-and-dedupe/README.md | 4 +-
.../enrich-and-dedupe/enrich-and-dedupe.camel.yaml | 10 +-
.../resources/examples/route/order-lines/README.md | 9 +-
.../route/order-lines/order-lines.camel.yaml | 10 +-
.../examples/run/order-generator/README.md | 8 +-
.../run/order-generator/order-generator.camel.yaml | 6 +-
.../examples/transform/csv-to-json/README.md | 2 +-
.../transform/csv-to-json/csv-to-json.camel.yaml | 6 +-
.../examples/transform/json-transform/README.md | 5 +-
.../json-transform/json-transform.camel.yaml | 6 +-
.../camel/dsl/jbang/core/commands/ExportTest.java | 32 ++
.../src/test/resources/zookeeper-master-route.yaml | 22 +
.../main/download/DownloadEndpointStrategy.java | 7 +-
dsl/camel-yaml-dsl/camel-yaml-dsl/pom.xml | 14 +
.../yaml/LangChain4jAgentToolSearchYamlTest.java | 103 +++++
parent/pom.xml | 18 +-
.../src/generated/resources/META-INF/metadata.json | 16 +-
.../infra/consul/services/container.properties | 2 +-
.../infra/docling/services/container.properties | 2 +-
.../hashicorp/vault/services/container.properties | 2 +-
.../test/infra/kafka/services/container.properties | 2 +-
.../test/infra/nats/services/container.properties | 2 +-
.../test/infra/neo4j/services/container.properties | 2 +-
.../observability/services/container.properties | 6 +-
.../infra/ollama/services/container.properties | 2 +-
.../test/infra/opa/services/container.properties | 2 +-
.../infra/qdrant/services/container.properties | 2 +-
153 files changed, 9194 insertions(+), 893 deletions(-)
create mode 100644
components/camel-ai/camel-ai-tool/src/main/java/org/apache/camel/component/ai/tool/AiToolSearch.java
create mode 100644
components/camel-ai/camel-ai-tool/src/main/java/org/apache/camel/component/ai/tool/AiToolSearchArguments.java
create mode 100644
components/camel-ai/camel-ai-tool/src/main/java/org/apache/camel/component/ai/tool/AiToolSearchCandidate.java
create mode 100644
components/camel-ai/camel-ai-tool/src/main/java/org/apache/camel/component/ai/tool/AiToolSearchEmbedder.java
create mode 100644
components/camel-ai/camel-ai-tool/src/main/java/org/apache/camel/component/ai/tool/AiToolSearchIndex.java
create mode 100644
components/camel-ai/camel-ai-tool/src/main/java/org/apache/camel/component/ai/tool/AiToolSearchSession.java
create mode 100644
components/camel-ai/camel-ai-tool/src/main/java/org/apache/camel/component/ai/tool/AiToolSearchSessions.java
copy
components/{camel-avro-rpc/camel-avro-rpc-spi/src/main/java/org/apache/camel/component/avro/spi/AvroRpcHttpServerFactory.java
=>
camel-ai/camel-ai-tool/src/main/java/org/apache/camel/component/ai/tool/AiToolSearchStrategy.java}
(56%)
create mode 100644
components/camel-ai/camel-ai-tool/src/test/java/org/apache/camel/component/ai/tool/AiToolSearchArgumentsTest.java
create mode 100644
components/camel-ai/camel-ai-tool/src/test/java/org/apache/camel/component/ai/tool/AiToolSearchIndexTest.java
create mode 100644
components/camel-ai/camel-ai-tool/src/test/java/org/apache/camel/component/ai/tool/AiToolSearchableUriTest.java
create mode 100644
components/camel-ai/camel-langchain4j-agent/src/main/java/org/apache/camel/component/langchain4j/agent/CamelToolSearchStrategy.java
create mode 100644
components/camel-ai/camel-langchain4j-agent/src/test/java/org/apache/camel/component/langchain4j/agent/CamelToolSearchStrategyTest.java
create mode 100644
components/camel-ai/camel-langchain4j-agent/src/test/java/org/apache/camel/component/langchain4j/agent/LangChain4jAgentToolSearchTest.java
create mode 100644
components/camel-ai/camel-openai/src/main/java/org/apache/camel/component/openai/OpenAIToolSearch.java
create mode 100644
components/camel-ai/camel-openai/src/test/java/org/apache/camel/component/openai/OpenAIToolSearchMockTest.java
create mode 100644
components/camel-ai/camel-openai/src/test/java/org/apache/camel/component/openai/OpenAIToolSearchTest.java
create mode 100644
components/camel-avro-rpc/camel-avro-rpc-component/src/test/java/org/apache/camel/component/avro/AvroHttpConsumerHostTest.java
create mode 100644
components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/SqsConsumerExtendMessageVisibilitySlowCallTest.java
create mode 100644
components/camel-azure/camel-azure-storage-queue/src/test/java/org/apache/camel/component/azure/storage/queue/QueueConsumerDeleteMessageTest.java
create mode 100644
components/camel-jira/src/test/java/org/apache/camel/component/jira/consumer/WatchUpdatesConsumerMaxResultsZeroTest.java
create mode 100644
components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/MongoDbChangeStreamsInvalidateTest.java
create mode 100644
components/camel-netty-http/src/test/java/org/apache/camel/component/netty/http/NettyHttpDifferentHostSamePortTest.java
create mode 100644
components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/PahoMqtt5ConsumerSessionMessagesTest.java
create mode 100644
components/camel-paho/src/test/java/org/apache/camel/component/paho/PahoConsumerSessionMessagesTest.java
create mode 100644
components/camel-spring-parent/camel-spring-ai/camel-spring-ai-chat/src/main/java/org/apache/camel/component/springai/chat/SpringAiToolSearch.java
create mode 100644
components/camel-spring-parent/camel-spring-ai/camel-spring-ai-chat/src/test/java/org/apache/camel/component/springai/chat/SpringAiChatToolSearchTest.java
create mode 100644
components/camel-spring-parent/camel-spring-rabbitmq/src/test/java/org/apache/camel/component/springrabbit/SpringRabbitMQProducerConfirmTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/processor/throttle/ThrottlingExceptionRoutePolicyFailureWindowTest.java
create mode 100644
core/camel-core/src/test/java/org/apache/camel/processor/throttle/ThrottlingInflightRoutePolicyContextScopeFailedExchangesTest.java
create mode 100644
dsl/camel-jbang/camel-jbang-core/src/test/resources/zookeeper-master-route.yaml
create mode 100644
dsl/camel-yaml-dsl/camel-yaml-dsl/src/test/java/org/apache/camel/dsl/yaml/LangChain4jAgentToolSearchYamlTest.java
