[GitHub] kafka pull request #3762: KAFKA-5807 - Check Connector.config() and Transfor...

GitHub user jcustenborder opened a pull request: https://github.com/apache/kafka/pull/3762 KAFKA-5807 - Check Connector.config() and Transformation.config() returns a valid ConfigDef You can merge this pull request into a Git repository by running: $ git pull https

[GitHub] kafka pull request #3556: KAFKA-5620

GitHub user jcustenborder opened a pull request: https://github.com/apache/kafka/pull/3556 KAFKA-5620 Expose the ClassCastException as the cause for the SerializationException. You can merge this pull request into a Git repository by running: $ git pull https://github.com

[GitHub] kafka pull request #3517: KAFKA-5579 check for null.

GitHub user jcustenborder opened a pull request: https://github.com/apache/kafka/pull/3517 KAFKA-5579 check for null. You can merge this pull request into a Git repository by running: $ git pull https://github.com/jcustenborder/kafka KAFKA-5579 Alternatively you can review

[GitHub] kafka pull request #3511: KAFKA-5575 - Add SchemaBuilder.from

GitHub user jcustenborder opened a pull request: https://github.com/apache/kafka/pull/3511 KAFKA-5575 - Add SchemaBuilder.from Added `SchemaBuilder.from` method which allows creating a schema builder prepopulated with the details from the schema. Added tests for structs, maps

[GitHub] kafka pull request #3508: KAFKA-5572 - ConfigDef should be able to escape co...

GitHub user jcustenborder opened a pull request: https://github.com/apache/kafka/pull/3508 KAFKA-5572 - ConfigDef should be able to escape comma(s) Allow escaping ',' character with '\,' as an escape sequence. You can merge this pull request into a Git repository by running

[GitHub] kafka pull request #3507: KAFKA-5550

GitHub user jcustenborder opened a pull request: https://github.com/apache/kafka/pull/3507 KAFKA-5550 Changed call to use the overload of ConnectSchema.validate method with the field name passed in. Ensure that field in put call is not null. You can merge this pull request

[GitHub] kafka pull request #3474: KAFKA-5548 - Extended validation for SchemaBuilder...

GitHub user jcustenborder opened a pull request: https://github.com/apache/kafka/pull/3474 KAFKA-5548 - Extended validation for SchemaBuilder methods. More input validation for SchemaBuilder methods. You can merge this pull request into a Git repository by running: $ git pull

[GitHub] kafka pull request #1602: KAFKA-3943 - ConfigDef with Builder pattern

GitHub user jcustenborder opened a pull request: https://github.com/apache/kafka/pull/1602 KAFKA-3943 - ConfigDef with Builder pattern Added Builder class and define() method with no arguments. Added testcase validating the ConfigDef using the current implementation against the new

[GitHub] kafka pull request #1560: KAFKA-3906 - Connect logical types do not support ...

GitHub user jcustenborder opened a pull request: https://github.com/apache/kafka/pull/1560 KAFKA-3906 - Connect logical types do not support nulls. Initial commit with failing unit tests for proposed functionality. You can merge this pull request into a Git repository by running

[GitHub] kafka pull request #952: KAFKA-3263 - Support for markdown generation.

Github user jcustenborder closed the pull request at: https://github.com/apache/kafka/pull/952 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[GitHub] kafka pull request: KAFKA-3407 - ErrorLoggingCallback trims helpfu...

GitHub user jcustenborder opened a pull request: https://github.com/apache/kafka/pull/1079 KAFKA-3407 - ErrorLoggingCallback trims helpful diagnostic information. This should help when diagnosing issues with the console producer. This allows the logger to use `exception` rather

[GitHub] kafka pull request: KAFKA-3347 - Configure java to prefer ipv4

GitHub user jcustenborder opened a pull request: https://github.com/apache/kafka/pull/1026 KAFKA-3347 - Configure java to prefer ipv4 Modified KAFKA_JVM_PERFORMANCE_OPTS to include -Djava.net.preferIPv4Stack=true. Added an additional space at the end of the string to be consistent

[GitHub] kafka pull request: KAFKA-3263 - Support for markdown generation.

GitHub user jcustenborder opened a pull request: https://github.com/apache/kafka/pull/952 KAFKA-3263 - Support for markdown generation. Added support to generate markdown from ConfigDef entries. Added test toMarkdown() to ConfigDefTest. Added toMarkdown() to ConfigDef. You can

[GitHub] kafka pull request: KAFKA-3260 - Added SourceTask.commitRecord

GitHub user jcustenborder opened a pull request: https://github.com/apache/kafka/pull/950 KAFKA-3260 - Added SourceTask.commitRecord Added commitRecord(SourceRecord record) to SourceTask. This method is called during the callback from producer.send() when the message has been sent

[GitHub] kafka pull request: KAFKA-3237 - Remove test cases testInvalidDefa...

GitHub user jcustenborder opened a pull request: https://github.com/apache/kafka/pull/936 KAFKA-3237 - Remove test cases testInvalidDefaultRange() and testInva… Remove test cases testInvalidDefaultRange() and testInvalidDefaultString(). Defaults if not overridden will get checked

[GitHub] kafka pull request: KAFKA-3225: Method commit() of class SourceTas...

GitHub user jcustenborder opened a pull request: https://github.com/apache/kafka/pull/909 KAFKA-3225: Method commit() of class SourceTask never invoked 1. Added a test case to prove commit() on SourceTask was not being called. 2. Added commitSourceTask() which logs potential