I've been working with Apache Kafka for over 7 years. I inevitably find myself doing the same set of activities while I'm developing or working with someone else's system. Here's a set of Kafka productivity hacks for doing a few things way faster than you're probably doing them now. 🔥
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
#!/usr/bin/env bb | |
;; convert.clj -- babashka edn/json/yaml to edn/json/yaml converter | |
;; Author: github.com/KGOH/ | |
;; Source: gist.github.com/KGOH/50c0f66022fea2ac173518a143238058 | |
;; Version: 2020.3 | |
; Usage example: | |
; In Emacs: i.imgur.com/TIEDmga.mp4 | |
; $ convert.clj edn <<< '{"foo": "bar"}' | |
; {:foo "bar"} |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
(ns datascript-crux.pull-api | |
(:require | |
[crux.api :as crux] | |
[datascript.pull-parser :as dpp] | |
[my-app.crux-node :refer [crux-node]]) | |
(:import [datascript.pull_parser PullSpec])) | |
;; lightly adapted from: | |
;; https://github.com/tonsky/datascript/blob/master/src/datascript/pull_api.cljc | |
;; https://github.com/tonsky/datascript/blob/master/src/datascript/pull_parser.cljc |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
(ns crux-pull | |
(:require | |
[edn-query-language.core :as eql] | |
[crux.api :as crux] | |
[my-app.crux-node :refer [crux-node]])) | |
(defn entity | |
([entity-id] (entity crux-node entity-id)) | |
([crux-node entity-id] | |
(crux/entity (crux/db crux-node) entity-id))) |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
;; inspired by: https://clojuredocs.org/clojure.zip/zipper#example-54d91161e4b081e022073c72 | |
(defn map-zipper | |
[m ref-keys] | |
{:pre [(set? ref-keys)]} | |
(z/zipper | |
(fn is-branch? [x] | |
(let [ret | |
(cond | |
(not (coll? x)) |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
[Test] | |
public void CursorShouldGetLessOrEqual() { | |
_db = _txn.OpenDatabase(flags: DbFlags.None); | |
var db2 = _txn.OpenDatabase("test_le", | |
DbFlags.Create | DbFlags.IntegerKey); | |
using (var cur = _txn.CreateCursor(db2)) { | |
int[] keys = new int[10000000]; |
NewerOlder