From 77c1e617587947c431b77773f53da5e222f4dd61 Mon Sep 17 00:00:00 2001
From: Anton Tananaev <anton@traccar.org>
Date: Mon, 14 Nov 2022 08:19:22 -0800
Subject: Customizable Kafka topic

---
 src/main/java/org/traccar/config/Keys.java | 16 ++++++++++++++++
 1 file changed, 16 insertions(+)

(limited to 'src/main/java/org/traccar/config/Keys.java')

diff --git a/src/main/java/org/traccar/config/Keys.java b/src/main/java/org/traccar/config/Keys.java
index 2224192d9..9ae71921e 100644
--- a/src/main/java/org/traccar/config/Keys.java
+++ b/src/main/java/org/traccar/config/Keys.java
@@ -706,6 +706,14 @@ public final class Keys {
             List.of(KeyType.CONFIG),
             "url");
 
+    /**
+     * Position forwarding Kafka topic.
+     */
+    public static final ConfigKey<String> FORWARD_TOPIC = new StringConfigKey(
+            "forward.topic",
+            List.of(KeyType.CONFIG),
+            "positions");
+
     /**
      * URL to forward positions. Data is passed through URL parameters. For example, {uniqueId} for device identifier,
      * {latitude} and {longitude} for coordinates.
@@ -767,6 +775,14 @@ public final class Keys {
             List.of(KeyType.CONFIG),
             "json");
 
+    /**
+     * Events forwarding Kafka topic.
+     */
+    public static final ConfigKey<String> EVENT_FORWARD_TOPIC = new StringConfigKey(
+            "event.forward.topic",
+            List.of(KeyType.CONFIG),
+            "events");
+
     /**
      * Events forwarding URL.
      */
-- 
cgit v1.2.3