awslabs/amazon-kinesis-connector-flink

Issues

• AWS Kinesis Stream read from different account fails after upgrade to flink-connector-kinesis 1.15.2

  #65 opened a year ago by spachari-im
  0

• (Python) Unable to convert kinesis table into datastream

  #64 opened 2 years ago by mattfysh
  4

• Publish the latest version to Maven central

  #58 opened 2 years ago by vitaliislobodianyk-okta
  2

• Getting IOException/StacklessClosedChannelException when consuming data from Kinesis

  #51 opened 3 years ago by leonxu8
  1

• SequenceNumber class is not POJO type

  #47 opened 3 years ago by Cyberness
  2

• AmazonKinesisException when authenticating Kinesis through AWS SSO (profile)

  #50 opened 3 years ago by mberchon
  0

• Error occurred on EFO subscription: java.nio.channels.ClosedChannelException - (null).

  #30 opened 3 years ago by ensc-yang
  2

• Problems encountered when using aws connector to replace flink connector to connect kinesis stream in flink

  #34 opened 3 years ago by SOD-DOB
  2

• `FlinkKinesisConsumer` metric groups and publication should be externally configurable

  #29 opened 3 years ago by bobtiernay-okta
  1

• Is there any difference

  #33 opened 3 years ago by Missshao
  2

• Flink Kinesis EFO keep job restart forever after expired first 5 minutes

  #44 opened 3 years ago by totten25
  1

• initpos LATEST triggers InvalidArgumentException

  #13 opened 4 years ago by cizmazia
  13

• A Rare UnknownHostException in Flink Kinesis Consumer

  #27 opened 3 years ago by sepulrator
  3

• An exception in `KinesisDataFetcher#shutdownFetcher` may fail to shutdown `shardConsumersExecutor` leading to job hanging

  #23 opened 3 years ago by bobtiernay-okta
  3

• Confirm if `FanOutShardSubscriber#handleError` should perform `cause instanceof TimeoutException` instead of `ReadTimeoutException`

  #21 opened 3 years ago by bobtiernay-okta
  3

• `KinesisDataFetcher#stopWithError` should log exception so that the root cause can be observed

  #22 opened 3 years ago by bobtiernay-okta
  1

• Test notifications

  #20 opened 3 years ago by dannycranmer
  0

• Test issue

  #14 opened 3 years ago by dannycranmer
  0

• .

  #15 opened 4 years ago by aleksandersumowski
  0

• Multiple Google Guava Dependencies in Package (18 and 26.0-jre)

  #12 opened 4 years ago by dbadami
  4

• Validation exception for shardIteratorType being used with Ddb Stream in Amzn-Kinesis-Connector-Flink

  #9 opened 4 years ago by dbadami
  4