frankgrimes97
frankgrimes97
I was thinking that something along the lines of Jackson's @JsonDeserialize annotation would be ideal. Or any way to wire up that configuration without needing to hand-write custom deserialization code...
Make GenericRecord comparison handle String vs Utf8 for MAP type This mirrors what was already previously done for Schema.type.STRING Adds the following new unit tests: - org.apache.avro.generic.TestGenericData.testMapKeyEquals - org.apache.avro.generic.TestGenericData.testMapValuesEquals N.B....
Could a new param be added to support this? For context, I tried to use `genSelfSignedCert` to generate keys for Kafka and was unable to load them because Kafka requires...
Hi, I'm running `docker run -p 5433:5433 -d -v ~/vertica_data:/home/dbadmin/docker jbfavre/vertica:9.2.0-7_centos-7 ` but when shutting down the following lines are not executed: https://github.com/jbfavre/docker-vertica/blob/master/docker-entrypoint.sh#L15-L19 As a consequence of this trying to...
Don't generate union classes when a simple union contains only two elements, one of which is null. Instead, generate pointers to the types. (Golang built-in nullability) https://github.com/actgardner/gogen-avro/issues/184
This PR attempts to address https://github.com/actgardner/gogen-avro/issues/172
We often define a single structure but return subsets of its fields from different JAX-RS resource methods by annotating the methods with @JsonView. (FYI, we're actually using Dropwizard) e.g. http://jira.codehaus.org/browse/JACKSON-578...
The required version of `io.confluent:common:[7.6.0, 7.6.1)` does not appear to be available at https://packages.confluent.io/maven/io/confluent/common/ (latest version published there seems to be `7.5.2`) This seems similar to this previously-reported problem: https://github.com/confluentinc/kafka-connect-storage-cloud/issues/511
This PR attempts to address https://github.com/confluentinc/kafka-connect-storage-cloud/issues/237 We would very much like to work towards having this contributed back upstream rather than maintain our own fork. Feedback is most welcome!
When late data is arriving on a Kafka partition (e.g. data for the previous hourly encodedPartition) the following check triggers an immediate rotation and commit of files: https://github.com/confluentinc/kafka-connect-storage-cloud/blob/918730d011dcd199e810ec3a68a03ab01c927f62/kafka-connect-s3/src/main/java/io/confluent/connect/s3/TopicPartitionWriter.java#L410 When late...