Lucas Brutschy

When I try to import the schemas whose base directory is the current directory, the schema path is dropped ``` rq protobuf add com/bla/admin.proto --base . [INFO] [record_query::proto_index] Added proto...

I am surprised to discover that RowUniquenessConstraint is implemented using CL_LOCAL_QUORUM by default. This would leave the possibility of creating non-unique rows across datacenters. I suggest this behavior to be...

*More detailed description of your change, if necessary. The PR title and PR message become the squashed commit message, so use a separate comment to ping reviewers.* *Summary of testing...

KAFKA-16287: Implement example tests for common rebalance callback

3

Add 6 example tests to the `PlaintextConsumerTest` that tests using a `ConsumerRebalanceListener` to invoke methods on the consumer. This test is implemented in a reasonably general way with a view...

Non-atomic update in addNewKey

3

In the file: ``cassieq/core/src/main/java/io/paradoxical/cassieq/admin/resources/api/v1/AccountResource.java`` The addNewKey operation is not safe for concurrent addition of keys - one will overwrite the other. For example, two clients inserting a key (one inserts,...

This is related to #128. The function ``addNewKey`` ``cassieq/core/src/main/java/io/paradoxical/cassieq/admin/resources/api/v1/AccountResource.java`` could re-add an account that is concurrently deleted. ``` SELECT keys FROM account WHERE account = ‘webapp’ DELETE * FROM account...

Ports several tools for topic configuration from the client side, to the broker-side. Several things are refactored: - Decoupling. On the client side, for example, RepartitionTopics was using the CopartitionedTopicEnforcer,...