Bobby Johansen comments

Results 15 comments of


Bobby Johansen

Which branch was missed?

Is there any ETA to release this feature?

JavaScript heap out of memory on large swagger file

Any movement here?

If IRecordProcessor.processRecords() throws an exception, record processor should be destroyed, events should not be skipped.

Does anyone know how to shutdown a record processor in processRecords when an exception is thrown from the check pointer? I currently experience two workers reading the same shard one...

If IRecordProcessor.processRecords() throws an exception, record processor should be destroyed, events should not be skipped.

@majidfn Unfortunately the interface ShardRecordProcessor.processRecords does not allow me to throw a ShutdownException. Would you recommend throwing a runtime Exception?

If IRecordProcessor.processRecords() throws an exception, record processor should be destroyed, events should not be skipped.

Unfortunately the interface ShardRecordProcessor does not throw an exception therefore I cannot throw a ShutdownException from the processRecords overriden method :(. I can wrap it and throw a non checked...

Bobby Johansen

Which branch was missed?

JavaScript heap out of memory on large swagger file

i got doubts

If IRecordProcessor.processRecords() throws an exception, record processor should be destroyed, events should not be skipped.

If IRecordProcessor.processRecords() throws an exception, record processor should be destroyed, events should not be skipped.

If IRecordProcessor.processRecords() throws an exception, record processor should be destroyed, events should not be skipped.

Kinesis graceful shutdown for a simple KCL 2.0 consumer not working

Is it fixed ?

NEXUS-17451 - add optional limit request parameter to REST APIs

Race condition in KCL v2 graceful shutdown