Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[Rule Engine] - Individual Kafka Consumer Groups for Rule Engine Topics #10728

Merged
merged 12 commits into from
May 22, 2024
Merged

[Rule Engine] - Individual Kafka Consumer Groups for Rule Engine Topics #10728

merged 12 commits into from
May 22, 2024

Commits on May 6, 2024

  1. Rule engine: Kafka consumer group per partition

    @smatvienko-tb
    smatvienko-tb committed May 6, 2024
    Configuration menu
    Copy the full SHA
    8519387 View commit details
    Browse the repository at this point in the history

Commits on May 7, 2024

  1. TbRuleEngineQueueConsumerManagerTest fixed, bumped to JUnit5, paramet… 

    …rized test added
    @smatvienko-tb
    smatvienko-tb committed May 7, 2024
    Configuration menu
    Copy the full SHA
    e638e60 View commit details
    Browse the repository at this point in the history

Commits on May 8, 2024

  1. TbKafkaAdmin WIP

    @smatvienko-tb
    smatvienko-tb committed May 8, 2024
    Configuration menu
    Copy the full SHA
    07de3b9 View commit details
    Browse the repository at this point in the history

Commits on May 13, 2024

  1. TbRuleEngineQueueConsumerManager - createToRuleEngineMsgConsumer lazy

    @smatvienko-tb
    smatvienko-tb committed May 13, 2024
    Configuration menu
    Copy the full SHA
    416439f View commit details
    Browse the repository at this point in the history

  2. TbQueueConsumerTask::awaitCompletion after launchConsumer to provide … 

    …a fully async repartition experience
    @smatvienko-tb
    smatvienko-tb committed May 13, 2024
    Configuration menu
    Copy the full SHA
    5d7dc19 View commit details
    Browse the repository at this point in the history

  3. mvn license:format

    @smatvienko-tb
    smatvienko-tb committed May 13, 2024
    Configuration menu
    Copy the full SHA
    34cfd58 View commit details
    Browse the repository at this point in the history

Commits on May 15, 2024

  1. Kafka groupId syncOffsets from a fat group to a single-partition group

    @smatvienko-tb
    smatvienko-tb committed May 15, 2024
    Configuration menu
    Copy the full SHA
    258c26e View commit details
    Browse the repository at this point in the history

Commits on May 16, 2024

  1. TbQueueConsumerTask access the lazy consumer only by getter

    @smatvienko-tb
    smatvienko-tb committed May 16, 2024
    Configuration menu
    Copy the full SHA
    68225b4 View commit details
    Browse the repository at this point in the history

Commits on May 22, 2024

  1. minor cleanup

    @smatvienko-tb
    smatvienko-tb committed May 22, 2024
    Configuration menu
    Copy the full SHA
    5e3ff6f View commit details
    Browse the repository at this point in the history

  2. Merge remote-tracking branch 'ce/master' into feature/kafka-consumer-… 

    …group-per-partition

# Conflicts:
#	application/src/main/java/org/thingsboard/server/service/queue/ruleengine/TbQueueConsumerTask.java
#	application/src/main/java/org/thingsboard/server/service/queue/ruleengine/TbRuleEngineQueueConsumerManager.java
#	application/src/test/java/org/thingsboard/server/service/queue/ruleengine/TbRuleEngineQueueConsumerManagerTest.java
#	common/queue/src/main/java/org/thingsboard/server/queue/kafka/TbKafkaAdmin.java
    @smatvienko-tb
    smatvienko-tb committed May 22, 2024
    Configuration menu
    Copy the full SHA
    11a8e5c View commit details
    Browse the repository at this point in the history

  3. consumer creation refactored after merge

    @smatvienko-tb
    smatvienko-tb committed May 22, 2024
    Configuration menu
    Copy the full SHA
    0f1ef6d View commit details
    Browse the repository at this point in the history

  4. removed unused import

    @smatvienko-tb
    smatvienko-tb committed May 22, 2024
    Configuration menu
    Copy the full SHA
    fdf2801 View commit details
    Browse the repository at this point in the history