nakadi-java

nakadi-java copied to clipboard

Nakadi publishing API accepts events in batches. It can fail to publish some events from the batch to underlying storage (Apache Kafka). In that case Nakadi publishing API will return...

adyach

[Support] Retrying done even in case of 4xx error

1

I would like to understand the use case for which `nakad-java` client retries [publishing even in case of 4xx errors](https://github.com/dehora/nakadi-java/blob/f3a18c12ba5348de5c66a9ffad3ddb9141296ca3/nakadi-java-client/src/main/java/nakadi/ExceptionSupport.java#L109). Is this so that a publisher can keep retrying publishing...

samizzy

The default JsonSupport comes with GsonSupport class with predefined configuration: ```java private static class GsonCompressedHolder { private static final Gson INSTANCE = new GsonBuilder() .setFieldNamingPolicy(FieldNamingPolicy.LOWER_CASE_WITH_UNDERSCORES) .registerTypeAdapter(OFFSET_DATE_TIME_TYPE, new OffsetDateTimeSerdes()) .setDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSSXXX") .create();...

romanmusii

Hi, it looks like the threads are not cleaned after the processor stops. I created 5 different Nakadi clients, each with maxRetryAttempts set to 2 and started the processes. They...

pramakrishn

With this commit it is easy to use Avro as never 1. update library dependencies 2. in Nakadi client builder provide Avro serializer: ``` final NakadiClient client = NakadiClient.newBuilder() ......

adyach

Nakadi Avro publishing

5

Since recently, Nakadi supports publishing in Apache Avro format(https://github.com/zalando/nakadi/pull/1430). This issue is the request for discussion and possible approaches to implement it in nakadi-java. Nakadi Avro Envelope enables to send...

adyach

Honor rate limiting headers sent by the server

1

**Current behavior** Nakadi (at least on the staging system at Zalando) now has some rate limiting (via a gateway). This has the effect that all kinds of calls can get...

ePaul

Abstract payload serialization logic

2

Abstracting the payload serialization logic by adding `PayloadSerialization` interface. This will enable support for further serialization types in the future like Avro. Currently, existing json serializaton logic has been moved...

samizzy

Add support Avro publishing

2

This PR is part of the effort to introduce Avro capability. In this first PR, Avro publishing feature has implemented. 1. The public API for publishing is kept decoupled from...

samizzy

JsonSyntaxException when Nakadi's response is not JSON

2

**Current behavior** When Nakadi replies with an error which can't be parsed as application/problem+json, then Nakadi-Java throws just a NakadiException wrapping a JsonSyntaxException, without any trace of the original error...

ePaul