senzing-garage/stream-producer

Fix use of kafka_group

Closed this issue · 0 comments

docktermj commented

Describe the bug

Two parts:

  1. Currently kafka_group_id is used in configuration. https://github.com/Senzing/stream-producer/blob/f7743d9a75e29539e4cb4da7e891ff2596f7582d/stream-producer.py#L1268-L1269 In stream-loader the variable is kafka_group https://github.com/Senzing/stream-loader/blob/e666c3f7a7f21a55c051fa91c9aa1831b485f185/stream-loader.py#L1455

The fix: In stream-producer.py, change kafka_group_id to kafka_group so it matches stream-loader.py.

  1. stream-producer.py, doesn't not currently have CLI option, nor OS environment variable support for kafka_group. It needs to be added (In stream-loader.py: https://github.com/Senzing/stream-loader/blob/e666c3f7a7f21a55c051fa91c9aa1831b485f185/stream-loader.py#L146-L150)