AutMaple’s gists

AutMaple / javascript.json

Created September 12, 2023 05:55

[vim snippets] 自动转换自定义的 snippets #vim #snippets

AutMaple / prettierrc.js

Created September 12, 2023 05:50

[prettier] prettier 配置文件 #prettier

AutMaple / consumer.py

Created August 30, 2023 03:49

[kafka消费者和生产者] #kafka,#python

	#!/home/autmaple/Tools/personal/kafka/.venv/bin/python

	from confluent_kafka import Consumer, KafkaError
	import argparse

	parser = argparse.ArgumentParser(description='Kafka Producer')
	parser.add_argument('--broker', required=True, help='Kafka broker address')
	parser.add_argument('--topic', required=True, help='Kafka topic to produce to')
	args = parser.parse_args()

AutMaple / Application.java

Last active September 14, 2023 06:19

[Flink+Iceberg+Minio] #flink,#iceberg,#minio,#java

	package org.example;

	import org.apache.flink.api.common.eventtime.WatermarkStrategy;
	import org.apache.flink.api.common.serialization.SimpleStringSchema;
	import org.apache.flink.api.java.utils.ParameterTool;
	import org.apache.flink.connector.kafka.source.KafkaSource;
	import org.apache.flink.connector.kafka.source.enumerator.initializer.OffsetsInitializer;
	import org.apache.flink.streaming.api.datastream.DataStream;
	import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
	import org.apache.flink.types.Row;

AutMaple / ConsumerCallback.java

Last active August 31, 2023 07:54

[MQTT 作为 Flink 输入源] #flink #mqtt #java

	package org.example;

	import lombok.RequiredArgsConstructor;
	import lombok.extern.slf4j.Slf4j;
	import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
	import org.eclipse.paho.client.mqttv3.MqttCallback;
	import org.eclipse.paho.client.mqttv3.MqttClient;
	import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
	import org.eclipse.paho.client.mqttv3.MqttException;
	import org.eclipse.paho.client.mqttv3.MqttMessage;

AutMaple / EagerSingleton.java

Last active July 11, 2023 06:20

[单例模式] #设计模式

	// 饿汉式单例模式，并发安全，但是会浪费系统资源。
	public class EagerSingleton {
	private static EagerSingleton instance = new EagerSingleton();
	private EagerSingleton(){}

	public static EagerSingleton getInstance(){
	return instance;
	}
	}

AutMaple / AndExpression.java

Last active July 8, 2023 03:59

[规格模式] #设计模式#

	@RequiredArgsConstructor
	public class AndExpression extends CompositeExpression {
	private final Expression left;
	private final Expression right;

	@Override
	public boolean compute(Map<String, Double> data) {
	return left.compute(data) && right.compute(data);
	}
	}

AutMaple / GatewaySecurityConfig.java

Last active May 5, 2023 07:19

[Spring Cloud Gateway 作为 OAuth2 Resource Server 整合 Keycloak] #Keycloak #SpringCloudGateway #OAuth2

	package com.autmaple.config;

	import org.springframework.context.annotation.Bean;
	import org.springframework.context.annotation.Configuration;
	import org.springframework.security.config.web.server.ServerHttpSecurity;
	import org.springframework.security.oauth2.jose.jws.SignatureAlgorithm;
	import org.springframework.security.oauth2.jwt.NimbusReactiveJwtDecoder;
	import org.springframework.security.oauth2.jwt.ReactiveJwtDecoder;
	import org.springframework.security.web.server.SecurityWebFilterChain;

AutMaple / .gitignore

Created February 27, 2023 07:12

[.gitignore]

	target/
	!.mvn/wrapper/maven-wrapper.jar
	!/src/main//target/
	!/src/test//target/

	### IntelliJ IDEA ###
	.idea/modules.xml
	.idea/jarRepositories.xml
	.idea/compiler.xml
	.idea/libraries/

AutMaple / RedisUtil.java

Last active January 15, 2023 12:44

[工具类仓库]

	package com.autmaple.oauth.components.redis;

	import com.autmaple.oauth.common.utils.SpringUtil;
	import org.springframework.data.redis.core.RedisCallback;
	import org.springframework.data.redis.core.RedisTemplate;

	import java.util.Collection;
	import java.util.List;
	import java.util.Map;
	import java.util.Set;

AutMaple AutMaple