Merge pull request #12 from SnuK87/hotfix/default-config-values

Hotfix/default config values
SnuK87 · Aug 23, 2021 · 74debfb · 74debfb
2 parents e0f5db2 + e3c368d
commit 74debfb
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 8 deletions.
diff --git a/README.md b/README.md
@@ -17,7 +17,7 @@ Simple module for [Keycloak](https://www.keycloak.org/) to produce keycloak even
 
 Kafka version: `2.12-2.1.x`, `2.12-2.4.x`, `2.12-2.5.x`, `2.13-2.8`
 
-Keycloak version: `4.8.3`, `6.0.x`, `7.0.0`, `9.0.x`, `10.0.x`, `13.0.x`, `14.0.x`
+Keycloak version: `4.8.3`, `6.0.x`, `7.0.0`, `9.0.x`, `10.0.x`, `13.0.x`, `14.0.x` `15.0.x`
 
 Java version: `11`, `13`
 

diff --git a/pom.xml b/pom.xml
@@ -4,12 +4,12 @@
 	<modelVersion>4.0.0</modelVersion>
 	<groupId>com.github.snuk87.keycloak</groupId>
 	<artifactId>keycloak-kafka</artifactId>
-	<version>1.1.0</version>
+	<version>1.1.1</version>
 
 	<properties>
 		<maven.compiler.source>11</maven.compiler.source>
 		<maven.compiler.target>11</maven.compiler.target>
-		<keycloak.version>14.0.0</keycloak.version>
+		<keycloak.version>15.0.2</keycloak.version>
 		<kafka.version>2.8.0</kafka.version>
 	</properties>
 

diff --git a/src/main/java/com/github/snuk87/keycloak/kafka/KafkaEventListenerProviderFactory.java b/src/main/java/com/github/snuk87/keycloak/kafka/KafkaEventListenerProviderFactory.java
@@ -41,12 +41,12 @@ public String getId() {
 	@Override
 	public void init(Scope config) {
 		LOG.info("Init kafka module ...");
-		topicEvents = config.get("topicEvents");
-		clientId = config.get("clientId", "keycloak");
-		bootstrapServers = config.get("bootstrapServers");
-		topicAdminEvents = config.get("topicAdminEvents");
+		topicEvents = config.get("topicEvents", System.getenv("KAFKA_TOPIC"));
+		clientId = config.get("clientId", System.getenv("KAFKA_CLIENT_ID"));
+		bootstrapServers = config.get("bootstrapServers", System.getenv("KAFKA_BOOTSTRAP_SERVERS"));
+		topicAdminEvents = config.get("topicAdminEvents", System.getenv("KAFKA_ADMIN_TOPIC"));
 
-		String eventsString = config.get("events");
+		String eventsString = config.get("events", System.getenv("KAFKA_EVENTS"));
 
 		if (eventsString != null) {
 			events = eventsString.split(",");