This is an automated email from the ASF dual-hosted git repository.
davsclaus 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 cc7627423c1 Regen
cc7627423c1 is described below
commit cc7627423c19339134b4c64d13274bae6372b424
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Mon Feb 5 14:30:51 2024 +0100
Regen
---
.../org/apache/camel/springboot/catalog/components/kafka.json | 2 +-
.../camel/component/kafka/integration/KafkaProducerFullIT.java | 10 +++++-----
2 files changed, 6 insertions(+), 6 deletions(-)
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kafka.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kafka.json
index 5f316641690..84ed92d0e2b 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kafka.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kafka.json
@@ -150,7 +150,7 @@
"kafka.LAST_POLL_RECORD": { "index": 8, "kind": "header", "displayName":
"", "group": "consumer", "label": "consumer", "required": false, "javaType":
"Boolean", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "Indicates the last record within the current
poll request (only available if autoCommitEnable endpoint parameter is false or
allowManualCommit is true)", "constantName":
"org.apache.camel.component.kafka.KafkaConstants#LAST_POLL_R [...]
"kafka.TIMESTAMP": { "index": 9, "kind": "header", "displayName": "",
"group": "consumer", "label": "consumer", "required": false, "javaType":
"Long", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "The timestamp of the message", "constantName":
"org.apache.camel.component.kafka.KafkaConstants#TIMESTAMP" },
"kafka.OVERRIDE_TIMESTAMP": { "index": 10, "kind": "header",
"displayName": "", "group": "producer", "label": "producer", "required": false,
"javaType": "Long", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "The ProducerRecord also has an
associated timestamp. If the user did provide a timestamp, the producer will
stamp the record with the provided timestamp and the header is not preserved.",
"constantName": "org.apache.camel.componen [...]
- "org.apache.kafka.clients.producer.RecordMetadata": { "index": 11, "kind":
"header", "displayName": "", "group": "producer", "label": "producer",
"required": false, "javaType": "List<RecordMetadata>", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false, "description": "The
metadata (only configured if recordMetadata endpoint parameter is true)",
"constantName":
"org.apache.camel.component.kafka.KafkaConstants#KAFKA_RECORDMETA" },
+ "kafka.RECORD_META": { "index": 11, "kind": "header", "displayName": "",
"group": "producer", "label": "producer", "required": false, "javaType":
"List<RecordMetadata>", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "description": "The metadata (only
configured if recordMetadata endpoint parameter is true)", "constantName":
"org.apache.camel.component.kafka.KafkaConstants#KAFKA_RECORD_META" },
"CamelKafkaManualCommit": { "index": 12, "kind": "header", "displayName":
"", "group": "consumer", "label": "consumer", "required": false, "javaType":
"org.apache.camel.component.kafka.consumer.KafkaManualCommit", "deprecated":
false, "deprecationNote": "", "autowired": false, "secret": false,
"description": "Can be used for forcing manual offset commit when using Kafka
consumer.", "constantName":
"org.apache.camel.component.kafka.KafkaConstants#MANUAL_COMMIT" }
},
"properties": {
diff --git
a/components-starter/camel-kafka-starter/src/test/java/org/apache/camel/component/kafka/integration/KafkaProducerFullIT.java
b/components-starter/camel-kafka-starter/src/test/java/org/apache/camel/component/kafka/integration/KafkaProducerFullIT.java
index 7154ea5ba9f..d91acf3a2ac 100644
---
a/components-starter/camel-kafka-starter/src/test/java/org/apache/camel/component/kafka/integration/KafkaProducerFullIT.java
+++
b/components-starter/camel-kafka-starter/src/test/java/org/apache/camel/component/kafka/integration/KafkaProducerFullIT.java
@@ -171,7 +171,7 @@ public class KafkaProducerFullIT extends
BaseEmbeddedKafkaTestSupport {
for (Exchange exchange : exchangeList) {
@SuppressWarnings("unchecked")
List<RecordMetadata> recordMetaData1
- = (List<RecordMetadata>)
(exchange.getIn().getHeader(KafkaConstants.KAFKA_RECORDMETA));
+ = (List<RecordMetadata>)
(exchange.getIn().getHeader(KafkaConstants.KAFKA_RECORD_META));
assertEquals(1, recordMetaData1.size(), "One RecordMetadata is
expected.");
assertTrue(recordMetaData1.get(0).offset() >= 0, "Offset is
positive");
assertTrue(recordMetaData1.get(0).topic().startsWith("test"),
"Topic Name start with 'test'");
@@ -202,7 +202,7 @@ public class KafkaProducerFullIT extends
BaseEmbeddedKafkaTestSupport {
for (Exchange exchange : exchangeList) {
@SuppressWarnings("unchecked")
List<RecordMetadata> recordMetaData1
- = (List<RecordMetadata>)
(exchange.getIn().getHeader(KafkaConstants.KAFKA_RECORDMETA));
+ = (List<RecordMetadata>)
(exchange.getIn().getHeader(KafkaConstants.KAFKA_RECORD_META));
assertEquals(1, recordMetaData1.size(), "One RecordMetadata is
expected.");
assertTrue(recordMetaData1.get(0).offset() >= 0, "Offset is
positive");
assertTrue(recordMetaData1.get(0).topic().startsWith("test"),
"Topic Name start with 'test'");
@@ -260,7 +260,7 @@ public class KafkaProducerFullIT extends
BaseEmbeddedKafkaTestSupport {
assertEquals(2, exchangeList.size(), "Two Exchanges are expected");
Exchange e1 = exchangeList.get(0);
@SuppressWarnings("unchecked")
- List<RecordMetadata> recordMetaData1 = (List<RecordMetadata>)
(e1.getIn().getHeader(KafkaConstants.KAFKA_RECORDMETA));
+ List<RecordMetadata> recordMetaData1 = (List<RecordMetadata>)
(e1.getIn().getHeader(KafkaConstants.KAFKA_RECORD_META));
assertEquals(10, recordMetaData1.size(), "Ten RecordMetadata is
expected.");
for (RecordMetadata recordMeta : recordMetaData1) {
assertTrue(recordMeta.offset() >= 0, "Offset is positive");
@@ -268,7 +268,7 @@ public class KafkaProducerFullIT extends
BaseEmbeddedKafkaTestSupport {
}
Exchange e2 = exchangeList.get(1);
@SuppressWarnings("unchecked")
- List<RecordMetadata> recordMetaData2 = (List<RecordMetadata>)
(e2.getIn().getHeader(KafkaConstants.KAFKA_RECORDMETA));
+ List<RecordMetadata> recordMetaData2 = (List<RecordMetadata>)
(e2.getIn().getHeader(KafkaConstants.KAFKA_RECORD_META));
assertEquals(5, recordMetaData2.size(), "Five RecordMetadata is
expected.");
for (RecordMetadata recordMeta : recordMetaData2) {
assertTrue(recordMeta.offset() >= 0, "Offset is positive");
@@ -304,7 +304,7 @@ public class KafkaProducerFullIT extends
BaseEmbeddedKafkaTestSupport {
for (Exchange exchange : exchangeList) {
@SuppressWarnings("unchecked")
List<RecordMetadata> recordMetaData1
- = (List<RecordMetadata>)
(exchange.getIn().getHeader(KafkaConstants.KAFKA_RECORDMETA));
+ = (List<RecordMetadata>)
(exchange.getIn().getHeader(KafkaConstants.KAFKA_RECORD_META));
assertEquals(1, recordMetaData1.size(), "One RecordMetadata is
expected.");
assertTrue(recordMetaData1.get(0).offset() >= 0, "Offset is
positive");
assertTrue(recordMetaData1.get(0).topic().startsWith("test"),
"Topic Name start with 'test'");
