WW-Digital reactive-kinesis issues

WW-Digital / reactive-kinesis

A Scala & Akka based implementation for working with Amazon Kinesis Streams

Apache License 2.0

34 stars 13 forks source link

issues

Newest

Newest Most commented Recently updated Oldest Least commented Least recently updated

Please publish reactive-kinesis 0.6.13 also for scala 2.12

#82 danielspigel opened 3 years ago
0
Update fork

#81 saeltz closed 4 years ago
0
Kinesis Retries scheme for KPL

#80 ww-jesusaguilar closed 4 years ago
1
Force checkpoint before shutting down terminated shards

#79 easel closed 4 years ago
2
Update kinesis client library: 1.9.3 -> 1.11.1

#78 markus1189 closed 4 years ago
2
Cross compile for Scala 2.13.0

#77 markus1189 closed 4 years ago
5
Publish binaries for 0.6.12

#76 Jacoby6000 opened 5 years ago
0
Kinesis Client Issues?

#75 chasdevs closed 4 years ago
6
Upgrade amazon-kinesis-client to 1.9.3

#74 JannikArndt closed 5 years ago
3
JodaTime -> java.time

#73 Slakah opened 5 years ago
1
0.6.11 not available for scala 2.12

#72 dobrien27 closed 5 years ago
6
New conf represented in reference.conf

#71 etspaceman closed 5 years ago
1
Update dependencies

#70 JannikArndt closed 5 years ago
7
initial pass at splitting the project into modules

#69 agaro1121 opened 6 years ago
2
Support KCL Version 2.x

#68 aquamatthias opened 6 years ago
5
updates readme with instructions on how to keep a handle to the inner…

#67 agaro1121 closed 6 years ago
1
accessing KinesisConsumer directly when using Akka Source

#66 dobrien27 opened 6 years ago
0
KPL Typed Config

#65 etspaceman closed 6 years ago
9
upgrade localstack

#64 markglh opened 6 years ago
2
Problem consuming from stream when moving from 1 shard to 2 shards.

#63 jackmitchelwidman closed 4 years ago
8
fix typo

#62 markglh closed 6 years ago
1
Add additional factory methods to Kinesis to create Akka Source

#61 htimur closed 6 years ago
4
Kinesis stream how to call shutdown on source?

#60 MeiSign closed 6 years ago
1
Please publish reactive-kinesis 0.6.7 also for scala 2.11

#59 htimur closed 6 years ago
7
Amazon Software License

#58 etspaceman opened 6 years ago
5
License - AWS vs. Apache 2

#57 etspaceman opened 6 years ago
6
Updating packages, adding new configuration for KCL

#56 etspaceman closed 6 years ago
4
creating a CWPublisherRunnable that tries to publish to cloudwatch

#55 fommil closed 6 years ago
1
makes buildKPLConfig public

#54 agaro1121 closed 6 years ago
2
make buildKPLConfig public

#53 fommil closed 6 years ago
1
Tweak documentation on consumer shutdown method call

#52 TJC closed 6 years ago
1
Shutdown process - unclear how to trigger - could improve docs

#51 TJC closed 6 years ago
1
KinesisProducerActor: failed sends should be retried

#50 aquamatthias opened 6 years ago
0
Remove unnecessary dependencies.

#49 aquamatthias closed 6 years ago
1
Calling KinesisProducerActor.props already starts a KinesisProducer

#48 aquamatthias opened 6 years ago
0
Add an Akka Stream Sink graph stage for Kinesis.

#47 aquamatthias closed 6 years ago
12
Make KinesisSourceGraphIntegrationSpec more robust.

#46 aquamatthias closed 6 years ago
4
Please publish reactive-kinesis 0.6.5 also for scala 2.12

#45 aquamatthias closed 6 years ago
3
Update KPL and KCL libraries

#44 markglh closed 6 years ago
2
Investigate & implement 2 Phase checkpoints to reduce duplication on failover

#43 markglh opened 6 years ago
0
Swap out backend for Non Blocking SDK

#42 markglh opened 6 years ago
0
Fix #35 by using ByteBuffer instead of String.

#41 aquamatthias closed 6 years ago
6
Fix #33 by stopping the ConsumerWorker on lease loss

#40 aquamatthias closed 6 years ago
18
Fix #25 by providing an Akka Stream Source graph stage for Kinesis.

#39 aquamatthias closed 6 years ago
19
Consumer Integration testing & Testkit module

#38 markglh opened 6 years ago
0
Scaling Kinesis Shards Yields Errors

#37 etspaceman closed 4 years ago
4
Fix #25 by providing an Akka Stream Source graph stage for Kinesis.

#36 aquamatthias closed 6 years ago
8
Update the kinesis library to accept and return a byte array (or bytebuffer)

#35 markglh closed 6 years ago
0
Feature/integration testing

#34 markglh closed 6 years ago
8
CheckpointWorker Actor is not killed when the lease is lost

#33 aquamatthias closed 6 years ago
3