Add admin API operations to promisified and non-promisified API

[milindl]

For example: listing topics, ACL operations, consumer group operations, consumer group offset operations.

[milindl]

Added: ListGroups to list consumer groups

[milindl]

Added: DeleteGroups and DescribeGroups
Added: ListTopics

[brunodomenici]

+1 for describeGroup. We use this function to health check the consumer.
Any idea how to do it without this function?

[milindl]

@brunodomenici , the function is already available in the released version of the library which you can download off npm.

Unfortunately I've not added an example yet, but the usage can be seen in the test: https://github.com/confluentinc/confluent-kafka-javascript/blob/v0.1.12-devel/test/promisified/admin/describe_groups.spec.js#L71

[nhr-one]

Hi @milindl - are there any plans to add the setOffsets functionality to the Admin Client in the near future? My company is in the process of migrating from KafkaJS -> @confluentinc/kafka-javascript, and that is a key feature blocking our full migration between the libraries. We use it to initialize consumers to offsets that aren't the start or end of topics.

[milindl]

We plan to implement setOffsets, but we don't have a timeline in mind yet.

Thanks for attaching your use case, there's actually a way to do this, maybe it helps in the meanwhile, the rebalance cb can be used to set offsets at assignment time, for example:

const consumer = kafka.consumer({
            rebalance_cb: function (err, assignment) {
                if (err.code === ErrorCodes.ERR__ASSIGN_PARTITIONS) {
                    // whatever you return here will be what will be assigned. You can change offsets here. Note that the offsets are numbers, not strings.
                    return assignment.map(a => ({...a, offset: 2}));
                }
            }
      //... your other config ...
});

Unlike setOffsets, this won't actually change the offsets on the broker side, but only what the particular consumer will start consuming from, however maybe for your use case it can help.