Skip to content

add compressionType,enableChunking for pulsar client , upgrade dependencies for security #5191

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

Merged
agapple merged 8 commits into from
Jul 16, 2024
Merged

add compressionType,enableChunking for pulsar client , upgrade dependencies for security #5191

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
8 commits
Select commit Hold shift + click to select a range
7c6a689
add support for listener name which is described in https://pulsar.ap…
zhangjiayin Apr 24, 2024
355f826
Merge pull request #1 from alibaba/master
zhangjiayin May 21, 2024
23c0c05
upgrade for CVE-2023-20883 CVE-2022-1471 CVE-2023-20860
zhangjiayin May 21, 2024
07c367d
Merge pull request #2 from alibaba/master
zhangjiayin Jul 2, 2024
e090ed9
add enableChunking
zhangjiayin Jul 2, 2024
52129dc
downgrade pulsar client version
zhangjiayin Jul 2, 2024
fd39ced
fix
zhangjiayin Jul 2, 2024
195a9b4
增加压缩算法
zhangjiayin Jul 2, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
fix
  • Loading branch information
@zhangjiayin
zhangjiayin committed Jul 2, 2024
commit fd39cedfadaceece1fd3d6234b47f5fca027993c
2 changes: 1 addition & 1 deletion .../main/java/com/alibaba/otter/canal/connector/pulsarmq/producer/CanalPulsarMQProducer.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -418,7 +418,7 @@ private Producer<byte[]> getProducer(String topic) {
producerBuilder.enableChunking(true);
producerBuilder.enableBatching(false);
}
producerBuilder.topic(fullTopic)
producer = producerBuilder.topic(fullTopic)
// 指定路由器
.messageRouter(new MessageRouterImpl(topic))
.create();
Expand Down
2 changes: 1 addition & 1 deletion pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -105,7 +105,7 @@
<rabbitmq_version>5.18.0</rabbitmq_version>
<mq_amqp_client>1.0.3</mq_amqp_client>
<kafka_version>2.4.0</kafka_version>
<pulsar_version>2.9.5</pulsar_version>
<pulsar_version>2.11.4</pulsar_version>
<mysql_driver_version>5.1.48</mysql_driver_version>
<maven-jacoco-plugin.version>0.8.3</maven-jacoco-plugin.version>
<maven-surefire.version>2.22.1</maven-surefire.version>
Expand Down