| # Written by Arsham Arya | |
| # I'm not sure it's the best way, | |
| # So any contribution makes me and other readers happy :) | |
| from psycopg2.pool import ThreadedConnectionPool | |
| import config | |
| _CONNECTION_POOL = None |
| from tkinter import * | |
| from tkinter import messagebox | |
| root = Tk() | |
| root.geometry("480x170") | |
| root.title("Raha Contacts books") | |
| Name = StringVar() | |
| Number = StringVar() | |
| Address = StringVar() |
| """ | |
| Written by Arsham Arya | |
| I'm not sure it's the best way, | |
| So any contribution makes everyone happy! | |
| """ | |
| # pip install requests | |
| from requests import get | |
| # Config is can is a dictionary of ENV variables including TMDB_API_KEY | |
| # https://gist.github.com/arshamalh/16a42854cb43bbe48038c7431529a552 |
| version: '3.8' | |
| services: | |
| jaeger: | |
| image: jaegertracing/all-in-one:1.51 # At least 1.35 if you want to have enabled collector | |
| container_name: jaeger | |
| environment: | |
| - COLLECTOR_ZIPKIN_HOST_PORT=:9411 | |
| - COLLECTOR_OTLP_ENABLED=true | |
| ports: # Some ports are optional or deprecated, but we still let them be here as it's a general snippet | |
| - "5775:5775/udp" # agent accept zipkin.thrift over compact thrift protocol (deprecated, used by legacy clients only) |
| """ | |
| Written by Arsham Arya | |
| I'm not sure it's the best way, | |
| So any contribution makes everyone happy! | |
| """ | |
| from os import environ | |
| # pip install python-dotenv | |
| from dotenv import dotenv_values |
| Producer | |
| Setup | |
| bin/kafka-topics.sh --zookeeper esv4-hcl197.grid.linkedin.com:2181 --create --topic test-rep-one --partitions 6 --replication-factor 1 | |
| bin/kafka-topics.sh --zookeeper esv4-hcl197.grid.linkedin.com:2181 --create --topic test --partitions 6 --replication-factor 3 | |
| Single thread, no replication | |
| bin/kafka-run-class.sh org.apache.kafka.clients.tools.ProducerPerformance test7 50000000 100 -1 acks=1 bootstrap.servers=esv4-hcl198.grid.linkedin.com:9092 buffer.memory=67108864 batch.size=8196 |
| # import config. | |
| # You can change the default config with `make cnf="config_special.env" build` | |
| cnf ?= config.env | |
| include $(cnf) | |
| export $(shell sed 's/=.*//' $(cnf)) | |
| # import deploy config | |
| # You can change the default deploy config with `make cnf="deploy_special.env" release` | |
| dpl ?= deploy.env | |
| include $(dpl) |
| How to delete an image tag/image from docker registry v2.4 | |
| 1) Re/Start registry with delete option enabled | |
| Edit the config.yml | |
| storage: | |
| delete: | |
| enabled: true |
Kafka 0.11.0.0 (Confluent 3.3.0) added support to manipulate offsets for a consumer group via cli kafka-consumer-groups command.
kafka-consumer-groups --bootstrap-server <kafkahost:port> --group <group_id> --describeNote the values under "CURRENT-OFFSET" and "LOG-END-OFFSET". "CURRENT-OFFSET" is the offset where this consumer group is currently at in each of the partitions.