Mirror of Apache Kafka

Related tags

Messaging scala kafka
Overview

Apache Kafka

See our web site for details on the project.

You need to have Java installed.

We build and test Apache Kafka with Java 8, 11 and 15. We set the release parameter in javac and scalac to 8 to ensure the generated binaries are compatible with Java 8 or higher (independently of the Java version used for compilation).

Scala 2.13 is used by default, see below for how to use a different Scala version or all of the supported Scala versions.

Build a jar and run it

./gradlew jar

Follow instructions in https://kafka.apache.org/quickstart

Build source jar

./gradlew srcJar

Build aggregated javadoc

./gradlew aggregatedJavadoc

Build javadoc and scaladoc

./gradlew javadoc
./gradlew javadocJar # builds a javadoc jar for each module
./gradlew scaladoc
./gradlew scaladocJar # builds a scaladoc jar for each module
./gradlew docsJar # builds both (if applicable) javadoc and scaladoc jars for each module

Run unit/integration tests

./gradlew test # runs both unit and integration tests
./gradlew unitTest
./gradlew integrationTest

Force re-running tests without code change

./gradlew cleanTest test
./gradlew cleanTest unitTest
./gradlew cleanTest integrationTest

Running a particular unit/integration test

./gradlew clients:test --tests RequestResponseTest

Running a particular test method within a unit/integration test

./gradlew core:test --tests kafka.api.ProducerFailureHandlingTest.testCannotSendToInternalTopic
./gradlew clients:test --tests org.apache.kafka.clients.MetadataTest.testMetadataUpdateWaitTime

Running a particular unit/integration test with log4j output

Change the log4j setting in either clients/src/test/resources/log4j.properties or core/src/test/resources/log4j.properties

./gradlew clients:test --tests RequestResponseTest

Specifying test retries

By default, each failed test is retried once up to a maximum of five retries per test run. Tests are retried at the end of the test task. Adjust these parameters in the following way:

./gradlew test -PmaxTestRetries=1 -PmaxTestRetryFailures=5

See Test Retry Gradle Plugin for more details.

Generating test coverage reports

Generate coverage reports for the whole project:

./gradlew reportCoverage -PenableTestCoverage=true

Generate coverage for a single module, i.e.:

./gradlew clients:reportCoverage -PenableTestCoverage=true

Building a binary release gzipped tar ball

./gradlew clean releaseTarGz

The release file can be found inside ./core/build/distributions/.

Building auto generated messages

Sometimes it is only necessary to rebuild the RPC auto-generated message data when switching between branches, as they could fail due to code changes. You can just run:

./gradlew processMessages processTestMessages

Cleaning the build

./gradlew clean

Running a task with one of the Scala versions available (2.12.x or 2.13.x)

Note that if building the jars with a version other than 2.13.x, you need to set the SCALA_VERSION variable or change it in bin/kafka-run-class.sh to run the quick start.

You can pass either the major version (eg 2.12) or the full version (eg 2.12.7):

./gradlew -PscalaVersion=2.12 jar
./gradlew -PscalaVersion=2.12 test
./gradlew -PscalaVersion=2.12 releaseTarGz

Running a task with all the scala versions enabled by default

Invoke the gradlewAll script followed by the task(s):

./gradlewAll test
./gradlewAll jar
./gradlewAll releaseTarGz

Running a task for a specific project

This is for core, examples and clients

./gradlew core:jar
./gradlew core:test

Streams has multiple sub-projects, but you can run all the tests:

./gradlew :streams:testAll

Listing all gradle tasks

./gradlew tasks

Building IDE project

Note that this is not strictly necessary (IntelliJ IDEA has good built-in support for Gradle projects, for example).

./gradlew eclipse
./gradlew idea

The eclipse task has been configured to use ${project_dir}/build_eclipse as Eclipse's build directory. Eclipse's default build directory (${project_dir}/bin) clashes with Kafka's scripts directory and we don't use Gradle's build directory to avoid known issues with this configuration.

Publishing the jar for all version of Scala and for all projects to maven

The recommended command is:

./gradlewAll publish

For backwards compatibility, the following also works:

./gradlewAll uploadArchives

Please note for this to work you should create/update ${GRADLE_USER_HOME}/gradle.properties (typically, ~/.gradle/gradle.properties) and assign the following variables

mavenUrl=
mavenUsername=
mavenPassword=
signing.keyId=
signing.password=
signing.secretKeyRingFile=

Publishing the streams quickstart archetype artifact to maven

For the Streams archetype project, one cannot use gradle to upload to maven; instead the mvn deploy command needs to be called at the quickstart folder:

cd streams/quickstart
mvn deploy

Please note for this to work you should create/update user maven settings (typically, ${USER_HOME}/.m2/settings.xml) to assign the following variables

<settings xmlns="http://maven.apache.org/SETTINGS/1.0.0"
   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
   xsi:schemaLocation="http://maven.apache.org/SETTINGS/1.0.0
                       https://maven.apache.org/xsd/settings-1.0.0.xsd">
...                           
<servers>
   ...
   <server>
      <id>apache.snapshots.https</id>
      <username>${maven_username}</username>
      <password>${maven_password}</password>
   </server>
   <server>
      <id>apache.releases.https</id>
      <username>${maven_username}</username>
      <password>${maven_password}</password>
    </server>
    ...
 </servers>
 ...

Installing the jars to the local Maven repository

The recommended command is:

./gradlewAll publishToMavenLocal

For backwards compatibility, the following also works:

./gradlewAll install

Building the test jar

./gradlew testJar

Determining how transitive dependencies are added

./gradlew core:dependencies --configuration runtime

Determining if any dependencies could be updated

./gradlew dependencyUpdates

Running code quality checks

There are two code quality analysis tools that we regularly run, spotbugs and checkstyle.

Checkstyle

Checkstyle enforces a consistent coding style in Kafka. You can run checkstyle using:

./gradlew checkstyleMain checkstyleTest

The checkstyle warnings will be found in reports/checkstyle/reports/main.html and reports/checkstyle/reports/test.html files in the subproject build directories. They are also printed to the console. The build will fail if Checkstyle fails.

Spotbugs

Spotbugs uses static analysis to look for bugs in the code. You can run spotbugs using:

./gradlew spotbugsMain spotbugsTest -x test

The spotbugs warnings will be found in reports/spotbugs/main.html and reports/spotbugs/test.html files in the subproject build directories. Use -PxmlSpotBugsReport=true to generate an XML report instead of an HTML one.

JMH microbenchmarks

We use JMH to write microbenchmarks that produce reliable results in the JVM.

See jmh-benchmarks/README.md for details on how to run the microbenchmarks.

Common build options

The following options should be set with a -P switch, for example ./gradlew -PmaxParallelForks=1 test.

  • commitId: sets the build commit ID as .git/HEAD might not be correct if there are local commits added for build purposes.
  • mavenUrl: sets the URL of the maven deployment repository (file://path/to/repo can be used to point to a local repository).
  • maxParallelForks: limits the maximum number of processes for each task.
  • ignoreFailures: ignore test failures from junit
  • showStandardStreams: shows standard out and standard error of the test JVM(s) on the console.
  • skipSigning: skips signing of artifacts.
  • testLoggingEvents: unit test events to be logged, separated by comma. For example ./gradlew -PtestLoggingEvents=started,passed,skipped,failed test.
  • xmlSpotBugsReport: enable XML reports for spotBugs. This also disables HTML reports as only one can be enabled at a time.
  • maxTestRetries: the maximum number of retries for a failing test case.
  • maxTestRetryFailures: maximum number of test failures before retrying is disabled for subsequent tests.
  • enableTestCoverage: enables test coverage plugins and tasks, including bytecode enhancement of classes required to track said coverage. Note that this introduces some overhead when running tests and hence why it's disabled by default (the overhead varies, but 15-20% is a reasonable estimate).
  • scalaOptimizerMode: configures the optimizing behavior of the scala compiler, the value should be one of none, method, inline-kafka or inline-scala (the default is inline-kafka). none is the scala compiler default, which only eliminates unreachable code. method also includes method-local optimizations. inline-kafka adds inlining of methods within the kafka packages. Finally, inline-scala also includes inlining of methods within the scala library (which avoids lambda allocations for methods like Option.exists). inline-scala is only safe if the Scala library version is the same at compile time and runtime. Since we cannot guarantee this for all cases (for example, users may depend on the kafka jar for integration tests where they may include a scala library with a different version), we don't enable it by default. See https://www.lightbend.com/blog/scala-inliner-optimizer for more details.

Dependency Analysis

The gradle dependency debugging documentation mentions using the dependencies or dependencyInsight tasks to debug dependencies for the root project or individual subprojects.

Alternatively, use the allDeps or allDepInsight tasks for recursively iterating through all subprojects:

./gradlew allDeps

./gradlew allDepInsight --configuration runtime --dependency com.fasterxml.jackson.core:jackson-databind

These take the same arguments as the builtin variants.

Running system tests

See tests/README.md.

Running in Vagrant

See vagrant/README.md.

Contribution

Apache Kafka is interested in building the community; we would welcome any thoughts or patches. You can reach us on the Apache mailing lists.

To contribute follow the instructions here:

Comments
  • org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition

    org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition

    [2017-05-24 09:39:34,637] ERROR [ReplicaFetcherThread-0-175], Error for partition [__consumer_offsets,15] to broker 175:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
    [2017-05-24 09:39:34,637] ERROR [ReplicaFetcherThread-0-175], Error for partition [__consumer_offsets,45] to broker 175:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
    [2017-05-24 09:39:34,637] ERROR [ReplicaFetcherThread-0-175], Error for partition [__consumer_offsets,27] to broker 175:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
    [2017-05-24 09:39:34,637] ERROR [ReplicaFetcherThread-0-175], Error for partition [__consumer_offsets,12] to broker 175:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
    [2017-05-24 09:39:34,637] ERROR [ReplicaFetcherThread-0-175], Error for partition [__consumer_offsets,9] to broker 175:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
    [2017-05-24 09:39:34,637] ERROR [ReplicaFetcherThread-0-175], Error for partition [__consumer_offsets,42] to broker 175:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
    [2017-05-24 09:39:34,637] ERROR [ReplicaFetcherThread-0-175], Error for partition [__consumer_offsets,24] to broker 175:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread)
    

    =================== I just use [bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker] to get the offset info from this kafka cluster. Who can tell me why the server log always print this error? Thanks!

    opened by linxiaobai 404
  • KAFKA-4208: Add Record Headers

    KAFKA-4208: Add Record Headers

    As per KIP-82

    Adding record headers api to ProducerRecord, ConsumerRecord Support to convert from protocol to api added Kafka Producer, Kafka Fetcher (Consumer) Updated MirrorMaker, ConsoleConsumer and scala BaseConsumer Add RecordHeaders and RecordHeader implementation of the interfaces Headers and Header

    Some bits using are reverted to being Java 7 compatible, for the moment until KIP-118 is implemented.

    opened by michaelandrepearce 152
  • KAFKA-3715: add granular metrics per node

    KAFKA-3715: add granular metrics per node

    Kafka Streams: add granular metrics per node, also expose ability to … …register non latency metrics in StreamsMetrics

    from https://github.com/apache/kafka/pull/1362#issuecomment-218326690------- We can consider adding metrics for process / punctuate / commit rate at the granularity of each processor node in addition to the global rate mentioned above. This is very helpful in debugging.

    We can consider adding rate / total cumulated metrics for context.forward indicating how many records were forwarded downstream from this processor node as well. This is helpful in debugging.

    We can consider adding metrics for each stream partition's timestamp. This is helpful in debugging.

    Besides the latency metrics, we can also add throughput latency in terms of source records consumed.

    More discussions here https://issues.apache.org/jira/browse/KAFKA-3715

    opened by aartigupta 148
  • KAFKA-4514: Add Codec for ZStandard Compression

    KAFKA-4514: Add Codec for ZStandard Compression

    Hello. This PR resolves KAFKA-4514: Add Codec for ZStandard Compression. Please have a look when you are free. Since I am a total newbie of Apache Kafka, feel free to point out the deficiencies.

    Add to the feature itself, I have a question: Should we support an option for ZStandard compression level?

    According to ZStandard official documentation, it supports compression level of 1 ~ 22. Because of that, Hadoop added a new configuration option named "io.compression.codec.zstd.level", whose default value is 3. In this PR, I configured the compression level to 1 as a temporary one but wondering following problems:

    • Should we provide a configurable option?
    • Would it better to change the default value, from 1 to another one?

    I am looking forward to your advice. Thanks.

    opened by dongjinleekr 130
  • KAFKA-3705: Added a foreignKeyJoin implementation for KTable.

    KAFKA-3705: Added a foreignKeyJoin implementation for KTable.

    https://issues.apache.org/jira/browse/KAFKA-3705

    Foreign Key Join:

    Allows for a KTable to map its value to a given foreign key and join on another KTable keyed on that foreign key. Applies the joiner, then returns the tuples keyed on the original key. This supports updates from both sides of the join.

    Design Philosophy:

    The intent of this design was to build a totally encapsulated function that operates very similarly to the regular join function. No further work is required by the user to obtain their foreignKeyJoin results after calling the function. That being said, there is increased cost in some of the topology components, especially due to resolving out-of-order arrival due to foreign key changes. I would appreciate any and all feedback on this approach, as my understanding of the Kafka Streams DSL is to provide higher level functionality without requiring the users to know exactly what's going on under the hood.

    Some points of note:

    1. Requires an additional materialized State Store for the prefixScanning of the repartitioned CombinedKey events.

    2. ReadOnlyKeyValueStore interface was modified to contain prefixScan. This requires that all implementations support this, but follows an existing precedent where some store functions are already stubbed out with exceptions.

    3. Currently limited to Inner Join (can do more join logic in future - just limiting the focus of this KIP).

    4. Application Reset does not seem to delete the new internal topics that I have added. (only tested with Kafka 1.0).

    5. Only works with identical number of input partitions at the moment, though it may be possible to get it working with KTables of varying input partition count.

    Testing:

    Testing is covered by a two integration tests that exercises the foreign key join. The first test exercises the out-of-order resolution and partitioning strategies by running three streams instances on three partitions. This demonstrates the scalability of the proposed solution.

    important The second test (KTableKTableForeignKeyInnerJoinMultiIntegrationTest) attempts to join using foreign key twice. This results in a NullPointerException regarding a missing task, and must be resolved before committing this.

    streams kip 
    opened by bellemare 118
  • KAFKA-5150 reduce lz4 decompression overhead

    KAFKA-5150 reduce lz4 decompression overhead

    • reuse decompression buffers in consumer Fetcher
    • switch lz4 input stream to operate directly on ByteBuffers
    • avoids performance impact of catching exceptions when reaching the end of legacy record batches
    • more tests with both compressible / incompressible data, multiple blocks, and various other combinations to increase code coverage
    • fixes bug that would cause exception instead of invalid block size for invalid incompressible blocks
    • fixes bug if incompressible flag is set on end frame block size

    Overall this improves LZ4 decompression performance by up to 40x for small batches. Most improvements are seen for batches of size 1 with messages on the order of ~100B. We see at least 2x improvements for for batch sizes of < 10 messages, containing messages < 10kB

    This patch also yields 2-4x improvements on v1 small single message batches for other compression types.

    Full benchmark results can be found here https://gist.github.com/xvrl/05132e0643513df4adf842288be86efd

    opened by xvrl 106
  • KAFKA-5045: KTable cleanup

    KAFKA-5045: KTable cleanup

    This is the implementation of KIP-114: KTable state stores and improved semantics:

    • Allow for decoupling between querying and materialisation
    • consistent APIs, overloads with queryableName and without
    • depreciated several KTable calls
    • new unit and integration tests

    In this implementation, state stores are materialized if the user desires them to be queryable. In subsequent versions we can offer a second option, to have a view-like state store. The tradeoff then would be between storage space (materialize) and re-computation (view). That tradeoff can be exploited by later query optimizers.

    opened by enothereska 95
  • KAFKA-4843: More efficient round-robin scheduler

    KAFKA-4843: More efficient round-robin scheduler

    • Improves streams efficiency by more than 200K requests/second (small 100 byte requests)

    • Gets streams efficiency very close to pure consumer (see results in https://jenkins.confluent.io/job/system-test-kafka-branch-builder/746/console)

    • Maintains same fairness across tasks

    • Schedules all records in the queue in-between poll() calls, not just one per task.

    opened by enothereska 87
  • KAFKA-8334 Make sure the thread which tries to complete delayed reque…

    KAFKA-8334 Make sure the thread which tries to complete delayed reque…

    The main changes of this PR are shown below.

    1. replace tryLock by lock for DelayedOperation#maybeTryComplete
    2. complete the delayed requests without holding group lock

    BEFORE

    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.topic=topic-replication-factor-three.num_producers=3.acks=1
    status: PASS
    run time: 56.718 seconds
    {"records_per_sec": 621619.67445, "mb_per_sec": 59.28}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_consumer_throughput.interbroker_security_protocol=PLAINTEXT.tls_version=TLSv1.2.security_protocol=SSL.compression_type=none
    status: PASS
    run time: 1 minute 16.067 seconds
    {"records_per_sec": 1565190.1706, "mb_per_sec": 149.2682}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_consumer_throughput.interbroker_security_protocol=PLAINTEXT.tls_version=TLSv1.2.security_protocol=SSL.compression_type=snappy
    status: PASS
    run time: 1 minute 2.486 seconds
    {"records_per_sec": 3165558.7211, "mb_per_sec": 301.8912}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_consumer_throughput.interbroker_security_protocol=PLAINTEXT.tls_version=TLSv1.3.security_protocol=SSL.compression_type=none
    status: PASS
    run time: 1 minute 19.929 seconds
    {"records_per_sec": 1350621.2858, "mb_per_sec": 128.8053}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_consumer_throughput.interbroker_security_protocol=PLAINTEXT.tls_version=TLSv1.3.security_protocol=SSL.compression_type=snappy
    status: PASS
    run time: 1 minute 3.014 seconds
    {"records_per_sec": 3653635.3672, "mb_per_sec": 348.4378}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_consumer_throughput.security_protocol=PLAINTEXT.compression_type=none
    status: PASS
    run time: 58.852 seconds
    {"records_per_sec": 3252032.5203, "mb_per_sec": 310.138}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_consumer_throughput.security_protocol=PLAINTEXT.compression_type=snappy
    status: PASS
    run time: 59.315 seconds
    {"records_per_sec": 3825554.7054, "mb_per_sec": 364.8333}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_end_to_end_latency.security_protocol=SASL_PLAINTEXT.compression_type=none
    status: PASS
    run time: 41.012 seconds
    {"latency_99th_ms": 6.0, "latency_50th_ms": 0.0, "latency_999th_ms": 16.0}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_end_to_end_latency.security_protocol=SASL_PLAINTEXT.compression_type=snappy
    status: PASS
    run time: 44.975 seconds
    {"latency_99th_ms": 5.0, "latency_50th_ms": 0.0, "latency_999th_ms": 19.0}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_end_to_end_latency.security_protocol=SASL_SSL.compression_type=none
    status: PASS
    run time: 49.868 seconds
    {"latency_99th_ms": 5.0, "latency_50th_ms": 0.0, "latency_999th_ms": 15.0}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_end_to_end_latency.security_protocol=SASL_SSL.compression_type=snappy
    status: PASS
    run time: 48.454 seconds
    {"latency_99th_ms": 5.0, "latency_50th_ms": 0.0, "latency_999th_ms": 19.0}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_and_consumer.interbroker_security_protocol=PLAINTEXT.tls_version=TLSv1.2.security_protocol=SSL.compression_type=none
    status: PASS
    run time: 1 minute 9.145 seconds
    {"consumer": {"records_per_sec": 610426.0774, "mb_per_sec": 58.2148}, "producer": {"records_per_sec": 620385.880017, "mb_per_sec": 59.16}}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_and_consumer.interbroker_security_protocol=PLAINTEXT.tls_version=TLSv1.2.security_protocol=SSL.compression_type=snappy
    status: PASS
    run time: 1 minute 2.140 seconds
    {"consumer": {"records_per_sec": 1465845.793, "mb_per_sec": 139.7939}, "producer": {"records_per_sec": 1416831.963729, "mb_per_sec": 135.12}}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_and_consumer.interbroker_security_protocol=PLAINTEXT.tls_version=TLSv1.3.security_protocol=SSL.compression_type=none
    status: PASS
    run time: 1 minute 10.968 seconds
    {"consumer": {"records_per_sec": 599089.3841, "mb_per_sec": 57.1336}, "producer": {"records_per_sec": 626370.184779, "mb_per_sec": 59.74}}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_and_consumer.interbroker_security_protocol=PLAINTEXT.tls_version=TLSv1.3.security_protocol=SSL.compression_type=snappy
    status: PASS
    run time: 58.237 seconds
    {"consumer": {"records_per_sec": 1298532.6581, "mb_per_sec": 123.8377}, "producer": {"records_per_sec": 1315443.304394, "mb_per_sec": 125.45}}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_and_consumer.security_protocol=PLAINTEXT.compression_type=none
    status: PASS
    run time: 1 minute 0.201 seconds
    {"consumer": {"records_per_sec": 997705.2779, "mb_per_sec": 95.1486}, "producer": {"records_per_sec": 957212.596918, "mb_per_sec": 91.29}}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_and_consumer.security_protocol=PLAINTEXT.compression_type=snappy
    status: PASS
    run time: 56.187 seconds
    {"consumer": {"records_per_sec": 1313025.2101, "mb_per_sec": 125.2198}, "producer": {"records_per_sec": 1363512.407963, "mb_per_sec": 130.03}}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_end_to_end_latency.interbroker_security_protocol=PLAINTEXT.tls_version=TLSv1.2.security_protocol=SSL.compression_type=none
    status: PASS
    run time: 57.195 seconds
    {"latency_99th_ms": 3.0, "latency_50th_ms": 0.0, "latency_999th_ms": 11.0}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_end_to_end_latency.interbroker_security_protocol=PLAINTEXT.tls_version=TLSv1.2.security_protocol=SSL.compression_type=snappy
    status: PASS
    run time: 57.311 seconds
    {"latency_99th_ms": 3.0, "latency_50th_ms": 0.0, "latency_999th_ms": 8.0}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_end_to_end_latency.interbroker_security_protocol=PLAINTEXT.tls_version=TLSv1.3.security_protocol=SSL.compression_type=none
    status: PASS
    run time: 57.756 seconds
    {"latency_99th_ms": 3.0, "latency_50th_ms": 0.0, "latency_999th_ms": 11.0}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_end_to_end_latency.interbroker_security_protocol=PLAINTEXT.tls_version=TLSv1.3.security_protocol=SSL.compression_type=snappy
    status: PASS
    run time: 57.291 seconds
    {"latency_99th_ms": 3.0, "latency_50th_ms": 0.0, "latency_999th_ms": 8.0}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_end_to_end_latency.security_protocol=PLAINTEXT.compression_type=none
    status: PASS
    run time: 48.981 seconds
    {"latency_99th_ms": 3.0, "latency_50th_ms": 0.0, "latency_999th_ms": 15.0}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_end_to_end_latency.security_protocol=PLAINTEXT.compression_type=snappy
    status: PASS
    run time: 51.503 seconds
    {"latency_99th_ms": 3.0, "latency_50th_ms": 0.0, "latency_999th_ms": 9.0}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_long_term_producer_throughput.interbroker_security_protocol=PLAINTEXT.tls_version=TLSv1.2.security_protocol=SSL.compression_type=none
    status: PASS
    run time: 1 minute 8.161 seconds
    {"0": {"records_per_sec": 698421.567258, "mb_per_sec": 66.61}}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_long_term_producer_throughput.interbroker_security_protocol=PLAINTEXT.tls_version=TLSv1.2.security_protocol=SSL.compression_type=snappy
    status: PASS
    run time: 56.530 seconds
    {"0": {"records_per_sec": 1639881.928501, "mb_per_sec": 156.39}}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_long_term_producer_throughput.interbroker_security_protocol=PLAINTEXT.tls_version=TLSv1.3.security_protocol=SSL.compression_type=none
    status: PASS
    run time: 1 minute 4.389 seconds
    {"0": {"records_per_sec": 720097.933319, "mb_per_sec": 68.67}}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_long_term_producer_throughput.interbroker_security_protocol=PLAINTEXT.tls_version=TLSv1.3.security_protocol=SSL.compression_type=snappy
    status: PASS
    run time: 59.589 seconds
    {"0": {"records_per_sec": 1621271.076524, "mb_per_sec": 154.62}}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_long_term_producer_throughput.security_protocol=PLAINTEXT.compression_type=none
    status: PASS
    run time: 56.165 seconds
    {"0": {"records_per_sec": 1152737.752161, "mb_per_sec": 109.93}}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_long_term_producer_throughput.security_protocol=PLAINTEXT.compression_type=snappy
    status: PASS
    run time: 54.846 seconds
    {"0": {"records_per_sec": 1646903.820817, "mb_per_sec": 157.06}}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.2.message_size=10.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=none
    status: PASS
    run time: 59.692 seconds
    {"records_per_sec": 1794354.545455, "mb_per_sec": 17.11}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.2.message_size=10.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=snappy
    status: PASS
    run time: 58.774 seconds
    {"records_per_sec": 1973499.779444, "mb_per_sec": 18.82}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.2.message_size=100.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=none
    status: PASS
    run time: 57.450 seconds
    {"records_per_sec": 325613.051917, "mb_per_sec": 31.05}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.2.message_size=100.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=snappy
    status: PASS
    run time: 54.134 seconds
    {"records_per_sec": 734232.49453, "mb_per_sec": 70.02}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.2.message_size=1000.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=none
    status: PASS
    run time: 54.106 seconds
    {"records_per_sec": 41259.452813, "mb_per_sec": 39.35}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.2.message_size=1000.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=snappy
    status: PASS
    run time: 52.577 seconds
    {"records_per_sec": 51681.555641, "mb_per_sec": 49.29}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.2.message_size=10000.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=none
    status: PASS
    run time: 57.747 seconds
    {"records_per_sec": 4320.991629, "mb_per_sec": 41.21}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.2.message_size=10000.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=snappy
    status: PASS
    run time: 55.024 seconds
    {"records_per_sec": 4223.096287, "mb_per_sec": 40.27}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.2.message_size=100000.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=none
    status: PASS
    run time: 53.355 seconds
    {"records_per_sec": 817.794028, "mb_per_sec": 77.99}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.2.message_size=100000.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=snappy
    status: PASS
    run time: 53.097 seconds
    {"records_per_sec": 797.859691, "mb_per_sec": 76.09}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.3.message_size=10.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=none
    status: PASS
    run time: 57.602 seconds
    {"records_per_sec": 1779132.025451, "mb_per_sec": 16.97}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.3.message_size=10.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=snappy
    status: PASS
    run time: 59.207 seconds
    {"records_per_sec": 1935367.267484, "mb_per_sec": 18.46}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.3.message_size=100.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=none
    status: PASS
    run time: 58.127 seconds
    {"records_per_sec": 330911.489152, "mb_per_sec": 31.56}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.3.message_size=100.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=snappy
    status: PASS
    run time: 50.805 seconds
    {"records_per_sec": 615677.522936, "mb_per_sec": 58.72}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.3.message_size=1000.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=none
    status: PASS
    run time: 51.221 seconds
    {"records_per_sec": 40378.158845, "mb_per_sec": 38.51}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.3.message_size=1000.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=snappy
    status: PASS
    run time: 50.578 seconds
    {"records_per_sec": 51901.392111, "mb_per_sec": 49.5}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.3.message_size=10000.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=none
    status: PASS
    run time: 53.369 seconds
    {"records_per_sec": 4363.13394, "mb_per_sec": 41.61}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.3.message_size=10000.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=snappy
    status: PASS
    run time: 53.982 seconds
    {"records_per_sec": 4323.775773, "mb_per_sec": 41.23}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.3.message_size=100000.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=none
    status: PASS
    run time: 54.736 seconds
    {"records_per_sec": 810.386473, "mb_per_sec": 77.28}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.3.message_size=100000.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=snappy
    status: PASS
    run time: 54.867 seconds
    {"records_per_sec": 795.023697, "mb_per_sec": 75.82}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.topic=topic-replication-factor-one.acks=1
    status: PASS
    run time: 48.440 seconds
    {"records_per_sec": 701608.468374, "mb_per_sec": 66.91}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.topic=topic-replication-factor-three.acks=-1
    status: PASS
    run time: 55.268 seconds
    {"records_per_sec": 268274.435339, "mb_per_sec": 25.58}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.topic=topic-replication-factor-three.acks=1
    status: PASS
    run time: 50.207 seconds
    {"records_per_sec": 467657.491289, "mb_per_sec": 44.6}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.topic=topic-replication-factor-three.security_protocol=PLAINTEXT.compression_type=none.acks=1.message_size=10
    status: PASS
    run time: 55.395 seconds
    {"records_per_sec": 2038543.742406, "mb_per_sec": 19.44}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.topic=topic-replication-factor-three.security_protocol=PLAINTEXT.compression_type=none.acks=1.message_size=100
    status: PASS
    run time: 52.835 seconds
    {"records_per_sec": 479520.185781, "mb_per_sec": 45.73}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.topic=topic-replication-factor-three.security_protocol=PLAINTEXT.compression_type=none.acks=1.message_size=1000
    status: PASS
    run time: 47.566 seconds
    {"records_per_sec": 50609.728507, "mb_per_sec": 48.27}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.topic=topic-replication-factor-three.security_protocol=PLAINTEXT.compression_type=none.acks=1.message_size=10000
    status: PASS
    run time: 49.949 seconds
    {"records_per_sec": 5941.124391, "mb_per_sec": 56.66}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.topic=topic-replication-factor-three.security_protocol=PLAINTEXT.compression_type=none.acks=1.message_size=100000
    status: PASS
    run time: 48.718 seconds
    {"records_per_sec": 1698.734177, "mb_per_sec": 162.0}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.topic=topic-replication-factor-three.security_protocol=PLAINTEXT.compression_type=snappy.acks=1.message_size=10
    status: PASS
    run time: 55.253 seconds
    {"records_per_sec": 1946594.923858, "mb_per_sec": 18.56}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.topic=topic-replication-factor-three.security_protocol=PLAINTEXT.compression_type=snappy.acks=1.message_size=100
    status: PASS
    run time: 50.712 seconds
    {"records_per_sec": 986894.852941, "mb_per_sec": 94.12}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.topic=topic-replication-factor-three.security_protocol=PLAINTEXT.compression_type=snappy.acks=1.message_size=1000
    status: PASS
    run time: 58.378 seconds
    {"records_per_sec": 112787.394958, "mb_per_sec": 107.56}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.topic=topic-replication-factor-three.security_protocol=PLAINTEXT.compression_type=snappy.acks=1.message_size=10000
    status: PASS
    run time: 50.972 seconds
    {"records_per_sec": 5747.751606, "mb_per_sec": 54.81}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.topic=topic-replication-factor-three.security_protocol=PLAINTEXT.compression_type=snappy.acks=1.message_size=100000
    status: PASS
    run time: 47.419 seconds
    {"records_per_sec": 1580.683157, "mb_per_sec": 150.75}
    --------------------------------------------------------------------------------
    

    AFTER

    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.topic=topic-replication-factor-three.num_producers=3.acks=1
    status: PASS
    run time: 56.262 seconds
    {"records_per_sec": 625731.99396, "mb_per_sec": 59.68}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_consumer_throughput.interbroker_security_protocol=PLAINTEXT.tls_version=TLSv1.2.security_protocol=SSL.compression_type=none
    status: PASS
    run time: 1 minute 15.345 seconds
    {"records_per_sec": 1458151.0645, "mb_per_sec": 139.0601}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_consumer_throughput.interbroker_security_protocol=PLAINTEXT.tls_version=TLSv1.2.security_protocol=SSL.compression_type=snappy
    status: PASS
    run time: 1 minute 5.284 seconds
    {"records_per_sec": 3173595.6839, "mb_per_sec": 302.6577}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_consumer_throughput.interbroker_security_protocol=PLAINTEXT.tls_version=TLSv1.3.security_protocol=SSL.compression_type=none
    status: PASS
    run time: 1 minute 16.265 seconds
    {"records_per_sec": 1477759.7163, "mb_per_sec": 140.9301}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_consumer_throughput.interbroker_security_protocol=PLAINTEXT.tls_version=TLSv1.3.security_protocol=SSL.compression_type=snappy
    status: PASS
    run time: 1 minute 4.992 seconds
    {"records_per_sec": 2992220.2274, "mb_per_sec": 285.3604}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_consumer_throughput.security_protocol=PLAINTEXT.compression_type=none
    status: PASS
    run time: 1 minute 2.562 seconds
    {"records_per_sec": 3987240.8293, "mb_per_sec": 380.2529}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_consumer_throughput.security_protocol=PLAINTEXT.compression_type=snappy
    status: PASS
    run time: 1 minute 1.068 seconds
    {"records_per_sec": 3531073.4463, "mb_per_sec": 336.7494}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_end_to_end_latency.security_protocol=SASL_PLAINTEXT.compression_type=none
    status: PASS
    run time: 43.213 seconds
    {"latency_99th_ms": 6.0, "latency_50th_ms": 0.0, "latency_999th_ms": 19.0}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_end_to_end_latency.security_protocol=SASL_PLAINTEXT.compression_type=snappy
    status: PASS
    run time: 44.302 seconds
    {"latency_99th_ms": 6.0, "latency_50th_ms": 0.0, "latency_999th_ms": 17.0}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_end_to_end_latency.security_protocol=SASL_SSL.compression_type=none
    status: PASS
    run time: 52.117 seconds
    {"latency_99th_ms": 6.0, "latency_50th_ms": 0.0, "latency_999th_ms": 17.0}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_end_to_end_latency.security_protocol=SASL_SSL.compression_type=snappy
    status: PASS
    run time: 48.599 seconds
    {"latency_99th_ms": 6.0, "latency_50th_ms": 0.0, "latency_999th_ms": 15.0}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_and_consumer.interbroker_security_protocol=PLAINTEXT.tls_version=TLSv1.2.security_protocol=SSL.compression_type=none
    status: PASS
    run time: 1 minute 6.347 seconds
    {"consumer": {"records_per_sec": 610165.3548, "mb_per_sec": 58.1899}, "producer": {"records_per_sec": 645161.290323, "mb_per_sec": 61.53}}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_and_consumer.interbroker_security_protocol=PLAINTEXT.tls_version=TLSv1.2.security_protocol=SSL.compression_type=snappy
    status: PASS
    run time: 58.196 seconds
    {"consumer": {"records_per_sec": 1365001.365, "mb_per_sec": 130.1767}, "producer": {"records_per_sec": 1315270.288044, "mb_per_sec": 125.43}}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_and_consumer.interbroker_security_protocol=PLAINTEXT.tls_version=TLSv1.3.security_protocol=SSL.compression_type=none
    status: PASS
    run time: 1 minute 8.056 seconds
    {"consumer": {"records_per_sec": 635364.3815, "mb_per_sec": 60.5931}, "producer": {"records_per_sec": 645369.474024, "mb_per_sec": 61.55}}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_and_consumer.interbroker_security_protocol=PLAINTEXT.tls_version=TLSv1.3.security_protocol=SSL.compression_type=snappy
    status: PASS
    run time: 55.585 seconds
    {"consumer": {"records_per_sec": 1396453.0094, "mb_per_sec": 133.1761}, "producer": {"records_per_sec": 1345170.836696, "mb_per_sec": 128.29}}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_and_consumer.security_protocol=PLAINTEXT.compression_type=none
    status: PASS
    run time: 57.844 seconds
    {"consumer": {"records_per_sec": 995024.8756, "mb_per_sec": 94.893}, "producer": {"records_per_sec": 934928.9454, "mb_per_sec": 89.16}}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_and_consumer.security_protocol=PLAINTEXT.compression_type=snappy
    status: PASS
    run time: 57.728 seconds
    {"consumer": {"records_per_sec": 1442793.2477, "mb_per_sec": 137.5955}, "producer": {"records_per_sec": 1343002.954607, "mb_per_sec": 128.08}}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_end_to_end_latency.interbroker_security_protocol=PLAINTEXT.tls_version=TLSv1.2.security_protocol=SSL.compression_type=none
    status: PASS
    run time: 59.918 seconds
    {"latency_99th_ms": 4.0, "latency_50th_ms": 0.0, "latency_999th_ms": 10.0}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_end_to_end_latency.interbroker_security_protocol=PLAINTEXT.tls_version=TLSv1.2.security_protocol=SSL.compression_type=snappy
    status: PASS
    run time: 58.414 seconds
    {"latency_99th_ms": 4.0, "latency_50th_ms": 0.0, "latency_999th_ms": 13.0}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_end_to_end_latency.interbroker_security_protocol=PLAINTEXT.tls_version=TLSv1.3.security_protocol=SSL.compression_type=none
    status: PASS
    run time: 58.689 seconds
    {"latency_99th_ms": 4.0, "latency_50th_ms": 0.0, "latency_999th_ms": 10.0}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_end_to_end_latency.interbroker_security_protocol=PLAINTEXT.tls_version=TLSv1.3.security_protocol=SSL.compression_type=snappy
    status: PASS
    run time: 57.322 seconds
    {"latency_99th_ms": 4.0, "latency_50th_ms": 0.0, "latency_999th_ms": 11.0}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_end_to_end_latency.security_protocol=PLAINTEXT.compression_type=none
    status: PASS
    run time: 53.221 seconds
    {"latency_99th_ms": 4.0, "latency_50th_ms": 0.0, "latency_999th_ms": 12.0}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_end_to_end_latency.security_protocol=PLAINTEXT.compression_type=snappy
    status: PASS
    run time: 53.012 seconds
    {"latency_99th_ms": 4.0, "latency_50th_ms": 0.0, "latency_999th_ms": 13.0}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_long_term_producer_throughput.interbroker_security_protocol=PLAINTEXT.tls_version=TLSv1.2.security_protocol=SSL.compression_type=none
    status: PASS
    run time: 1 minute 9.797 seconds
    {"0": {"records_per_sec": 712352.186921, "mb_per_sec": 67.94}}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_long_term_producer_throughput.interbroker_security_protocol=PLAINTEXT.tls_version=TLSv1.2.security_protocol=SSL.compression_type=snappy
    status: PASS
    run time: 58.567 seconds
    {"0": {"records_per_sec": 1586294.416244, "mb_per_sec": 151.28}}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_long_term_producer_throughput.interbroker_security_protocol=PLAINTEXT.tls_version=TLSv1.3.security_protocol=SSL.compression_type=none
    status: PASS
    run time: 1 minute 3.881 seconds
    {"0": {"records_per_sec": 730513.551026, "mb_per_sec": 69.67}}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_long_term_producer_throughput.interbroker_security_protocol=PLAINTEXT.tls_version=TLSv1.3.security_protocol=SSL.compression_type=snappy
    status: PASS
    run time: 58.038 seconds
    {"0": {"records_per_sec": 1624959.376016, "mb_per_sec": 154.97}}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_long_term_producer_throughput.security_protocol=PLAINTEXT.compression_type=none
    status: PASS
    run time: 54.064 seconds
    {"0": {"records_per_sec": 1184834.123223, "mb_per_sec": 112.99}}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_long_term_producer_throughput.security_protocol=PLAINTEXT.compression_type=snappy
    status: PASS
    run time: 53.514 seconds
    {"0": {"records_per_sec": 1647175.094713, "mb_per_sec": 157.09}}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.2.message_size=10.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=none
    status: PASS
    run time: 1 minute 0.244 seconds
    {"records_per_sec": 1814733.910222, "mb_per_sec": 17.31}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.2.message_size=10.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=snappy
    status: PASS
    run time: 59.460 seconds
    {"records_per_sec": 2014373.705538, "mb_per_sec": 19.21}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.2.message_size=100.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=none
    status: PASS
    run time: 58.051 seconds
    {"records_per_sec": 328240.890193, "mb_per_sec": 31.3}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.2.message_size=100.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=snappy
    status: PASS
    run time: 52.228 seconds
    {"records_per_sec": 747730.91922, "mb_per_sec": 71.31}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.2.message_size=1000.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=none
    status: PASS
    run time: 53.001 seconds
    {"records_per_sec": 40475.572979, "mb_per_sec": 38.6}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.2.message_size=1000.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=snappy
    status: PASS
    run time: 54.782 seconds
    {"records_per_sec": 70752.24038, "mb_per_sec": 67.47}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.2.message_size=10000.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=none
    status: PASS
    run time: 57.875 seconds
    {"records_per_sec": 4461.768617, "mb_per_sec": 42.55}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.2.message_size=10000.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=snappy
    status: PASS
    run time: 57.089 seconds
    {"records_per_sec": 4282.386726, "mb_per_sec": 40.84}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.2.message_size=100000.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=none
    status: PASS
    run time: 54.228 seconds
    {"records_per_sec": 824.324324, "mb_per_sec": 78.61}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.2.message_size=100000.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=snappy
    status: PASS
    run time: 51.462 seconds
    {"records_per_sec": 809.897405, "mb_per_sec": 77.24}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.3.message_size=10.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=none
    status: PASS
    run time: 59.836 seconds
    {"records_per_sec": 1812773.095624, "mb_per_sec": 17.29}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.3.message_size=10.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=snappy
    status: PASS
    run time: 56.087 seconds
    {"records_per_sec": 2029604.113111, "mb_per_sec": 19.36}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.3.message_size=100.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=none
    status: PASS
    run time: 55.743 seconds
    {"records_per_sec": 348707.976098, "mb_per_sec": 33.26}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.3.message_size=100.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=snappy
    status: PASS
    run time: 52.794 seconds
    {"records_per_sec": 974003.628447, "mb_per_sec": 92.89}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.3.message_size=1000.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=none
    status: PASS
    run time: 55.364 seconds
    {"records_per_sec": 41284.835435, "mb_per_sec": 39.37}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.3.message_size=1000.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=snappy
    status: PASS
    run time: 51.486 seconds
    {"records_per_sec": 57827.229642, "mb_per_sec": 55.15}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.3.message_size=10000.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=none
    status: PASS
    run time: 55.384 seconds
    {"records_per_sec": 4502.180476, "mb_per_sec": 42.94}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.3.message_size=10000.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=snappy
    status: PASS
    run time: 54.028 seconds
    {"records_per_sec": 4217.787555, "mb_per_sec": 40.22}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.3.message_size=100000.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=none
    status: PASS
    run time: 56.079 seconds
    {"records_per_sec": 839.79975, "mb_per_sec": 80.09}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.tls_version=TLSv1.3.message_size=100000.topic=topic-replication-factor-three.security_protocol=SSL.acks=1.compression_type=snappy
    status: PASS
    run time: 54.970 seconds
    {"records_per_sec": 826.35468, "mb_per_sec": 78.81}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.topic=topic-replication-factor-one.acks=1
    status: PASS
    run time: 46.430 seconds
    {"records_per_sec": 746068.371317, "mb_per_sec": 71.15}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.topic=topic-replication-factor-three.acks=-1
    status: PASS
    run time: 53.541 seconds
    {"records_per_sec": 318277.685558, "mb_per_sec": 30.35}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.topic=topic-replication-factor-three.acks=1
    status: PASS
    run time: 49.139 seconds
    {"records_per_sec": 487355.482934, "mb_per_sec": 46.48}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.topic=topic-replication-factor-three.security_protocol=PLAINTEXT.compression_type=none.acks=1.message_size=10
    status: PASS
    run time: 53.150 seconds
    {"records_per_sec": 2153686.136072, "mb_per_sec": 20.54}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.topic=topic-replication-factor-three.security_protocol=PLAINTEXT.compression_type=none.acks=1.message_size=100
    status: PASS
    run time: 51.156 seconds
    {"records_per_sec": 455438.411944, "mb_per_sec": 43.43}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.topic=topic-replication-factor-three.security_protocol=PLAINTEXT.compression_type=none.acks=1.message_size=1000
    status: PASS
    run time: 51.568 seconds
    {"records_per_sec": 52820.543093, "mb_per_sec": 50.37}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.topic=topic-replication-factor-three.security_protocol=PLAINTEXT.compression_type=none.acks=1.message_size=10000
    status: PASS
    run time: 46.992 seconds
    {"records_per_sec": 6253.960857, "mb_per_sec": 59.64}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.topic=topic-replication-factor-three.security_protocol=PLAINTEXT.compression_type=none.acks=1.message_size=100000
    status: PASS
    run time: 46.280 seconds
    {"records_per_sec": 1669.154229, "mb_per_sec": 159.18}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.topic=topic-replication-factor-three.security_protocol=PLAINTEXT.compression_type=snappy.acks=1.message_size=10
    status: PASS
    run time: 54.138 seconds
    {"records_per_sec": 1951122.546882, "mb_per_sec": 18.61}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.topic=topic-replication-factor-three.security_protocol=PLAINTEXT.compression_type=snappy.acks=1.message_size=100
    status: PASS
    run time: 47.680 seconds
    {"records_per_sec": 1021443.683409, "mb_per_sec": 97.41}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.topic=topic-replication-factor-three.security_protocol=PLAINTEXT.compression_type=snappy.acks=1.message_size=1000
    status: PASS
    run time: 47.886 seconds
    {"records_per_sec": 116104.67128, "mb_per_sec": 110.73}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.topic=topic-replication-factor-three.security_protocol=PLAINTEXT.compression_type=snappy.acks=1.message_size=10000
    status: PASS
    run time: 54.126 seconds
    {"records_per_sec": 5550.454921, "mb_per_sec": 52.93}
    --------------------------------------------------------------------------------
    test_id: kafkatest.benchmarks.core.benchmark_test.Benchmark.test_producer_throughput.topic=topic-replication-factor-three.security_protocol=PLAINTEXT.compression_type=snappy.acks=1.message_size=100000
    status: PASS
    run time: 46.799 seconds
    {"records_per_sec": 1582.54717, "mb_per_sec": 150.92}
    --------------------------------------------------------------------------------
    
    
    

    Committer Checklist (excluded from commit message)

    • [ ] Verify design and implementation
    • [ ] Verify test coverage and CI build status
    • [ ] Verify documentation (including upgrade notes)
    opened by chia7712 85
  • KAFKA-4916: test streams with brokers failing

    KAFKA-4916: test streams with brokers failing

    Several fixes for handling broker failures:

    • default replication value for internal topics is now 3 in test itself (not in streams code, that will require a KIP.
    • streams producer waits for acks from all replicas in test itself (not in streams code, that will require a KIP.
    • backoff time for streams client to try again after a failure to contact controller.
    • fix bug related to state store locks (this helps in multi-threaded scenarios)
    • fix related to catching exceptions property for network errors.
    • system test for all the above
    opened by enothereska 81
  • Kafka 4507: The client should send older versions of requests to the broker if necessary

    Kafka 4507: The client should send older versions of requests to the broker if necessary

    KAFKA-4507

    The client should send older versions of requests to the broker if necessary.

    Note: This builds on top of KAFKA-3600, which has not yet been committed yet.

    opened by cmccabe 81
  • MINOR: Multiple clean ups associated with scala collection

    MINOR: Multiple clean ups associated with scala collection

    Clean up of different aspects on the scala code. Some are potential performance improvement and some are readability improvements.

    Example for type of changes are:

    1. Merge consecutive filter calls to avoid creation of an intermediate collection
    2. Don’t resort to pattern matching to check value existence. The simplified expression works faster.
    3. For option, don’t emulate exists & other monadic functions using pattern matching. see: https://pavelfatin.com/scala-collections-tips-and-tricks/#options-processing
    4. Don’t use map when result is ignored, use foreach instead.
    5. Using .lengthCompare(n) > 0) instead of .length() reduces the complexity from O(length) to O(length min n)
    opened by divijvaidya 0
  • MINOR: Various cleanups in client tests

    MINOR: Various cleanups in client tests

    • Simplify assertions
    • Remove redundant types
    • Use lambdas instead of anonymous classes
    • Remove unnecessary throws

    Committer Checklist (excluded from commit message)

    • [ ] Verify design and implementation
    • [ ] Verify test coverage and CI build status
    • [ ] Verify documentation (including upgrade notes)
    opened by mimaison 0
  • KAFKA-14607: Move Scheduler/KafkaScheduler to server-common

    KAFKA-14607: Move Scheduler/KafkaScheduler to server-common

    For broader context, see:

    • KAFKA-14470: Move log layer to storage module

    Committer Checklist (excluded from commit message)

    • [ ] Verify design and implementation
    • [ ] Verify test coverage and CI build status
    • [ ] Verify documentation (including upgrade notes)
    opened by ijuma 0
  • KAFKA-14605 Change the log level to info when logIfAllowed is set, warn when logIfDenied is set.

    KAFKA-14605 Change the log level to info when logIfAllowed is set, warn when logIfDenied is set.

    KAFKA-14605 StandardAuthorizer log at INFO level when logIfDenied is set(otherwise, we log at TRACE), but at debug level when logIfAllowed is set. Since audit log is security log, it should be logged at default verbosity level, not debug or trace when logIfAllowed is set. So I think, log at INFO when allow, and log at WARN when deny is better.

        private void logAuditMessage(
            ...... ) {
            switch (rule.result()) {
                case ALLOWED:
                    if (action.logIfAllowed() && auditLog.isDebugEnabled()) {
                        auditLog.debug(......); // info maybe better
                    } else if (auditLog.isTraceEnabled()) {
                        auditLog.trace(buildAuditMessage(principal, requestContext, action, rule));
                    }
                    return;
    
                case DENIED:
                    if (action.logIfDenied()) {
                        auditLog.info(......); // warn maybe better
                    } else if (auditLog.isTraceEnabled()) {
                        auditLog.trace(buildAuditMessage(principal, requestContext, action, rule));
                    }
            }
        }
    

    Committer Checklist (excluded from commit message)

    • [x] Verify design and implementation
    • [ ] Verify test coverage and CI build status
    • [ ] Verify documentation (including upgrade notes)
    opened by curie71 0
  • KAFKA-14601: Improve exception handling in KafkaEventQueue

    KAFKA-14601: Improve exception handling in KafkaEventQueue

    If KafkaEventQueue gets an InterruptedException while waiting for a condition variable, it currently exits immediately. Instead, it should complete the remaining events exceptionally and then execute the cleanup event. This will allow us to finish any necessary cleanup steps.

    Also, handle cases where Event#handleException itself throws an exception.

    opened by cmccabe 0
Owner
The Apache Software Foundation
The Apache Software Foundation
A template and introduction for the first kafka stream application. The readme file contains all the required commands to run the Kafka cluster from Scrach

Kafka Streams Template Maven Project This project will be used to create the followings: A Kafka Producer Application that will start producing random

null 2 Jan 10, 2022
Demo project for Kafka Ignite streamer, Kafka as source and Ignite cache as sink

ignite-kafka-streamer **Description : Demo project for Kafka Ignite streamer, Kafka as source and Ignite cache as sink Step-1) Run both Zookeeper and

null 1 Feb 1, 2022
Kafka example - a simple producer and consumer for kafka using spring boot + java

Kafka example - a simple producer and consumer for kafka using spring boot + java

arturcampos 1 Feb 18, 2022
Mirror of Apache RocketMQ

Apache RocketMQ Apache RocketMQ is a distributed messaging and streaming platform with low latency, high performance and reliability, trillion-level c

The Apache Software Foundation 18.5k Dec 28, 2022
Mirror of Apache ActiveMQ

Welcome to Apache ActiveMQ Apache ActiveMQ is a high performance Apache 2.0 licensed Message Broker and JMS 1.1 implementation. Getting Started To hel

The Apache Software Foundation 2.1k Jan 2, 2023
Mirror of Apache ActiveMQ Artemis

ActiveMQ Artemis This file describes some minimum 'stuff one needs to know' to get started coding in this project. Source For details about the modify

The Apache Software Foundation 824 Dec 26, 2022
Kryptonite is a turn-key ready transformation (SMT) for Apache Kafka® Connect to do field-level 🔒 encryption/decryption 🔓 of records. It's an UNOFFICIAL community project.

Kryptonite - An SMT for Kafka Connect Kryptonite is a turn-key ready transformation (SMT) for Apache Kafka® to do field-level encryption/decryption of

Hans-Peter Grahsl 53 Jan 3, 2023
FLiP: StreamNative: Cloud-Native: Streaming Analytics Using Apache Flink SQL on Apache Pulsar

StreamingAnalyticsUsingFlinkSQL FLiP: StreamNative: Cloud-Native: Streaming Analytics Using Apache Flink SQL on Apache Pulsar Running on NVIDIA XAVIER

Timothy Spann 5 Dec 19, 2021
A distributed event bus that implements a RESTful API abstraction on top of Kafka-like queues

Nakadi Event Broker Nakadi is a distributed event bus broker that implements a RESTful API abstraction on top of Kafka-like queues, which can be used

Zalando SE 866 Dec 21, 2022
Fast and reliable message broker built on top of Kafka.

Hermes Hermes is an asynchronous message broker built on top of Kafka. We provide reliable, fault tolerant REST interface for message publishing and a

Allegro Tech 742 Jan 3, 2023
Dataflow template which read data from Kafka (Support SSL), transform, and outputs the resulting records to BigQuery

Kafka to BigQuery Dataflow Template The pipeline template read data from Kafka (Support SSL), transform the data and outputs the resulting records to

DoiT International 12 Jun 1, 2021
A command line client for Kafka Connect

kcctl -- A CLI for Apache Kafka Connect This project is a command-line client for Kafka Connect. Relying on the idioms and semantics of kubectl, it al

Gunnar Morling 274 Dec 19, 2022
A command line client for Kafka Connect

?? kcctl – Your Cuddly CLI for Apache Kafka Connect This project is a command-line client for Kafka Connect. Relying on the idioms and semantics of ku

kcctl 274 Dec 19, 2022
Publish Kafka messages from HTTP

Kafka Bridge Publish Kafka messages from HTTP Configuration Example configuration for commonly used user + password authentication: kafka-bridge: ka

neuland - Büro für Informatik 4 Nov 9, 2021
Implementação de teste com Kafka

TesteKafka01 Implementação de teste com Kafka Projeto criado para estudo e testes com Kafka Recursos que estarão disponiveis: -Envio de msg -Recebe Ms

null 3 Sep 17, 2021
Firehose is an extensible, no-code, and cloud-native service to load real-time streaming data from Kafka to data stores, data lakes, and analytical storage systems.

Firehose - Firehose is an extensible, no-code, and cloud-native service to load real-time streaming data from Kafka to data stores, data lakes, and analytical storage systems.

Open DataOps Foundation 279 Dec 22, 2022
MemQ is a new PubSub system that augments Kafka

MemQ: An efficient, scalable cloud native PubSub system MemQ is a new PubSub system that augments Kafka at Pinterest. It uses a decoupled storage and

Pinterest 56 Dec 30, 2022
KC4Streams - a simple Java library that provides utility classes and standard implementations for most of the Kafka Streams pluggable interfaces

KC4Streams (which stands for Kafka Commons for Streams) is a simple Java library that provides utility classes and standard implementations for most of the Kafka Streams pluggable interfaces.

StreamThoughts 2 Mar 2, 2022
Output Keycloak Events and Admin Events to a Kafka topic.

keycloak-kafka-eventlistener Output Keycloak Events and Admin Events to a Kafka topic. Based on Keycloak 15.0.2+ / RH-SSO 7.5.0+ How to use the plugin

Dwayne Du 4 Oct 10, 2022