diff --git a/confluent_client/bin/nodeeventlog b/confluent_client/bin/nodeeventlog index 0a0686f6..680ea400 100755 --- a/confluent_client/bin/nodeeventlog +++ b/confluent_client/bin/nodeeventlog @@ -163,5 +163,9 @@ if options.lines: evtdata_list = evtdata_list[-abs(options.lines):] for evt in evtdata_list: if options.timeframe: - pass - print('{0}: {1}'.format(node, format_event(evt))) + if 'timestamp' in evt and evt['timestamp'] is not None: + display = dt.strptime(evt['timestamp'], '%Y-%m-%dT%H:%M:%S') + if display > timeframe: + print('{0}: {1}'.format(node, format_event(evt))) + else: + print('{0}: {1}'.format(node, format_event(evt)))