;Get topic lag
(require 'clj-aiven.core)


(def aiven-conn {:project "proj-name"
                 :service "serv-name"
                 :token   "aivenv1 token"})
              
                 
(topic-info aiven-conn "topic-name")

(topic-consumer-lag conn "topic-name" "consumer-name")           


----------------------------------------------------------------------------------


;Get topic sizes

(def schema-conn {:url  "***REMOVED***"
                  :user "user"
                  :pass "password"})
                  
(list-topic-sizes conn schema-conn)