RetroSearch Browse

Home - News ( United States | United Kingdom | Italy | Germany ) - Football scores

Showing content from https://github.com/SahilKang/cl-rdkafka/commit/cd47e1a67f6dcf6b22f0b9e93a4486d8c5ab88fa below:

Merge pull request #69 from SahilKang/misc · SahilKang/cl-rdkafka@cd47e1a · GitHub

File tree Expand file treeCollapse file tree 7 files changed

+56

-5

lines changed

Filter options

Expand file treeCollapse file tree 7 files changed

+56

-5

lines changed Original file line number Diff line number Diff line change


 @@ -1,5 +1,15 @@

1 1


 # Changelog

2 2 3

+
 ## [1.2.1] - 2023-01-08

4 + 5

+
 ### Fixed

6 + 7

+
 * When checking the return value's type, key and value producer

8

+
 serializers no longer traverse the return value if it's a

9

+
 `(vector (unsigned-byte 8))`.

10 + 11

+
 * Set `client.software.name` and `client.software.version` configs.

12 + 3 13


 ## [1.2.0] - 2022-12-30

4 14 5 15


 ### Added

Original file line number Diff line number Diff line change


 @@ -1,5 +1,5 @@

1 1


 Copyright (C) 2018-2020 Sahil Kang <sahil.kang@asilaycomputing.com>

2

-
 Copyright 2022 Google LLC

2

+
 Copyright 2022-2023 Google LLC

3 3 4 4


 All parts of cl-rdkafka are licensed under the GNU GPLv3 as detailed below.

5 5 Original file line number Diff line number Diff line change


 @@ -1,4 +1,5 @@

1 1


 ;;; Copyright (C) 2018-2020 Sahil Kang <sahil.kang@asilaycomputing.com>

2

+
 ;;; Copyright 2023 Google LLC

2 3

;;;

3 4


 ;;; This file is part of cl-rdkafka.

4 5

;;;


 @@ -131,8 +132,6 @@ If TYPE is :TOPIC, then NAME should be the topic-name."))

131 132


 (%alter-config pointer topic config timeout-ms))

132 133 133 134 134

-
 ;; TODO debian stable's version of librdkafka doesn't have the

135

-
 ;; rd-kafka-conf function so figure out a unit-testing approach later

136 135


 (def-admin-methods get-conf (client)

137 136


 (let ((conf (cl-rdkafka/ll:rd-kafka-conf pointer))

138 137


 kv-pairs

Original file line number Diff line number Diff line change


 @@ -1,4 +1,5 @@

1 1


 ;;; Copyright (C) 2018-2020 Sahil Kang <sahil.kang@asilaycomputing.com>

2

+
 ;;; Copyright 2023 Google LLC

2 3

;;;

3 4


 ;;; This file is part of cl-rdkafka.

4 5

;;;


 @@ -48,4 +49,4 @@ functions.")

48 49


 (typep elt '(unsigned-byte 8)))

49 50


 seq)))

50 51 51

-
 (deftype byte-seq () '(satisfies byte-seq-p))

52

+
 (deftype byte-seq () '(or (vector (unsigned-byte 8)) (satisfies byte-seq-p)))

Original file line number Diff line number Diff line change


 @@ -1,4 +1,5 @@

1 1


 ;;; Copyright (C) 2018-2020 Sahil Kang <sahil.kang@asilaycomputing.com>

2

+
 ;;; Copyright 2023 Google LLC

2 3

;;;

3 4


 ;;; This file is part of cl-rdkafka.

4 5

;;;


 @@ -102,6 +103,12 @@

102 103


 ,@(when old-version-p

103 104


 `(,rd-kafka-topic-conf (alloc-rd-kafka-topic-conf))))

104 105


 ,@body

106

+
 (,set-keyval "client.software.name" "cl-rdkafka")

107

+
 (,set-keyval "client.software.version"

108

+
 (format nil "v~A-librdkafka-v~A"

109

+
 (asdf:component-version

110

+
 (asdf:find-system 'cl-rdkafka))

111

+
 (cl-rdkafka/ll:rd-kafka-version-str)))

105 112


 ,@(when old-version-p

106 113


 `((cl-rdkafka/ll:rd-kafka-conf-set-default-topic-conf

107 114


 ,rd-kafka-conf

Original file line number Diff line number Diff line change


 @@ -1,4 +1,5 @@

1 1


 ;;; Copyright (C) 2018-2020 Sahil Kang <sahil.kang@asilaycomputing.com>

2

+
 ;;; Copyright 2023 Google LLC

2 3

;;;

3 4


 ;;; This file is part of cl-rdkafka.

4 5

;;;


 @@ -228,6 +229,39 @@

228 229


 (is (string= "LogAppendTime" (funcall get-actual))))))

229 230 230 231 232

+
 (test get-topic-with-consumer

233

+
 (with-topics ((topic "get-topic-with-consumer"))

234

+
 (let* ((consumer (make-instance

235

+
 'kf:consumer

236

+
 :conf (list "bootstrap.servers" *bootstrap-servers*)))

237

+
 (config (kf::get-conf consumer)))

238

+
 (is (string= "cl-rdkafka"

239

+
 (cdr (assoc "client.software.name" config :test #'string=))))

240

+
 (let ((version (format nil "v~A-librdkafka-v~A"

241

+
 (asdf:component-version

242

+
 (asdf:find-system 'cl-rdkafka))

243

+
 (cl-rdkafka/ll:rd-kafka-version-str))))

244

+
 (is (string= version

245

+
 (cdr (assoc "client.software.version" config

246

+
 :test #'string=))))))))

247 + 248

+
 (test get-topic-with-producer

249

+
 (with-topics ((topic "get-topic-with-producer"))

250

+
 (let* ((producer (make-instance

251

+
 'kf:producer

252

+
 :conf (list "bootstrap.servers" *bootstrap-servers*)))

253

+
 (config (kf::get-conf producer)))

254

+
 (is (string= "cl-rdkafka"

255

+
 (cdr (assoc "client.software.name" config :test #'string=))))

256

+
 (let ((version (format nil "v~A-librdkafka-v~A"

257

+
 (asdf:component-version

258

+
 (asdf:find-system 'cl-rdkafka))

259

+
 (cl-rdkafka/ll:rd-kafka-version-str))))

260

+
 (is (string= version

261

+
 (cdr (assoc "client.software.version" config

262

+
 :test #'string=))))))))

263 + 264 + 231 265


 (test cluster-metadata-with-consumer

232 266


 (with-topics ((topic "cluster-metadata-with-consumer"))

233 267


 (destructuring-bind (host port)

Original file line number Diff line number Diff line change


 @@ -1 +1 @@

1

-
 "1.2.0"

1

+
 "1.2.1"

You can’t perform that action at this time.

RetroSearch is an open source project built by @garambo | Open a GitHub Issue

Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo

HTML: 3.2 | Encoding: UTF-8 | Version: 0.7.4