amient affinity issues - Githubissues

amient / affinity

Library and a Framework for building fast, scalable, fault-tolerant Data APIs based on Akka, Avro, ZooKeeper and Kafka

Apache License 2.0

26 stars 4 forks source link

issues

Newest

Newest Most commented Recently updated Oldest Least commented Least recently updated

Introduce maximum suspended state timeout

#283 michal-harish opened 4 years ago
0
ZookeeperSchemaRegistry

#282 gr211 closed 4 years ago
1
Consider getting rid of zookeeper as a coordinator

#281 michal-harish opened 4 years ago
1
Enable stream topics to be managed externally

#280 michal-harish opened 4 years ago
1
Graph API System Test fails intermittently

#279 michal-harish closed 4 years ago
1
typo: abandonned -> abandoned

#278 marwahaha closed 5 years ago
0
Remove usage of javax.xml.bind.DatatypeConverter

#277 michal-harish opened 5 years ago
0
Expose globally unique ZID to the transactional producer

#276 michal-harish opened 5 years ago
0
Transactions

#275 michal-harish closed 5 years ago
0
Avro: Consider Value Classes as types with logicalType of its primitive

#274 michal-harish closed 5 years ago
0
Remove type args from this exception

#273 michal-harish closed 5 years ago
0
JsonEncoder still doesn't work faultlessly

#272 michal-harish closed 5 years ago
0
AvroJsonConverter not to wrap runtime exception and just rethrow

#271 michal-harish closed 5 years ago
0
Consider default config for http timeouts as infinite both ways

#270 michal-harish closed 5 years ago
0
Avro: Support ListMap, SortedMap as arguments

#269 michal-harish opened 5 years ago
0
benchmark the performance the old websocket impl. and compare to the new one

#268 michal-harish opened 5 years ago
0
Allow topic configuration in the node.stream.<x>.topic-config

#267 michal-harish opened 5 years ago
1
consumer offsets by time timeout on busy local clusters

#266 michal-harish closed 5 years ago
1
improve recovery from partitioned state

#265 michal-harish opened 5 years ago
0
Spark 2.3 and 2.4 cross builds

#264 michal-harish opened 5 years ago
0
Avrojs

#263 michal-harish closed 5 years ago
0
Avrojs

#262 michal-harish closed 5 years ago
0
avsc avrojs library bug with nested complex objects

#261 michal-harish closed 5 years ago
0
avro optional defaults must reorder the schema

#260 michal-harish closed 5 years ago
1
avro output stream should register schemas for -value and -key also

#259 michal-harish opened 5 years ago
0
failures during gateway initialization cause immediate 'address already used'

#258 michal-harish opened 5 years ago
0
failed pipeline which contains global stores hangs on error shutdown until shutdown timeout occurs

#257 michal-harish opened 5 years ago
1
Make Partition and Offset available in the Record

#256 michal-harish opened 5 years ago
0
Atomic Multiple Outputs

#255 michal-harish closed 5 years ago
0
Until compaction filter is implemented expiration should be a background work

#254 michal-harish closed 5 years ago
0
Global state is not materialized on all shards

#253 michal-harish closed 5 years ago
1
Avro fixes

#252 michal-harish closed 6 years ago
0
OutputDataStream doesn't initialize topic when inlined

#251 michal-harish closed 6 years ago
0
Annotation for Avro Field Descriptions

#250 michal-harish closed 6 years ago
0
Secondary Indicies

#249 michal-harish closed 6 years ago
0
Utilize RocksDB flush to stay asynchronous and ensure guarantees

#248 michal-harish opened 6 years ago
0
AvroJsonConverter treats Fixed Int as byte array

#247 michal-harish closed 6 years ago
0
Move ObservableState to Scala and make KVStoreLocal.listen strongly typed

#246 michal-harish closed 6 years ago
0
Config specializations could be defined by classes

#245 michal-harish opened 6 years ago
0
Make all connections retry idefinitely by default

#244 michal-harish opened 6 years ago
0
MemoryLogStorage doesn't behave in tests when as replacement for KafkaLogStorage

#243 michal-harish opened 6 years ago
0
Think next steps around guarantees and performance

#242 michal-harish opened 6 years ago
0
Design a coordinated shutdown besides a normal shutdown

#241 michal-harish opened 6 years ago
0
122 internal message serdes

#240 michal-harish closed 6 years ago
0
Reimplement ActorPublishers using akka.stream.stage.GraphStage

#239 michal-harish closed 5 years ago
0
Java serialization doesn't work when wrapped in Serde

#238 michal-harish closed 6 years ago
0
Parameterless case classes that extend AvroRecord cause AvroProxy requirement failure

#237 michal-harish closed 6 years ago
0
Performance benchmark

#236 michal-harish opened 6 years ago
0
Unassigned partitions should be dropped only once newly assigned ones are online

#235 michal-harish opened 6 years ago
0
Kafka 2.0

#234 michal-harish closed 6 years ago
0