From user-return-11211-archive-asf-public=cust-asf.ponee.io@zookeeper.apache.org Tue Jan 16 13:55:16 2018 Return-Path: X-Original-To: archive-asf-public@eu.ponee.io Delivered-To: archive-asf-public@eu.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by mx-eu-01.ponee.io (Postfix) with ESMTP id CE0B718065B for ; Tue, 16 Jan 2018 13:55:16 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id BDF56160C34; Tue, 16 Jan 2018 12:55:16 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id DD7E0160C26 for ; Tue, 16 Jan 2018 13:55:15 +0100 (CET) Received: (qmail 71305 invoked by uid 500); 16 Jan 2018 12:55:14 -0000 Mailing-List: contact user-help@zookeeper.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@zookeeper.apache.org Delivered-To: mailing list user@zookeeper.apache.org Received: (qmail 71293 invoked by uid 99); 16 Jan 2018 12:55:14 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 16 Jan 2018 12:55:14 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id 8D5201A2611 for ; Tue, 16 Jan 2018 12:55:13 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.878 X-Spam-Level: * X-Spam-Status: No, score=1.878 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, HTML_MESSAGE=2, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H4=-0.01, RCVD_IN_MSPIKE_WL=-0.01, SPF_HELO_PASS=-0.001, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd2-us-west.apache.org (amavisd-new); dkim=pass (1024-bit key) header.d=expertsystem.com Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id RQJbp5EJ2gpN for ; Tue, 16 Jan 2018 12:55:11 +0000 (UTC) Received: from EUR01-HE1-obe.outbound.protection.outlook.com (mail-he1eur01on0088.outbound.protection.outlook.com [104.47.0.88]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id 2F5F95F2FD for ; Tue, 16 Jan 2018 12:55:11 +0000 (UTC) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=expertsystem.com; s=selector1; h=From:Date:Subject:Message-ID:Content-Type:MIME-Version; bh=4ubqHyF3ppZbHU79xdNDz286AMFqLQZp1gQpUM58XvM=; b=kGNMjCM3AtTN8Eopv1SAz+xrDJJzTQSeMjCcWhJqToO+BHFS2hWnTXj4/l4u2ScOG/YeTlVmX4SomzjK4d3lSpYW1uuxZuh326aP3dbCZnRWRhDrZ7twS6liergVvR1VjQQTW1gsqSJOCQk5EPvjT22HyCWUpLxDbCopVGB0J+o= Received: from HE1PR04MB1227.eurprd04.prod.outlook.com (10.162.249.152) by HE1PR04MB1225.eurprd04.prod.outlook.com (10.162.249.150) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA384_P256) id 15.20.407.7; Tue, 16 Jan 2018 12:54:52 +0000 Received: from HE1PR04MB1227.eurprd04.prod.outlook.com ([fe80::905a:5550:e39:c8a8]) by HE1PR04MB1227.eurprd04.prod.outlook.com ([fe80::905a:5550:e39:c8a8%14]) with mapi id 15.20.0407.012; Tue, 16 Jan 2018 12:54:52 +0000 From: Bruno Freudensprung To: "user@zookeeper.apache.org" Subject: Observers: a link to message bus? Thread-Topic: Observers: a link to message bus? Thread-Index: AdOOxy0eYlHcXmWIRB2aK3HA0H5fow== Date: Tue, 16 Jan 2018 12:54:52 +0000 Message-ID: Accept-Language: fr-FR, en-US Content-Language: fr-FR X-MS-Has-Attach: X-MS-TNEF-Correlator: authentication-results: spf=none (sender IP is ) smtp.mailfrom=bfreudensprung@expertsystem.com; x-originating-ip: [109.26.135.236] x-ms-publictraffictype: Email x-microsoft-exchange-diagnostics: 1;HE1PR04MB1225;7:mgE2kdPfjym7JR3L6Hqqkw5lr/6t51X8h3dShaPXhQjlwm947qubK+Ofywl3iZkaa1UCQRA+VrDzB2wW3CiFmKmiQdQkQvloCKSAFK07igblBsgxDY9wR4tqct0Y0kDnkMy6WV7OHh+4wIMKPNF6Uydud/JHy7G6MfL6WV6K0sLrwEcZSNykz8rNS0tzYfP3ITpibMYaIBuUISMxbmqn+ml3pMMfdqtNgeEr1ZJOV2guiV+X/4lFBK3wJo9mRFop x-ms-exchange-antispam-srfa-diagnostics: SSOS; x-ms-office365-filtering-correlation-id: 0b449db1-4cd0-475c-571a-08d55ce05598 x-microsoft-antispam: UriScan:;BCL:0;PCL:0;RULEID:(7020095)(4652020)(5600026)(4604075)(3008032)(2017052603307)(7153060)(7193020);SRVR:HE1PR04MB1225; x-ms-traffictypediagnostic: HE1PR04MB1225: x-microsoft-antispam-prvs: x-exchange-antispam-report-test: UriScan:(28532068793085)(21748063052155); x-exchange-antispam-report-cfa-test: BCL:0;PCL:0;RULEID:(6040470)(2401047)(8121501046)(5005006)(3002001)(10201501046)(93006095)(93001095)(3231023)(944501161)(6041268)(201703131423095)(201702281528075)(20161123555045)(201703061421075)(201703061406153)(20161123560045)(20161123564045)(20161123562045)(20161123558120)(6072148)(201708071742011);SRVR:HE1PR04MB1225;BCL:0;PCL:0;RULEID:(100000803101)(100110400095);SRVR:HE1PR04MB1225; x-forefront-prvs: 0554B1F54F x-forefront-antispam-report: SFV:NSPM;SFS:(10009020)(396003)(39380400002)(376002)(39850400004)(366004)(346002)(189003)(199004)(9686003)(316002)(2900100001)(33656002)(25786009)(99286004)(68736007)(3846002)(790700001)(6116002)(7696005)(6436002)(5640700003)(53936002)(6306002)(97736004)(54896002)(7110500001)(55016002)(236005)(106356001)(3280700002)(478600001)(2351001)(6916009)(6506007)(3660700001)(105586002)(86362001)(2906002)(74316002)(14454004)(81166006)(2501003)(102836004)(7736002)(5660300001)(5890100001)(15650500001)(2420400007)(10710500007)(5250100002)(606006)(8676002)(81156014)(59450400001)(1730700003)(66066001)(26005)(8936002);DIR:OUT;SFP:1101;SCL:1;SRVR:HE1PR04MB1225;H:HE1PR04MB1227.eurprd04.prod.outlook.com;FPR:;SPF:None;PTR:InfoNoRecords;MX:1;A:1;LANG:en; received-spf: None (protection.outlook.com: expertsystem.com does not designate permitted sender hosts) x-microsoft-antispam-message-info: zWJB6vygqVT/szDZ9utOmHruh78gBcmWxaqtTFmB+65zy5M9GcH+lNaQK+UlUxfFkh60tgqrUeU4uLbocIO5JA== spamdiagnosticoutput: 1:99 spamdiagnosticmetadata: NSPM Content-Type: multipart/alternative; boundary="_000_HE1PR04MB1227BBEE5902D82C296F9583BAEA0HE1PR04MB1227eurp_" MIME-Version: 1.0 X-OriginatorOrg: expertsystem.com X-MS-Exchange-CrossTenant-Network-Message-Id: 0b449db1-4cd0-475c-571a-08d55ce05598 X-MS-Exchange-CrossTenant-originalarrivaltime: 16 Jan 2018 12:54:52.0488 (UTC) X-MS-Exchange-CrossTenant-fromentityheader: Hosted X-MS-Exchange-CrossTenant-id: 70eedb9c-d90d-466a-95c8-af1bb635543b X-MS-Exchange-Transport-CrossTenantHeadersStamped: HE1PR04MB1225 --_000_HE1PR04MB1227BBEE5902D82C296F9583BAEA0HE1PR04MB1227eurp_ Content-Type: text/plain; charset="us-ascii" Content-Transfer-Encoding: quoted-printable Hi, I have a question regarding this part of the Observers Guide (https://zooke= eper.apache.org/doc/r3.4.11/zookeeperObservers.html): "As a link to a message bus : [...] Observers would give a natural integrat= ion point for this work: a plug-in mechanism could be used to attach the st= ream of proposals an Observer sees to a publish-subscribe system" I've not been able to find such a plug-in mechanism in the source code of Z= ooKeeper. For the moment the only integration point I can think of is the c= ommitRequest method of the org.apache.zookeeper.server.quorum.ObserverZooK= eeperServer class. Am I looking in the right direction? To be honest: this is for the moment only pure curiosity since Apache Kafka= seems to be a more "natural" and out-of-the-box option for an ordered mess= age bus. However since I might probably need ZooKeeper for its distributed = lock and leader election features, I was wondering if I could use it as an = ordered message bus as well. Best regards, Bruno. --_000_HE1PR04MB1227BBEE5902D82C296F9583BAEA0HE1PR04MB1227eurp_--