Clone Tools
  • last updated 21 mins ago
Constraints
Constraints: committers
 
Constraints: files
Constraints: dates
Upgrade Kafka to version 2.4.1

    • -6
    • +0
    ./component/kafka/KafkaProducerFullTest.java
  1. … 1 more file in changeset.
CAMEL-14805: Fixed tests

    • -5
    • +0
    ./component/kafka/KafkaComponentTest.java
CS: Fix all imports

    • -1
    • +0
    ./component/kafka/KafkaComponentTest.java
  1. … 421 more files in changeset.
Removed brokers property from kafka component (can still be setted in configurations) details here: https://issues.apache.org/jira/browse/CAMEL-14615 fixed CAMEL-14615: camel kafka starter for spring does not consider camel.component.kafka.brokers property.

    • -1
    • +1
    ./component/kafka/BaseEmbeddedKafkaTest.java
    • -2
    • +2
    ./component/kafka/KafkaComponentTest.java
    • -1
    • +1
    ./component/kafka/KafkaProducerTest.java
  1. … 8 more files in changeset.
CAMEL-14558: Execute camel-kafak tests with testcontainers

    • -28
    • +13
    ./component/kafka/BaseEmbeddedKafkaTest.java
    • -1
    • +1
    ./component/kafka/KafkaProducerFullTest.java
    • -125
    • +0
    ./component/kafka/embedded/EmbeddedKafkaBroker.java
    • -53
    • +0
    ./component/kafka/embedded/SystemTime.java
    • -56
    • +0
    ./component/kafka/embedded/TestUtils.java
  1. … 1 more file in changeset.
[CAMEL-14516] Components should use the endpoint configurer when possible

    • -0
    • +1
    ./component/kafka/BaseEmbeddedKafkaTest.java
    • -1
    • +3
    ./component/kafka/KafkaEndpointTest.java
    • -0
    • +1
    ./component/kafka/KafkaProducerTest.java
  1. … 77 more files in changeset.
CAMEL-14435: Optimize core

    • -2
    • +4
    ./component/kafka/KafkaProducerTest.java
  1. … 26 more files in changeset.
CAMEL-14020 - Migrate getOut to getMessage in camel-kafka.

    • -14
    • +14
    ./component/kafka/KafkaProducerTest.java
Camel-Kafka - Fixed CS

    • -7
    • +2
    ./component/kafka/BaseEmbeddedKafkaTest.java
    • -8
    • +8
    ./component/kafka/KafkaComponentTest.java
    • -9
    • +5
    ./component/kafka/KafkaConsumerBatchSizeTest.java
    • -13
    • +11
    ./component/kafka/KafkaConsumerFullTest.java
    • -3
    • +3
    ./component/kafka/KafkaConsumerLastRecordHeaderTest.java
    • -10
    • +8
    ./component/kafka/KafkaConsumerManualCommitTest.java
    • -11
    • +4
    ./component/kafka/KafkaConsumerRebalanceTest.java
    • -7
    • +4
    ./component/kafka/KafkaConsumerTopicIsPatternTest.java
    • -41
    • +29
    ./component/kafka/KafkaProducerFullTest.java
    • -12
    • +9
    ./component/kafka/KafkaProducerTest.java
    • -1
    • +1
    ./component/kafka/MockConsumerInterceptor.java
    • -1
    • +1
    ./component/kafka/MockProducerInterceptor.java
    • -2
    • +2
    ./component/kafka/serde/DefaultKafkaHeaderDeserializerTest.java
  1. … 14 more files in changeset.
CAMEL-14308 - Upgrade to Kafka 2.4.x

    • -101
    • +0
    ./component/kafka/KafkaConsumerOffsetRepositoryEmptyTest.java
    • -102
    • +0
    ./component/kafka/KafkaConsumerOffsetRepositoryResumeTest.java
    • -117
    • +0
    ./component/kafka/KafkaConsumerRebalancePartitionRevokeTest.java
    • -17
    • +7
    ./component/kafka/embedded/EmbeddedKafkaBroker.java
  1. … 2 more files in changeset.
CAMEL-14360 - Allow overriding of message key and partition key for ggregated kafka messages (#3459)

* CAMEL-14360 - Allow overriding of message key and partition key for aggregated kafka messages

* CAMEL-14362 - Set metadata for each aggregated kafka message separately

* CAMEL-14362 - Use KeyValueHolder instead of Pair

* CMAEL-14362 - Code formatting changes and Exchange retrieval from Message instance

* CAMEL-14362 - Additional check for null return value of getExchange

    • -0
    • +23
    ./component/kafka/KafkaProducerTest.java
  1. … 1 more file in changeset.
CAMEL-14250: Make 'additionalProperties' option aware on the component level

    • -2
    • +17
    ./component/kafka/KafkaComponentTest.java
  1. … 3 more files in changeset.
CAMEL-14250: Add 'additionalProperties' option to camel-kafka to allow additional properties

    • -0
    • +22
    ./component/kafka/KafkaComponentTest.java
  1. … 3 more files in changeset.
CAMEL-14233: Fix Overriden topics when using aggregation on Exchanges or Messages

    • -0
    • +100
    ./component/kafka/KafkaProducerTest.java
  1. … 1 more file in changeset.
CAMEL-14180: Fix Checkstyle issues

Seems that previous versions of Checkstyle had few issues with checking

import sort/grouping. So I've run impsort Maven plugin:

mvn net.revelc.code:impsort-maven-plugin:sort -Dimpsort.groups=java,javax,org.w3c,org.xml,junit -Dimpsort.removeUnused=true -Dimpsort.staticAfter=true

To sort all the imports according to the Checkstyle rule.

Few remaining issues around indentation and unnecessary parentheses I

fixed manually.

    • -0
    • +1
    ./component/kafka/KafkaProducerFullTest.java
    • -1
    • +0
    ./component/kafka/embedded/TestUtils.java
    • -1
    • +1
    ./component/kafka/serde/DefaultKafkaHeaderDeserializerTest.java
  1. … 2770 more files in changeset.
CAMEL-14180: Fix Checkstyle issues

Seems that previous versions of Checkstyle had few issues with checking

import sort/grouping. So I've run impsort Maven plugin:

mvn net.revelc.code:impsort-maven-plugin:sort -Dimpsort.groups=java,javax,org.w3c,org.xml,junit -Dimpsort.removeUnused=true -Dimpsort.staticAfter=true

To sort all the imports according to the Checkstyle rule.

Few remaining issues around indentation and unnecessary parentheses I

fixed manually.

    • -0
    • +1
    ./component/kafka/KafkaProducerFullTest.java
    • -1
    • +0
    ./component/kafka/embedded/TestUtils.java
    • -1
    • +1
    ./component/kafka/serde/DefaultKafkaHeaderDeserializerTest.java
  1. … 2762 more files in changeset.
tiny cleanups: - remove unused import statements - make use of type inference for generic instance creation - remove obsolete 'public', 'static' and 'final' modifiers in interfaces - change field/method accesses to it's owning supertype - remove obsolete type castings - remove obsolete semicolons

    • -1
    • +0
    ./component/kafka/KafkaConsumerFullTest.java
    • -2
    • +0
    ./component/kafka/embedded/TestUtils.java
  1. … 345 more files in changeset.
CAMEL-13878: Message is forwarded to the wrong Kafka Topic.

    • -39
    • +3
    ./component/kafka/KafkaProducerTest.java
  1. … 3 more files in changeset.
CAMEL-13878: Message is forwarded to the wrong Kafka Topic.

    • -0
    • +24
    ./component/kafka/KafkaProducerTest.java
  1. … 3 more files in changeset.
Camel 13947 (#3199)

CAMEL-13947: PropertiesComponent should be a static service and resolved like other similar features.

    • -3
    • +2
    ./component/kafka/BaseEmbeddedKafkaTest.java
  1. … 204 more files in changeset.
CAMEL-13947: PropertiesComponent should be a static service and resolved like other similar features.

    • -3
    • +2
    ./component/kafka/BaseEmbeddedKafkaTest.java
  1. … 29 more files in changeset.
Change to awaitility instead of Thread.sleep

    • -1
    • +3
    ./component/kafka/KafkaConsumerOffsetRepositoryEmptyTest.java
    • -1
    • +3
    ./component/kafka/KafkaConsumerOffsetRepositoryResumeTest.java
  1. … 1 more file in changeset.
CAMEL-13943: Fix failing unit tests in camel-kafka

    • -0
    • +4
    ./component/kafka/KafkaConsumerOffsetRepositoryEmptyTest.java
    • -0
    • +4
    ./component/kafka/KafkaConsumerOffsetRepositoryResumeTest.java
CAMEL-13870: Fast property configuration of Camel endpoints.

    • -34
    • +11
    ./component/kafka/KafkaComponentTest.java
  1. … 585 more files in changeset.
Avoid using mockito when possible. Removed removed options as they were deprecated

    • -34
    • +11
    ./component/kafka/KafkaComponentTest.java
Switching to commons lang3 in a few places

    • -1
    • +1
    ./component/kafka/embedded/TestUtils.java
  1. … 15 more files in changeset.
Switching to commons lang3 in a few places

    • -1
    • +1
    ./component/kafka/embedded/TestUtils.java
  1. … 15 more files in changeset.
CAMEL-13853: AvailablePortFinder now delegates the port selection to OS

    • -2
    • +2
    ./component/kafka/BaseEmbeddedKafkaTest.java
  1. … 136 more files in changeset.
CAMEL-13853: AvailablePortFinder now delegates the port selection to OS

    • -2
    • +2
    ./component/kafka/BaseEmbeddedKafkaTest.java
  1. … 137 more files in changeset.
CAMEL-13853: AvailablePortFinder now delegates the port selection to OS

    • -2
    • +2
    ./component/kafka/BaseEmbeddedKafkaTest.java
    • -13
    • +0
    ./component/kafka/embedded/TestUtils.java
  1. … 147 more files in changeset.