issues
search
dehora
/
nakadi-java
🌀 Client library for the Nakadi Event Broker (examples: http://bit.ly/njc-examples, site: https://dehora.github.io/nakadi-java/)
MIT License
30
stars
19
forks
source link
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
Stops the processor after a successful response with a stream timeout.
#293
dehora
closed
7 years ago
0
Stops the processor after a successful response with a stream timeout
#292
dehora
closed
7 years ago
0
Processor retries even if stream_timeout is set
#291
dehora
closed
7 years ago
0
Calls StreamObserver.onStop only on termination.
#290
dehora
closed
7 years ago
0
onStop called multiple times
#289
dehora
closed
7 years ago
0
0.9.13
#288
dehora
closed
7 years ago
0
Lowers default batch buffer and allows setting by configuration.
#287
dehora
closed
7 years ago
2
0.9.12
#286
dehora
closed
7 years ago
0
Stops stream processor after retries are exceeded.
#285
dehora
closed
7 years ago
1
OkHTTP Thread pool leak when maxRetryAttempts not honored
#284
satybald
closed
7 years ago
4
Avoids StreamProcessor.stop waiting on start completion.
#283
dehora
closed
7 years ago
0
Tidies up OkHttpResource args and connection closing.
#282
dehora
closed
7 years ago
0
Extracts utility methods from OkHttpResponseBody.
#281
dehora
closed
7 years ago
0
Tidies the StreamProcessor and its logging.
#280
dehora
closed
7 years ago
0
0.9.11
#279
dehora
closed
7 years ago
0
Reduce allocations when marshalling events from a stream.
#278
dehora
closed
7 years ago
0
0.9.10
#277
dehora
closed
7 years ago
0
Adds a close method to the Response interface.
#276
dehora
closed
7 years ago
0
0.9.9
#275
dehora
closed
7 years ago
0
Routes rxjava undeliverable exceptions to a handler.
#274
dehora
closed
7 years ago
0
Moves processor connection close calls to a method.
#273
dehora
closed
7 years ago
0
Removes duplicate Observer onStart call.
#272
dehora
closed
7 years ago
0
Removes duplicate Observer onStart call.
#271
dehora
closed
7 years ago
0
0.9.8
#270
dehora
closed
7 years ago
0
Excludes test jar from nakadi-java-zign.
#269
dehora
closed
7 years ago
0
0.9.7
#268
dehora
closed
7 years ago
0
Adds authorizations to event types.
#267
dehora
closed
7 years ago
0
Deprecates scopes.
#266
dehora
closed
7 years ago
0
Makes publishing status and steps visible in BatchItemResponse.
#265
dehora
closed
7 years ago
0
make BatchItemResponse.PublishingStatus public
#264
kanuku
closed
7 years ago
1
0.9.6
#263
dehora
closed
7 years ago
0
Tidies up error handling in StreamBatchRecordSubscriber.
#262
dehora
closed
7 years ago
0
Cleans up observer error handling.
#261
dehora
closed
7 years ago
0
Allows tracking of errors from StreamProcessor.
#260
dehora
closed
7 years ago
0
Allows detecting if a StreamProcessor is running/shutdown.
#259
dehora
closed
7 years ago
0
wip
#258
dehora
closed
7 years ago
0
processor continues streaming even if observer was stopped
#257
satybald
closed
7 years ago
1
Possible Nakadi-java OOM
#256
satybald
closed
7 years ago
3
[Question] Disposing Subscriber onComplete
#255
satybald
closed
6 years ago
1
Do not use unified logger, use loggers per package
#254
ovolynets
closed
2 years ago
2
Refactor the library into packages according to their functions
#253
ovolynets
closed
2 years ago
3
Fixes jvm header details.
#252
dehora
closed
7 years ago
0
0.9.5
#251
dehora
closed
7 years ago
0
Sends flattened JSON when posting an event.
#250
dehora
closed
7 years ago
0
Shuts down the StreamProcessor on unhandled exceptions.
#249
dehora
closed
7 years ago
0
Renames dispose methods on StreamProcessor to stop.
#248
dehora
closed
7 years ago
0
Controlled processor shutdown
#247
dehora
closed
7 years ago
0
Updates .gitignore.
#246
dehora
closed
7 years ago
0
Fixes log message for cursor updates.
#245
dehora
closed
7 years ago
0
Log diagnostic confusing for checkpointer
#244
dehora
closed
7 years ago
0
Previous
Next