Skip to content
This repository was archived by the owner on Mar 13, 2025. It is now read-only.
This repository was archived by the owner on Mar 13, 2025. It is now read-only.

[$75] Update apps to use the no-kafka group consumer #221

@jmgasper

Description

@jmgasper

Topcoder has requested that we move from the kafka SimpleConsumer

this.consumer = new kafka.SimpleConsumer(config.KAFKA_OPTIONS);

To a group consumer, similar to what's seen here:

https://github.com/topcoder-platform/submission-processor/blob/68c1efabe9adb9e67c3a8c425c78a7ae1c030c0f/src/app.js#L14

We should ensure that we add the KAFKA_GROUP_ID to the configuration, document it in the configuration.md and make sure that the receiver and processor both work as expected with the change.

Metadata

Metadata

Assignees

Labels

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions