I am trying to create a consume stream in kinesis. I created my stream using
`awslocal kinesis create-stream --stream-name mylogstream --shard-count 2` 

which worked. Now I am trying to use lambda consumer, following the tutorial [here](https://docs.aws.amazon.com/lambda/latest/dg/with-kinesis.html#services-kinesis-configure), hence I did

`awslocal kinesis register-stream-consumer --consumer-name con1 --stream-arn arn:aws:kinesis:us-east-1:000000000000:stream/mylogstream`  

which resulted in following error:

>An error occurred (UnknownOperationException) when calling the RegisterStreamConsumer operation:

I tried again with `aws` instead of awslocal:

`aws kinesis register-stream-consumer --consumer-name con1 --stream-arn arn:aws:kinesis:us-east-1:000000000000:stream/mylogstream --endpoint-url=http://localhost:4568` 

which again resulted in same error.

I've configured my aws credentials etc. but nothing seems to fix the issue

TAGS = {'hello': 'world', 'env': 'prod'}
    def setUp(self):
        lambda_api.cleanup()
        self.maxDiff = None
        self.app = lambda_api.app
        self.app.testing = True
        self.client = self.app.test_client()
    def test_get_non_existent_function_returns_error(self):
        with self.app.test_request_context():
            result = json.loads(lambda_api.get_function('non_existent_function_name').get_data())
            self.assertEqual(self.RESOURCENOTFOUND_EXCEPTION, result['__type'])
            self.assertEqual(
                self.RESOURCENOTFOUND_MESSAGE % lambda_api.func_arn('non_existent_function_name'),
                result['message'])
    def test_get_event_source_mapping(self):
        with self.app.test_request_context():
            lambda_api.event_source_mappings.append({'UUID': self.TEST_UUID})
            result = lambda_api.get_event_source_mapping(self.TEST_UUID)
            self.assertEqual(json.loads(result.get_data()).get('UUID'), self.TEST_UUID)
    def test_get_event_sources(self):
        with self.app.test_request_context():
            lambda_api.event_source_mappings.append(
                {
                    'UUID': self.TEST_UUID,
                    'EventSourceArn': 'the_arn'
                })
            
            result = lambda_api.get_event_sources(source_arn='the_arn')
            self.assertEqual(len(result), 1)
            self.assertEqual(result[0].get('UUID'), self.TEST_UUID)