Jakub Kriz Jakub3628800

Kafka 0.11.0.0 (Confluent 3.3.0) added support to manipulate offsets for a consumer group via cli kafka-consumer-groups command.

List the topics to which the group is subscribed

kafka-consumer-groups --bootstrap-server <kafkahost:port> --group <group_id> --describe

Note 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.

Reset the consumer offset for a topic (preview)

	---
	name: pre-commit

	on: # yamllint disable-line rule:truthy
	pull_request:
	push:
	branches: [master]

	env:
	SKIP: no-commit-to-branch # Disable the no-commit-to-branch hook in CI

	name: Auto-Update pre-commit Hooks

	on:
	schedule:
	- cron: "0 0 * * 1"
	workflow_dispatch:

	permissions:
	contents: write
	pull-requests: write

	import requests
	import argparse
	import os

	GH_USERNAME = "Jakub3628800"
	GH_REPO = "repository123"
	MAIN_BRANCH = "master"


	auth_header = {

	# Example 0: Unpack a tuple
	weeks = ('monday', 'tuesday', 'wednesday')
	first, second, third = weeks
	print(first, second, third)
	# monday tuesday wednesday

	weeks = ('monday', 'tuesday', 'wednesday', 'thursday', 'friday', 'saturday', 'sunday')
	first, second, *other = weeks
	print(first, second, other)
	# monday tuesday ['wednesday', 'thursday', 'friday', 'saturday', 'sunday']

	# Tuples can be defined with or without brackets
	weekdays = "monday", "tuesday", "wednesday", "thursday", "friday", "saturday", "sunday"

	print(weekdays)
	# ('monday', 'tuesday', 'wednesday', 'thursday', 'friday', 'saturday', 'sunday')

	for week in weekdays:
	print(week)
	# monday
	# tuesday

	from collections import Counter

	items = ["apple", "orange", "apple", "pear", "orange", "apple"]
	item_counts = Counter(items)

	print(item_counts)
	# Counter({'apple': 3, 'orange': 2, 'pear': 1})

	def get_count(q):
	count_q = q.statement.with_only_columns([func.count()]).order_by(None)
	count = q.session.execute(count_q).scalar()
	return count

	q = session.query(TestModel).filter(...).order_by(...)

	# Slow: SELECT COUNT(*) FROM (SELECT ... FROM TestModel WHERE ...) ...
	print q.count()