From 8435cf1d25d07b09e2a9937d39bed1c1a422e4f0 Mon Sep 17 00:00:00 2001
From: jiazx0107@163.com <jiazx0107@163.com>
Date: 星期四, 14 十二月 2023 14:10:45 +0800
Subject: [PATCH] 提交正来电子协议解析-1
---
src/main/java/com/fzzy/conf/KafkaProviderConfig.java | 20 --------------------
1 files changed, 0 insertions(+), 20 deletions(-)
diff --git a/src/main/java/com/fzzy/conf/KafkaProviderConfig.java b/src/main/java/com/fzzy/conf/KafkaProviderConfig.java
index d7a3c40..ed7fecd 100644
--- a/src/main/java/com/fzzy/conf/KafkaProviderConfig.java
+++ b/src/main/java/com/fzzy/conf/KafkaProviderConfig.java
@@ -39,9 +39,6 @@
@Value("${spring.kafka.properties.sasl.password}")
private String saslPassword;
-// @Value("${spring.kafka.producer.transaction-id-prefix}")
-// private String transactionIdPrefix;
-
@Bean
public Map<String, Object> producerConfigs() {
Map<String, Object> props = new HashMap<>();
@@ -59,10 +56,6 @@
props.put("sasl.username", saslUsername);
props.put("sasl.password", saslPassword);
-
- // props.put("sasl.jaas.config", "org.apache.kafka.common.security.scram.ScramLoginModule required username='sc001' password='wCV0ISwmoKwbx1lpBKMW';");
-
-
props.put("sasl.jaas.config", saslJaasConfig);
return props;
@@ -73,19 +66,6 @@
DefaultKafkaProducerFactory<String, String> producerFactory = new DefaultKafkaProducerFactory<>(producerConfigs());
return producerFactory;
}
-
-// @Bean
-// public ProducerFactory<Object, Object> producerFactory() {
-// DefaultKafkaProducerFactory<Object, Object> factory = new DefaultKafkaProducerFactory<>(producerConfigs());
-// //寮�鍚簨鍔★紝浼氬鑷� LINGER_MS_CONFIG 閰嶇疆澶辨晥
-// // factory.setTransactionIdPrefix(transactionIdPrefix);
-// return factory;
-// }
-
-// @Bean
-// public KafkaTransactionManager<Object, Object> kafkaTransactionManager(ProducerFactory<Object, Object> producerFactory) {
-// return new KafkaTransactionManager<>(producerFactory);
-// }
@Bean
public KafkaTemplate<String, String> kafkaTemplate(ProducerFactory<String, String> producerFactory) {
--
Gitblit v1.9.3