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

def do_execute(*args):
            
            invocation_time = int(time.time() * 1000)
            
            try:
                result, log_output = self._execute(func_arn, func_details, event, context, version)
            finally:
                self.function_invoke_times[func_arn] = invocation_time
            
            self._store_logs(func_details, log_output, invocation_time)
            
            return result, log_output
        
        if asynchronous:
            LOG.debug('Lambda executed in Event (asynchronous) mode, no response from this '
                      'function will be returned to caller')
            FuncThread(do_execute).start()
            return None, 'Lambda executed asynchronously.'
        return do_execute()
    def _execute(self, func_arn, func_details, event, context=None, version=None):
        """ This method must be overwritten by subclasses. """
        raise Exception('Not implemented.')
    def startup(self):
        pass
    def cleanup(self, arn=None):
        pass
    def _store_logs(self, func_details, log_output, invocation_time):
        if not aws_stack.is_service_enabled('logs'):