Skip to content

issues Search Results · repo:WW-Digital/reactive-kinesis language:Scala

Filter by

44 results
 (65 ms)

44 results

inWW-Digital/reactive-kinesis (press backspace or delete to remove)

WW-Digital/reactive-kinesis
Please publish reactive-kinesis 0.6.13 also for scala 2.12

Seems the 0.6.13 isn t available in for 2.12, the latest version for 2.12 is 0.6.11: maven.org Please also publish a 2.12 version. Thanks!
  • danielspigel
  • Opened 
    on Jun 16, 2021
  • #82

WW-Digital/reactive-kinesis
Publish binaries for 0.6.12

The tagged version exists, but there is no jar in maven.
  • Jacoby6000
  • Opened 
    on Apr 16, 2019
  • #76

WW-Digital/reactive-kinesis
Kinesis Client Issues?

I noticed that you guys updated the AWS Kinesis Client library today (very recently), and I was wondering if you had been seeing any strange behaviors with workers getting shut-down. We have a consumer ...
  • chasdevs
  • 6
  • Opened 
    on Apr 1, 2019
  • #75

WW-Digital/reactive-kinesis
JodaTime -> java.time

Looks like the library makes use of jodatime. Migration to java.time data types probably makes sense.
  • Slakah
  • 1
  • Opened 
    on Mar 1, 2019
  • #73

WW-Digital/reactive-kinesis
0.6.11 not available for scala 2.12

The artifact was created for scala 2.11, but not 2.12. Can this please be republished for 2.12? Looks it may be due to a similar issue as seen in #45 and #59
  • dobrien27
  • 6
  • Opened 
    on Feb 21, 2019
  • #72

WW-Digital/reactive-kinesis
Support KCL Version 2.x

Looks like the AWS guys improved KCL: KCL 2.0 uses async IO with HTTP/2. Would be great to see support in reactive-kinesis for this. Migration guide from 1.x to 2.x: https://docs.aws.amazon.com/streams/latest/dev/kcl-migration.html ...
  • aquamatthias
  • 5
  • Opened 
    on Sep 3, 2018
  • #68

WW-Digital/reactive-kinesis
accessing KinesisConsumer directly when using Akka Source

I saw that issue #60 and the subsequent fix in #61 seemed to touch upon this problem, but I don t quite see how the proposed solution allows one to grab a reference to a KinesisConsumer or ConsumerService. ...
  • dobrien27
  • Opened 
    on Jul 30, 2018
  • #66

WW-Digital/reactive-kinesis
Problem consuming from stream when moving from 1 shard to 2 shards.

We are using reactive-kinesis for the time to consume from a stream. With 1 shard, everything works fine. When we bump it up to 2 shards, the consumer shuts down soon after it starts. The log error is: ...
  • jackmitchelwidman
  • 8
  • Opened 
    on May 9, 2018
  • #63

WW-Digital/reactive-kinesis
Kinesis stream how to call shutdown on source?

We are using the Kinesis object to create a kinesis stream source: Kinesis .source(StreamConfigName) .via(flow) .runWith(Sink.foreach[CommittableEvent[ConsumerEvent]](_.commit())) When we shutdown ...
  • MeiSign
  • 1
  • Opened 
    on Apr 17, 2018
  • #60

WW-Digital/reactive-kinesis
Please publish reactive-kinesis 0.6.7 also for scala 2.11

Seems the 0.6.7 isn t available in for 2.11, the latest version for 2.11 is 0.6.6: maven.org Please also publish a 2.11 version. Thanks!
  • htimur
  • 7
  • Opened 
    on Mar 23, 2018
  • #59
Issue origami icon

Learn how you can use GitHub Issues to plan and track your work.

Save views for sprints, backlogs, teams, or releases. Rank, sort, and filter issues to suit the occasion. The possibilities are endless.Learn more about GitHub Issues
ProTip! 
Press the
/
key to activate the search input again and adjust your query.
Issue origami icon

Learn how you can use GitHub Issues to plan and track your work.

Save views for sprints, backlogs, teams, or releases. Rank, sort, and filter issues to suit the occasion. The possibilities are endless.Learn more about GitHub Issues
ProTip! 
Press the
/
key to activate the search input again and adjust your query.
Issue search results · GitHub