keycloak-event-listener-rabbitmq

A Keycloak SPI plugin that publishes events to a RabbitMQ messaging broker.

Keycloak Version Compatibility

The version of this plugin is using the same version baseline like Keycloak itself. E.g. the plugin version 25.0.1 is compatible with Keycloak 25.0.1.

A Keycloak SPI plugin that publishes events to a RabbitMq server.

For example here is the notification of the user updated by administrator

routing key: KK.EVENT.ADMIN.MYREALM.SUCCESS.USER.UPDATE
published to exchange: amq.topic
content:

{
  "@class" : "com.github.aznamier.keycloak.event.provider.EventAdminNotificationMqMsg",
  "time" : 1596951200408,
  "realmId" : "MYREALM",
  "authDetails" : {
    "realmId" : "master",
    "clientId" : "********-****-****-****-**********",
    "userId" : "********-****-****-****-**********",
    "ipAddress" : "192.168.1.1"
  },
  "resourceType" : "USER",
  "operationType" : "UPDATE",
  "resourcePath" : "users/********-****-****-****-**********",
  "representation" : "representation details here....",
  "error" : null,
  "resourceTypeAsString" : "USER"
}

The routing key is calculated as follows:

admin events: KK.EVENT.ADMIN.<REALM>.<RESULT>.<RESOURCE_TYPE>.<OPERATION>
client events: KK.EVENT.CLIENT.<REALM>.<RESULT>.<CLIENT>.<EVENT_TYPE>

And because the recommended exchange is a TOPIC (amq.topic),
therefore its easy for Rabbit client to subscribe to selective combinations eg:

all events: KK.EVENT.#
all events from my realm: KK.EVENT.*.MYREALM.#
all error events from my realm: KK.EVENT.*.MYREALM.ERROR.#
all user events from my-relam and my-client: KK.EVENT.*.MY-REALM.*.MY-CLIENT.USER

USAGE:

Download the latest jar or build from source: mvn clean install
Copy jar into your Keycloak
1. Keycloak version 17+ (Quarkus) /opt/keycloak/providers/keycloak-to-rabbit-3.0.5.jar
2. Keycloak version 16 and older /opt/jboss/keycloak/standalone/deployments/keycloak-to-rabbit-3.0.5.jar
Configure as described below (option 1 or 2 or 3)
Restart the Keycloak server
Enable logging in Keycloak UI by adding keycloak-to-rabbitmq
Manage > Events > Config > Events Config > Event Listeners

Configuration

Recommended: OPTION 1: just configure ENVIRONMENT VARIABLES

KK_TO_RMQ_URL - default: localhost
KK_TO_RMQ_PORT - default: 5672
KK_TO_RMQ_VHOST - default: empty
KK_TO_RMQ_EXCHANGE - default: amq.topic
KK_TO_RMQ_USERNAME - default: admin
KK_TO_RMQ_PASSWORD - default: admin
KK_TO_RMQ_USE_TLS - default: false
KK_TO_RMQ_KEY_STORE - default: empty
KK_TO_RMQ_KEY_STORE_PASS - default: empty
KK_TO_RMQ_TRUST_STORE - default: empty
KK_TO_RMQ_TRUST_STORE_PASS - default: empty

Deprecated OPTION 2: edit Keycloak subsystem of WildFly (Keycloak 16 and older) standalone.xml or standalone-ha.xml:

<spi name="eventsListener">
    <provider name="keycloak-to-rabbitmq" enabled="true">
        <properties>
            <property name="url" value="${env.KK_TO_RMQ_URL:localhost}"/>
            <property name="port" value="${env.KK_TO_RMQ_PORT:5672}"/>
            <property name="vhost" value="${env.KK_TO_RMQ_VHOST:}"/>
            <property name="exchange" value="${env.KK_TO_RMQ_EXCHANGE:amq.topic}"/>
            <property name="use_tls" value="${env.KK_TO_RMQ_USE_TLS:false}"/>
            <property name="key_store" value="${env.KK_TO_RMQ_KEY_STORE:}"/>
            <property name="key_store_pass" value="${env.KK_TO_RMQ_KEY_STORE_PASS:}"/> 
            <property name="trust_store" value="${env.KK_TO_RMQ_TRUST_STORE:}"/>
            <property name="trust_store_pass" value="${env.KK_TO_RMQ_TRUST_STORE_PASS:}"/>           
            <property name="username" value="${env.KK_TO_RMQ_USERNAME:guest}"/>
            <property name="password" value="${env.KK_TO_RMQ_PASSWORD:guest}"/>
        </properties>
    </provider>
</spi>

Deprecated OPTION 3 same effect as OPTION 2 but programatically WildFly (Keycloak 16 and older):

echo "yes" | $KEYCLOAK_HOME/bin/jboss-cli.sh --file=$KEYCLOAK_HOME/KEYCLOAK_TO_RABBIT.cli

focus-shift/keycloak-event-listener-rabbitmq