diff --git a/README.md b/README.md
index e33288e..1673928 100644
--- 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
index 6098557..694d891 100644
--- a/pom.xml
+++ b/pom.xml
@@ -4,12 +4,12 @@
4.0.0
com.github.snuk87.keycloak
keycloak-kafka
- 1.1.0
+ 1.1.1
11
11
- 14.0.0
+ 15.0.2
2.8.0
diff --git a/src/main/java/com/github/snuk87/keycloak/kafka/KafkaEventListenerProviderFactory.java b/src/main/java/com/github/snuk87/keycloak/kafka/KafkaEventListenerProviderFactory.java
index e90474a..62a0b63 100644
--- 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(",");