wenbingshen

[FEATURE] Can kop support setting the entry format of topic level

4

**Is your feature request related to a problem? Please describe.** Currently kop only supports entryFormat at the agent level. Once kop is configured with entryFormat, it will no longer be...

**Describe the bug** A clear and concise description of what the bug is. When a topic is not consumed, call KafkaAdminClient to delete this topic. This topic will create a...

Close the old connection to make sure the broker drops the producer on its side

1

Master Issue: #676 ### Motivation When reconnecting to the server, the old connection should be closed. ### Modifications Close the old connection to make sure the broker drops the producer...

[BUG] When reconnecting to the server, the old connection is not closed

15

#### Expected behavior When reconnecting to the server, the old connection should be closed. #### Actual behavior When reconnecting to the server, the old connection is not closed. The following...

fix Flaky-test: BookieZKExpireTest.testBookieServerZKSessionExpireBehaviour

6

### Motivation fix Flaky-test: `BookieZKExpireTest.testBookieServerZKSessionExpireBehaviour` by disable retry session expired. issue #3206 was fixed by PR #3415, but it still introduced another flaky test: `BookieZKExpireTest.testBookieServerZKSessionExpireBehaviour` According to the investigation, the...

The following error occurred when I started the elastalert server `> @bitsensor/[email protected] start /opt/elastalert-server > sh ./scripts/start.sh /opt/elastalert-server/src/index.js:1 import ElastalertServer from './elastalert_server'; ^^^^^^ SyntaxError: Cannot use import statement outside a...

fix close ledgerAuditorManager repeatedly

4

### Motivation this introduced in #2842, the `ledgerAuditorManager` will be close repeatedly. ```java private void submitShutdownTask() { executor.submit(new Runnable() { @Override public void run() { if (!running.compareAndSet(true, false)) { return;...

Rename success with writableResult and update final writableResult about wait writeSet

3

### Changes update `success` about wait writeSet for Writable result.

Simplified No network topology script is found default log stack output

1

### Motivation The default `dnsResolver` of `RackawareEnsemblePlacementPolicyImpl` is initialized as `ScriptBasedMapping`. Since the script is missing by default, detailed stack information will be printed, but the code will fall back...

Add RegistrationSessionExpiredPolicy for session expired event

7

### Motivation The status of the Bookie service, including `writable` and `read-only`, needs to be registered with the `Registration` service. At present, most of the time we use `zookeeper` as...