- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *. files (54): HEADER tests/docker/ssh-config tests/docker/ssh/authorized_keys tests/docker/ssh/config tests/docker/ssh/id_rsa tests/docker/Dockerfile tests/docker/ducker-ak licenses/zstd-jni-BSD-2-clause licenses/paranamer-BSD-3-clause licenses/jsr305-BSD-3-clause licenses/pcollections-MIT licenses/jopt-simple-MIT licenses/argparse-MIT licenses/protobuf-java-BSD-3-clause licenses/re2j-GO licenses/slf4j-MIT licenses/jline-BSD-3-clause licenses/hdrHistogram-BSD-2-clause licenses/classgraph-MIT gradlewAll gradlew LICENSE NOTICE-binary connect/runtime/src/test/resources/test-plugins/read-version-from-resource-v2/version connect/runtime/src/test/resources/test-plugins/read-version-from-resource-v1/version Vagrantfile NOTICE LICENSE-binary vagrant/aws/aws-access-keys-commands docker/examples/fixtures/secrets/kafka_ssl_key_creds docker/examples/fixtures/secrets/kafka_keystore_creds docker/examples/fixtures/secrets/kafka_truststore_creds docker/docker_official_images/3.7.0/jvm/jsa_launch docker/docker_official_images/3.7.0/jvm/resources/common-scripts/configure docker/docker_official_images/3.7.0/jvm/resources/common-scripts/bash-config docker/docker_official_images/3.7.0/jvm/resources/common-scripts/run docker/docker_official_images/3.7.0/jvm/resources/common-scripts/configureDefaults docker/docker_official_images/3.7.0/jvm/launch docker/docker_official_images/3.7.0/jvm/Dockerfile docker/resources/common-scripts/configure docker/resources/common-scripts/bash-config docker/resources/common-scripts/run docker/resources/common-scripts/configureDefaults docker/jvm/jsa_launch docker/jvm/launch docker/jvm/Dockerfile docker/native/launch docker/native/Dockerfile docker/test/fixtures/secrets/kafka_ssl_key_creds docker/test/fixtures/secrets/kafka_keystore_creds docker/test/fixtures/secrets/kafka_truststore_creds clients/src/test/resources/serializedData/offsetAndMetadataWithLeaderEpoch clients/src/test/resources/serializedData/topicPartitionSerializedfile clients/src/test/resources/serializedData/offsetAndMetadataBeforeLeaderEpoch - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.png files (47): docs/images/streams-interactive-queries-02.png docs/images/streams-welcome.png docs/images/streams-table-duality-03.png docs/images/creating-streams-iframe-placeholder.png docs/images/log_consumer.png docs/images/streams-elastic-scaling-3.png docs/images/kafka-apis.png docs/images/streams-interactive-queries-03.png docs/images/kafka_multidc_complex.png docs/images/log_anatomy.png docs/images/streams-time-windows-tumbling.png docs/images/kafka_log.png docs/images/log_compaction.png docs/images/streams-table-duality-01.png docs/images/transforming_part_2-iframe-placeholder.png docs/images/streams-sliding-windows.png docs/images/streams-interactive-queries-01.png docs/images/tracking_high_level.png docs/images/streams-elastic-scaling-2.png docs/images/mirror-maker.png docs/images/streams-interactive-queries-api-01.png docs/images/intro_to_streams-iframe-placeholder.png docs/images/icons/tutorials.png docs/images/icons/rabobank.png docs/images/icons/documentation.png docs/images/icons/zalando.png docs/images/icons/architecture.png docs/images/icons/tutorials--white.png docs/images/icons/line.png docs/images/icons/new-york.png docs/images/icons/architecture--white.png docs/images/icons/documentation--white.png docs/images/producer_consumer.png docs/images/log_cleaner_anatomy.png docs/images/streams-table-duality-02.png docs/images/streams-cache-and-commit-interval.png docs/images/streams-table-updates-02.png docs/images/kafka_multidc.png docs/images/streams-time-windows-hopping.png docs/images/transforming_part_1-iframe-placeholder.png docs/images/streams-table-updates-01.png docs/images/streams-session-windows-02.png docs/images/streams-stateful_operations.png docs/images/consumer-groups.png docs/images/streams-session-windows-01.png docs/images/streams-interactive-queries-api-02.png docs/images/streams-elastic-scaling-1.png - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.yaml files (33): .github/workflows/pr-reviewed.yml .github/workflows/docker_rc_release.yml .github/workflows/generate-reports.yml .github/workflows/pr-labeled.yml .github/workflows/docker_scan.yml .github/workflows/pr-linter.yml .github/workflows/docker_promote.yml .github/workflows/workflow-requested.yml .github/workflows/docker_build_and_test.yml .github/workflows/stale.yml .github/workflows/docker_official_image_build_and_test.yml .github/workflows/ci-complete.yml .github/workflows/pr-labels-cron.yml .github/workflows/deflake.yml .github/workflows/prepare_docker_official_image_source.yml .github/workflows/ci.yml .github/workflows/pr-update.yml .github/workflows/build.yml .github/configs/labeler.yml .github/actions/run-gradle/action.yml .github/actions/setup-gradle/action.yml .github/actions/gh-api-approve-run/action.yml .github/actions/gh-api-update-status/action.yml .github/actions/setup-python/action.yml docker/examples/docker-compose-files/cluster/combined/ssl/docker-compose.yml docker/examples/docker-compose-files/cluster/combined/plaintext/docker-compose.yml docker/examples/docker-compose-files/cluster/isolated/ssl/docker-compose.yml docker/examples/docker-compose-files/cluster/isolated/plaintext/docker-compose.yml docker/examples/docker-compose-files/single-node/ssl/docker-compose.yml docker/examples/docker-compose-files/single-node/plaintext/docker-compose.yml docker/examples/docker-compose-files/single-node/file-input/docker-compose.yml docker/test/fixtures/mode/combined/docker-compose.yml docker/test/fixtures/mode/isolated/docker-compose.yml - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.converter files (15): connect/api/src/main/resources/META-INF/services/org.apache.kafka.connect.storage.Converter connect/runtime/src/main/resources/META-INF/services/org.apache.kafka.connect.storage.Converter connect/runtime/src/test/resources/test-plugins/sampling-configurable/META-INF/services/org.apache.kafka.connect.storage.Converter connect/runtime/src/test/resources/test-plugins/multiple-plugins-in-jar/META-INF/services/org.apache.kafka.connect.storage.Converter connect/runtime/src/test/resources/test-plugins/bad-packaging/META-INF/services/org.apache.kafka.connect.storage.Converter connect/runtime/src/test/resources/test-plugins/service-loader/META-INF/services/org.apache.kafka.connect.storage.Converter connect/runtime/src/test/resources/test-plugins/read-version-from-resource-v2/META-INF/services/org.apache.kafka.connect.storage.Converter connect/runtime/src/test/resources/test-plugins/classpath-converter/META-INF/services/org.apache.kafka.connect.storage.Converter connect/runtime/src/test/resources/test-plugins/read-version-from-resource-v1/META-INF/services/org.apache.kafka.connect.storage.Converter connect/runtime/src/test/resources/test-plugins/sampling-converter/META-INF/services/org.apache.kafka.connect.storage.Converter connect/runtime/src/test/resources/test-plugins/aliased-static-field/META-INF/services/org.apache.kafka.connect.storage.Converter connect/runtime/src/test/resources/test-plugins/always-throw-exception/META-INF/services/org.apache.kafka.connect.storage.Converter connect/runtime/src/test/resources/test-plugins/subclass-of-classpath/META-INF/services/org.apache.kafka.connect.storage.Converter connect/runtime/src/test/resources/META-INF/services/org.apache.kafka.connect.storage.Converter connect/json/src/main/resources/META-INF/services/org.apache.kafka.connect.storage.Converter - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.jks files (7): docker/examples/fixtures/secrets/kafka01.keystore.jks docker/examples/fixtures/secrets/kafka.truststore.jks docker/examples/fixtures/client-secrets/client.keystore.jks docker/test/fixtures/secrets/client.keystore.jks docker/test/fixtures/secrets/kafka02.keystore.jks docker/test/fixtures/secrets/kafka01.keystore.jks docker/test/fixtures/secrets/kafka.truststore.jks - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.jpg files (7): docs/images/streams-architecture-threads.jpg docs/images/streams-architecture-topology.jpg docs/images/streams-concepts-topology.jpg docs/images/icons/NYT.jpg docs/images/streams-architecture-tasks.jpg docs/images/streams-architecture-overview.jpg docs/images/streams-architecture-states.jpg - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.sinkconnector files (6): connect/api/src/test/resources/META-INF/services/org.apache.kafka.connect.sink.SinkConnector connect/runtime/src/test/resources/test-plugins/bad-packaging/META-INF/services/org.apache.kafka.connect.sink.SinkConnector connect/runtime/src/test/resources/test-plugins/sampling-connector/META-INF/services/org.apache.kafka.connect.sink.SinkConnector connect/runtime/src/test/resources/META-INF/services/org.apache.kafka.connect.sink.SinkConnector connect/file/src/main/resources/META-INF/services/org.apache.kafka.connect.sink.SinkConnector connect/test-plugins/src/main/resources/META-INF/services/org.apache.kafka.connect.sink.SinkConnector - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.headerconverter files (6): connect/api/src/main/resources/META-INF/services/org.apache.kafka.connect.storage.HeaderConverter connect/runtime/src/main/resources/META-INF/services/org.apache.kafka.connect.storage.HeaderConverter connect/runtime/src/test/resources/test-plugins/bad-packaging/META-INF/services/org.apache.kafka.connect.storage.HeaderConverter connect/runtime/src/test/resources/test-plugins/sampling-header-converter/META-INF/services/org.apache.kafka.connect.storage.HeaderConverter connect/runtime/src/test/resources/META-INF/services/org.apache.kafka.connect.storage.HeaderConverter connect/json/src/main/resources/META-INF/services/org.apache.kafka.connect.storage.HeaderConverter - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.conf files (5): tests/kafkatest/services/security/templates/admin_client_as_broker_jaas.conf tests/kafkatest/services/security/templates/jaas.conf config/trogdor.conf core/src/test/resources/minikdc-krb5.conf checkstyle/.scalafmt.conf - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.sourceconnector files (5): connect/api/src/test/resources/META-INF/services/org.apache.kafka.connect.source.SourceConnector connect/runtime/src/test/resources/META-INF/services/org.apache.kafka.connect.source.SourceConnector connect/file/src/main/resources/META-INF/services/org.apache.kafka.connect.source.SourceConnector connect/test-plugins/src/main/resources/META-INF/services/org.apache.kafka.connect.source.SourceConnector connect/mirror/src/main/resources/META-INF/services/org.apache.kafka.connect.source.SourceConnector - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.connectorclientconfigoverridepolicy files (4): connect/runtime/src/main/resources/META-INF/services/org.apache.kafka.connect.connector.policy.ConnectorClientConfigOverridePolicy connect/runtime/src/test/resources/test-plugins/bad-packaging/META-INF/services/org.apache.kafka.connect.connector.policy.ConnectorClientConfigOverridePolicy connect/runtime/src/test/resources/test-plugins/non-migrated/META-INF/services/org.apache.kafka.connect.connector.policy.ConnectorClientConfigOverridePolicy connect/runtime/src/test/resources/test-plugins/subclass-of-classpath/META-INF/services/org.apache.kafka.connect.connector.policy.ConnectorClientConfigOverridePolicy - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.connectrestextension files (3): connect/runtime/src/test/resources/test-plugins/bad-packaging/META-INF/services/org.apache.kafka.connect.rest.ConnectRestExtension connect/runtime/src/test/resources/META-INF/services/org.apache.kafka.connect.rest.ConnectRestExtension connect/basic-auth-extension/src/main/resources/META-INF/services/org.apache.kafka.connect.rest.ConnectRestExtension - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.local files (2): vagrant/aws/aws-example-Vagrantfile.local vagrant/system-test-Vagrantfile.local - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.predicate files (2): connect/runtime/src/test/resources/META-INF/services/org.apache.kafka.connect.transforms.predicates.Predicate connect/transforms/src/main/resources/META-INF/services/org.apache.kafka.connect.transforms.predicates.Predicate - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.configprovider files (2): connect/runtime/src/test/resources/test-plugins/sampling-config-provider/META-INF/services/org.apache.kafka.common.config.provider.ConfigProvider clients/src/main/resources/META-INF/services/org.apache.kafka.common.config.provider.ConfigProvider - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.transformation files (2): connect/runtime/src/test/resources/META-INF/services/org.apache.kafka.connect.transforms.Transformation connect/transforms/src/main/resources/META-INF/services/org.apache.kafka.connect.transforms.Transformation - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.0 files (2): licenses/eclipse-distribution-license-1.0 licenses/eclipse-public-license-2.0 - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.template files (1): gradle/openapi.template - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.extension files (1): test-common/test-common-runtime/src/main/resources/META-INF/services/org.junit.jupiter.api.extension.Extension - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.serviceloadedclass files (1): connect/runtime/src/test/resources/test-plugins/service-loader/META-INF/services/test.plugins.ServiceLoadedClass - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.ldiff files (1): core/src/test/resources/minikdc.ldiff - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.postdiscoveryfilter files (1): test-common/test-common-util/src/main/resources/META-INF/services/org.junit.platform.launcher.PostDiscoveryFilter - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.1 files (1): licenses/CDDL+GPL-1.1 - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.gitkeep files (1): docker/docker_official_images/.gitkeep - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.header files (1): checkstyle/java.header - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -