[GitHub] kafka pull request #4151: [WIP] KIP-215: Add topic regex support for Connect...

GitHub user jklukas opened a pull request: https://github.com/apache/kafka/pull/4151 [WIP] KIP-215: Add topic regex support for Connect sinks I'm starting this WIP PR to prove out the concept of the KIP and identify some additional public interface changes that I had not previ

[GitHub] kafka pull request #4251: KAFKA-6253: Improve sink connector topic regex val...

GitHub user jklukas opened a pull request: https://github.com/apache/kafka/pull/4251 KAFKA-6253: Improve sink connector topic regex validation KAFKA-3073 added topic regex support for sink connectors. The addition requires that you only specify one of topics or topics.regex

[GitHub] kafka pull request #1479: KAFKA-3711: Ensure a RecordingMap is passed to con...

GitHub user jklukas opened a pull request: https://github.com/apache/kafka/pull/1479 KAFKA-3711: Ensure a RecordingMap is passed to configured instances See https://issues.apache.org/jira/browse/KAFKA-3711 I've tested locally that this change does indeed resolve the wa

[GitHub] kafka pull request #1481: MINOR: Pass absolute directory path to RocksDB.ope...

GitHub user jklukas opened a pull request: https://github.com/apache/kafka/pull/1481 MINOR: Pass absolute directory path to RocksDB.open The method `RocksDB.open` assumes an absolute file path. If a relative path is configured, it leads to an exception like the following

[GitHub] kafka pull request #1486: KAFKA-3753: Add size() method to KeyValueStore int...

GitHub user jklukas opened a pull request: https://github.com/apache/kafka/pull/1486 KAFKA-3753: Add size() method to KeyValueStore interface See https://issues.apache.org/jira/browse/KAFKA-3753 This contribution is my original work and I license the work to the project

[GitHub] kafka pull request: MINOR: Fix some copy-pasted Javadoc in Streams...

GitHub user jklukas opened a pull request: https://github.com/apache/kafka/pull/1270 MINOR: Fix some copy-pasted Javadoc in StreamsConfig.java This contribution is my original work and I license the work to the Kafka project under the project's open source license.

[GitHub] kafka pull request: MINOR: Expose KafkaStreams Metrics in public A...

GitHub user jklukas opened a pull request: https://github.com/apache/kafka/pull/1362 MINOR: Expose KafkaStreams Metrics in public API The Kafka clients expose their metrics registries through a `metrics` method presenting an unmodifiable collection (see [KafkaProducer's me

[GitHub] kafka pull request: MINOR: Call Metrics.close() in KafkaStreams

GitHub user jklukas opened a pull request: https://github.com/apache/kafka/pull/1379 MINOR: Call Metrics.close() in KafkaStreams Initially proposed by @ijuma in https://github.com/apache/kafka/pull/1362#issuecomment-218293662 @mjsax commented: > StreamThread.cl

[GitHub] kafka pull request: MINOR: Allow Serdes subclasses to access Wrapp...

GitHub user jklukas opened a pull request: https://github.com/apache/kafka/pull/1382 MINOR: Allow Serdes subclasses to access WrapperSerde This PR loosens access restrictions on `WrapperSerde` to `protected` so that users can define a `Serdes` subclass that provides additional

[GitHub] kafka pull request: KAFKA-3701: Expose KafkaStreams Metrics in pub...

Github user jklukas closed the pull request at: https://github.com/apache/kafka/pull/1362 --- 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 is

[GitHub] kafka pull request #3249: MINOR: Fix docs; client no longer uses yammer metr...

GitHub user jklukas opened a pull request: https://github.com/apache/kafka/pull/3249 MINOR: Fix docs; client no longer uses yammer metrics Yammer metrics is no longer a dependency of the client, but the Monitoring section of the docs contradicts this. For quite some time, clients