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

result = lambda_api.get_event_sources(source_arn='the_')
            self.assertEqual(len(result), 0)
    def test_get_event_sources_with_paths(self):
        with self.app.test_request_context():
            lambda_api.event_source_mappings.append(
                {
                    'UUID': self.TEST_UUID,
                    'EventSourceArn': 'the_arn/path/subpath'
                })
            
            result = lambda_api.get_event_sources(source_arn='the_arn')
            self.assertEqual(len(result), 1)
            result = lambda_api.get_event_sources(source_arn='the_arn/path')
            self.assertEqual(len(result), 1)
    def test_delete_event_source_mapping(self):
        with self.app.test_request_context():
            lambda_api.event_source_mappings.append({'UUID': self.TEST_UUID})
            result = lambda_api.delete_event_source_mapping(self.TEST_UUID)
            self.assertEqual(json.loads(result.get_data()).get('UUID'), self.TEST_UUID)
            self.assertEqual(0, len(lambda_api.event_source_mappings))
    def test_create_event_source_mapping(self):
        self.client.post('{0}/event-source-mappings/'.format(lambda_api.PATH_ROOT),
            data=json.dumps({'FunctionName': 'test-lambda-function', 'EventSourceArn': 'fake-arn'}))
        listResponse = self.client.get('{0}/event-source-mappings/'.format(lambda_api.PATH_ROOT))
        listResult = json.loads(listResponse.get_data())
        eventSourceMappings = listResult.get('EventSourceMappings')
        self.assertEqual(1, len(eventSourceMappings))
        self.assertEqual('Enabled', eventSourceMappings[0]['State'])
    def test_create_disabled_event_source_mapping(self):