release: 3.2.0-1.7

Author: iomonad

CHANGELOG.md

@@ -2,6 +2,11 @@
 
 ## [SNAPSHOT]
 
+## [3.2.0-1.6/7]
+- Administration function namespace
+- Test context simplification
+- Test migrations
+
 ## [3.2.0-1.5]
 
 - Kafka Client version bump
@@ -32,4 +37,3 @@
 - basic `consumer` + `process loop`
 - async consumer
 - serialization helpers
-

README.md

@@ -124,6 +124,22 @@ You can set either :threads-by-topic or :threads option (if both are set, :threa
 (fc/poll-loops consumer-cfg print-record {"topic1" 1 "topic2" 4} {:commit-policy :never})
 ```
 
+
+#### Administration
+
+The `felice.admin` provide interface to `Admin` kafka class, used to perform administration
+tasks on your cluster:
+
+```clojure
+(require [felice.admin :as fa])
+
+(with-open [ac (fa/admin-client {:bootstrap.servers "localhost:9092"})]
+  (fa/list-topics ac) ;;=> #{"foo" "bar"}
+  )
+```
+See all the administration methods [on documentation page](https://oscaro.github.io/felice/#felice.admin).
+
+
 #### Partitionning
 
 The partitionner used by a producer can be set using this [configuration key](https://kafka.apache.org/documentation/#producerconfigs_partitioner.class).
@@ -143,7 +159,7 @@ There is a comment at the bottom of the felice.producer namespace mimiking the d
 
 ## License
 
-Copyright © 2018 - 2022 Oscaro
+Copyright © 2018 - 2024 Oscaro
 
 This program and the accompanying materials are made available under the
 terms of the Eclipse Public License 2.0 which is available at

dev/user.clj

@@ -1,5 +1,11 @@
 (ns user
   (:require [felice.consumer :as fc]
-            [felice.producer :as fp]))
+            [felice.producer :as fp]
+            [felice.admin    :as fa]
+            [clojure.reflect :as r]
+            [clojure.pprint  :refer [print-table]]))
 
-;;; Playground
+(defn- dump-object-methods [o]
+  (print-table (:members (r/reflect o))))
+
+(def broker "localhost:9092")

docker-compose.yml

@@ -1,26 +1,8 @@
 version: '3.7'
 
 services:
-  zookeeper:
-    image: wurstmeister/zookeeper
-    container_name: zookeeper
-    hostname: zookeeper-docker
-    expose:
-      - "2181"
-
   kafka:
-    image: wurstmeister/kafka
     container_name: kafka
-    hostname: kafka-docker
-    depends_on:
-      - zookeeper
+    image: vectorized/redpanda:v23.3.10
     ports:
-      - "9092:9092"
-    expose:
-      - "9093"
-    environment:
-      KAFKA_ADVERTISED_LISTENERS: INSIDE://kafka:9093,OUTSIDE://localhost:9092
-      KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: INSIDE:PLAINTEXT,OUTSIDE:PLAINTEXT
-      KAFKA_LISTENERS: INSIDE://0.0.0.0:9093,OUTSIDE://0.0.0.0:9092
-      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
-      KAFKA_INTER_BROKER_LISTENER_NAME: INSIDE
+      - 9092:9092

project.clj

@@ -1,6 +1,6 @@
-(defproject com.oscaro/felice "3.2.0-1.6"
+(defproject com.oscaro/felice "3.2.0-1.7"
   :description "Felice is client library for Apache Kafka in Clojure"
-  :url "https://gitlab.oscaroad.com/it-dev/felice"
+  :url "https://github.com/oscaro/felice"
   :license {:name "Eclipse Public License"
             :url "http://www.eclipse.org/legal/epl-v10.html"}
   :plugins [[lein-marginalia "0.9.1"]]