messagequeue-framework v1.5.11

highly suggest upgrading to this version

Optimize

• Fix KafkaMessageReceiverRetry retry queue poll issue to prevent the CPU usage is too high.

Maven

<dependency>
    <groupId>org.darkphoenixs</groupId>
    <artifactId>messagequeue-framework</artifactId>
    <version>1.5.11</version>
</dependency>

messagequeue-framework v1.5.10

Optimize

• Fix KafkaMessageNewReceiverPool destroy threadpool resource issue.

Maven

<dependency>
    <groupId>org.darkphoenixs</groupId>
    <artifactId>messagequeue-framework</artifactId>
    <version>1.5.10</version>
</dependency>

messagequeue-framework v1.5.9

Optimize

• Fix KafkaMessageNewReceiverPool destroy threadpool issue.

Maven

<dependency>
    <groupId>org.darkphoenixs</groupId>
    <artifactId>messagequeue-framework</artifactId>
    <version>1.5.9</version>
</dependency>

messagequeue-framework v1.5.8

Features

• Add BlockingQueue Monitor for Kafka Consumer MODEL_2.

Optimize

• Some other optimizations.

Maven

<dependency>
    <groupId>org.darkphoenixs</groupId>
    <artifactId>messagequeue-framework</artifactId>
    <version>1.5.8</version>
</dependency>

messagequeue-framework v1.5.7

Optimize

• Add MQMessageDecoderAdapter and MQMessageEncoderAdapter.
• Some other optimizations.

Maven

<dependency>
    <groupId>org.darkphoenixs</groupId>
    <artifactId>messagequeue-framework</artifactId>
    <version>1.5.7</version>
</dependency>

messagequeue-framework v1.5.6

Optimize

• Fix potential security vulnerability.

Maven

<dependency>
    <groupId>org.darkphoenixs</groupId>
    <artifactId>messagequeue-framework</artifactId>
    <version>1.5.6</version>
</dependency>

messagequeue-framework v1.5.5

Optimize

• Some internal optimizations .

Maven

<dependency>
    <groupId>org.darkphoenixs</groupId>
    <artifactId>messagequeue-framework</artifactId>
    <version>1.5.5</version>
</dependency>

messagequeue-framework v1.5.4

Bug Fixed

• Fixed Kafka ConsumerRecords size 0 in batch model issue.

Maven

<dependency>
    <groupId>org.darkphoenixs</groupId>
    <artifactId>messagequeue-framework</artifactId>
    <version>1.5.4</version>
</dependency>

messagequeue-framework v1.5.3

Features

• Kafka consumer retrying .
• Compatible API (ActiveMQ & RocketMQ & Kafka) .

Optimize

• Some other optimizations .

Maven

<dependency>
    <groupId>org.darkphoenixs</groupId>
    <artifactId>messagequeue-framework</artifactId>
    <version>1.5.3</version>
</dependency>

messagequeue-framework v1.5.2

Optimize

• Upgrade Kafka version to 1.0.0 .
• Upgrade RocketMQ version to 4.2.0 .

Maven

<dependency>
    <groupId>org.darkphoenixs</groupId>
    <artifactId>messagequeue-framework</artifactId>
    <version>1.5.2</version>
</dependency>