Pavan Kumar pavan538

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)

Cascading Types

Persist: save or persist operations cascade to related entities
Merge: means that related entities are merged, when the owner entity is merged
Refresh: does the same thing for refresh() operation
Remove: removes all the entities association with this setting, when the owining entity is deleted.
Detach: detach all related entities, if a manual detach occurs.
All: shorthand of all related entities.

import asyncio
import threading


def worker():
    second_loop = asyncio.new_event_loop()
    execute_polling_coroutines_forever(second_loop)
    return

	import json, datetime

	class RoundTripEncoder(json.JSONEncoder):
	DATE_FORMAT = "%Y-%m-%d"
	TIME_FORMAT = "%H:%M:%S"
	def default(self, obj):
	if isinstance(obj, datetime.datetime):
	return {
	"_type": "datetime",
	"value": obj.strftime("%s %s" % (

	/*------------------------------------------
	Responsive Grid Media Queries - 1280, 1024, 768, 480
	1280-1024 - desktop (default grid)
	1024-768 - tablet landscape
	768-480 - tablet
	480-less - phone landscape & smaller
	--------------------------------------------*/
	@media all and (min-width: 1024px) and (max-width: 1280px) { }

	@media all and (min-width: 768px) and (max-width: 1024px) { }

	## installation openldap with backend mysql
	sudo apt update && sudo apt upgrade -y && sudo reboot
	sudo apt install mysql-server unixodbc make gcc libmysqlclient-dev unixodbc-dev groff ldap-utils

	## mysql login as root
	sudo mysql -u root

	CREATE DATABASE ldap
	CREATE USER 'ldap'@'%' IDENTIFIED BY 'S3cureP4ssw0rd$';
	GRANT ALL PRIVILEGES ON ldap.* TO 'ldap'@'%';

	curl -XPOST http://localhost:9200/test/articles/1 -d '{
	"content": "The quick brown fox"
	}'
	curl -XPOST http://localhost:9200/test/articles/2 -d '{
	"content": "What does the fox say?"
	}'
	curl -XPOST http://localhost:9200/test/articles/3 -d '{
	"content": "The quick brown fox jumped over the lazy dog"
	}'
	curl -XPOST http://localhost:9200/test/articles/4 -d '{

	<html>
	<head>

	<!--Recommended Meta Tags-->
	<meta charset="utf-8">
	<meta name="language" content="english">
	<meta http-equiv="content-type" content="text/html">
	<meta name="author" content=”Rafayel Mkrtchyan”>
	<meta name="designer" content=”Rafayel Mkrtchyan”>
	<meta name="publisher" content=”Rafayel Mkrtchyan”>

	data = o.to_mongo()
	o_id = data.pop('_id', None)
	if o_id:
	data['id'] = str(o_id)
	data.pop('_cls', None)
	return data

	- This below code will get both responses in parallel.

	import asyncio
	import requests

	@asyncio.coroutine
	def main():
	loop = asyncio.get_event_loop()
	future1 = loop.run_in_executor(None, requests.get, 'http://www.google.com')
	future2 = loop.run_in_executor(None, requests.get, 'http://www.google.co.uk')