blob: 8786ed52734a45b0a0a4d46abd8d8303a7c2583b [file] [log] [blame]
Andy Bavier03df22b2017-08-30 14:46:02 -07001
2# Copyright 2017-present Open Networking Foundation
3#
4# Licensed under the Apache License, Version 2.0 (the "License");
5# you may not use this file except in compliance with the License.
6# You may obtain a copy of the License at
7#
8# http://www.apache.org/licenses/LICENSE-2.0
9#
10# Unless required by applicable law or agreed to in writing, software
11# distributed under the License is distributed on an "AS IS" BASIS,
12# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13# See the License for the specific language governing permissions and
14# limitations under the License.
15
Matteo Scandolo7db85372018-05-22 15:26:55 -070016# Manually send the event
Andy Bavier03df22b2017-08-30 14:46:02 -070017
Matteo Scandolo7db85372018-05-22 15:26:55 -070018import json
19from kafka import KafkaProducer
20
21event = json.dumps({
22 'status': 'activated',
23 'serial_number': 'BRCM1234',
24 'uni_port_id': 16,
25 'of_dpid': 'of:109299321'
26})
Matteo Scandolo62ca52b2018-06-21 17:03:58 -070027producer = KafkaProducer(bootstrap_servers="cord-kafka")
Matteo Scandolo7db85372018-05-22 15:26:55 -070028producer.send("onu.events", event)
29producer.flush()