A simple cli for interacting with MSK and Lambda
Lambda consumers of MSK topics have UUID's for consumer group names, which make it difficult to identify which lambda consumers are configured to consume messages from a certain topic
Install Go 1.15
Clone repo
git clone git@github.com:colincgn/emsk.git
from emsk folder.
go build
This will create an executable binary with a few handy commands when working with MSK.
For convenience, you can use some environment variables instead of passing in command line flags on each call.
export EMSK_BOOTSTRAP_SERVERS=1-aws-msk-bootstrap-server:9094,2-aws-msk-bootstrap-server:9094
export EMSK_TLS_ENABLED=TRUE
./emsk topic list
./emsk consumergroup list
example output.
{
"Id": "23c2bf3d-91ea-44bc-8ab1-298f758d4fa7",
"ActiveMembers": 1,
"Members": [
{
"ClientId": "23c2bf3d-91ea-44bc-8ab1-298f758d4fa7",
"Topics": [
"example-topic-one"
]
}
],
"LastKnownStatus": "OK",
"FunctionArn": "arn:function:example-topic-one-dev-ExampleConsumer"
}