Tom K tlk3
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| from deephaven.stream.kafka import consumer as kc | |
| from deephaven import dtypes as dht | |
| from deephaven import time as dhtu | |
| from deephaven import agg | |
| from deephaven.plot.figure import Figure | |
| kafka_conf = { | |
| "bootstrap.servers": "127.0.0.1:9093", | |
| "security.protocol": "SASL_PLAINTEXT", |