cudf: [BUG] Kafka external datasource to follow CK convention of creating consumer
from custreamz import kafka
consumer = kafka.KafkaHandle(kafka_configs, topics=[topic], partitions=[partition]) needs to be changed to consumer = kafka.Consumer(kafka_configs)
About this issue
- Original URL
- State: closed
- Created 4 years ago
- Comments: 15 (11 by maintainers)
@chinmaychandak @jsmaupin I did validate that the timeout is being honored.