Repository Analysis

apache/pulsar

Apache Pulsar - distributed pub-sub messaging system

2.9 Likely human-written View on GitHub

Analysis Overview

This report presents the forensic synthetic code analysis of apache/pulsar, a Java project with 15,297 GitHub stars. SynthScan v2.0 examined 1,078,583 lines of code across 5089 source files, recording 650 pattern matches distributed across 18 syntactic categories. The overall adjusted score of 2.9 places this repository in the Likely human-written band.

The scanner applied 160+ deterministic lexical heuristics, multi-line block detectors, abstract syntax tree depth profilers, and a cross-file Jaccard similarity matrix to construct a statistically normalised synthetic code estimate. All matches are individually weighted by severity coefficient and contextual multiplier before summation, and the resulting headline score is temporally discounted to account for the repository's development history relative to the commercial emergence of large language model coding tooling (November 2022 onward).

2.9
Adjusted Score
2.9
Raw Score
100%
Time Factor
2026-07-14
Last Push
15.3K
Stars
Java
Language
1.1M
Lines of Code
5.1K
Files
650
Pattern Hits
2026-07-14
Scan Date
0.05
HC Hit Rate

What These Metrics Mean

Adjusted Score
Primary synthetic code indicator. Raw score normalised per 1,000 lines of code and multiplied by the temporal discount factor. This is the definitive comparative metric — use it to rank repositories by AI authorship density.
Raw Score
The unmodified sum of all severity-weighted, context-multiplied pattern match scores before temporal discounting. Reflects the absolute signal strength independent of when the repository was last active.
Time Factor
The temporal discount multiplier (0–100%) applied to the raw score. Repositories last updated before ChatGPT's launch (Nov 2022) receive a 5% factor. Full signal is only assigned to repositories active in the post-adoption era (Jan 2024+).
Pattern Hits
Total count of individual pattern matches across all files and categories. A high hit count with a low score may indicate a very large codebase with isolated AI snippets; a low count with a high score indicates dense, concentrated AI signatures.
HC Hit Rate
High+Critical pattern hits per file, averaged across the repository. This orthogonal signal catches repositories where a few files are densely packed with high-severity AI tells — a strong indicator even when the normalised score appears moderate due to codebase size.
Lines of Code / Files
Total lines and files analysed. The scanner examines 94 file extensions. These denominators are used to normalise the score, enabling fair comparison between repositories of vastly different sizes.

Score History

This chart maps the temporal evolution of the adjusted synthetic code score across successive scan runs. An upward trajectory indicates ongoing incorporation of AI-generated code or expanding LLM-assisted scaffolding; a stable or declining trajectory may reflect active human refactoring, code removal, or the adoption of stricter authorship policies. The dashed secondary line (right axis) independently tracks total raw pattern hit count, which can diverge from the normalised score when codebase size changes significantly between scans.

Severity Breakdown

Classifies detected patterns by their diagnostic confidence and structural impact. CRITICAL patterns (coefficient 10) represent definitive synthetic signatures — hallucinated imports, explicit LLM attribution metadata — virtually never produced by human authors. HIGH (5) indicates strong structural tells such as cross-file repetition or cross-linguistic idioms. MEDIUM (2) covers recognisable conversational padding and AI-specific vocabulary. LOW (1) captures subtle indicators like tautological comments and generic boilerplate that require density to carry independent signal.

CRITICAL 243HIGH 5MEDIUM 12LOW 390

Directory Score Breakdown

This horizontal bar chart decomposes the repository's raw synthetic code score by top-level directory, allowing you to pinpoint precisely which modules or components carry the highest AI authorship density. Directories with disproportionately high scores relative to their size warrant targeted manual review: concentrated AI signatures often trace back to mass-generated configuration layers, auto-ported test suites, LLM-scaffolded boilerplate classes, or entire subsystems authored under heavy copilot assistance. Use this view to prioritise your human code-review effort.

Pattern Findings

The scanner identified 650 distinct pattern matches across 18 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a statistically significant AI authorship indicator. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.

Reading the findings table: The Severity column indicates the diagnostic confidence level (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — comment-context matches receive a ×1.5 weight because LLMs systematically over-annotate. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier as dense clusters constitute far stronger evidence of synthetic authorship than isolated hits.

Hallucination Indicators243 hits · 2635 pts
SeverityFileLineSnippetContext
CRITICAL…g/apache/pulsar/websocket/proxy/ProxyRoleAuthTest.java392 org.apache.pulsar.common.policies.data.ClusterData.builder()CODE
CRITICAL…g/apache/pulsar/websocket/proxy/ProxyRoleAuthTest.java406 org.apache.pulsar.common.policies.data.TenantInfoImpl.builder()CODE
CRITICAL…ction/pendingack/impl/MetadataPendingAckStoreTest.java158 new org.apache.pulsar.broker.transaction.metadata.TxnEvent(CODE
CRITICAL…ction/pendingack/impl/MetadataPendingAckStoreTest.java185 new org.apache.pulsar.broker.transaction.metadata.TxnEvent(CODE
CRITICAL…ction/pendingack/impl/MetadataPendingAckStoreTest.java237 return new org.apache.pulsar.metadata.api.ScanConsumer() {CODE
CRITICAL…saction/buffer/impl/MetadataTransactionBufferTest.java246 new org.apache.pulsar.broker.transaction.metadata.SegmentWatermark(5, 0),CODE
CRITICAL…saction/buffer/impl/MetadataTransactionBufferTest.java271 new org.apache.pulsar.broker.transaction.metadata.SegmentWatermark(5, 0),CODE
CRITICAL…saction/buffer/impl/MetadataTransactionBufferTest.java333 new org.apache.pulsar.broker.transaction.metadata.SegmentWatermark(5, 0),CODE
CRITICAL…saction/buffer/impl/MetadataTransactionBufferTest.java408 new org.apache.pulsar.broker.transaction.metadata.SegmentWatermark(5, 0),CODE
CRITICAL…saction/buffer/impl/MetadataTransactionBufferTest.java443 new org.apache.pulsar.metadata.api.ScanConsumer() {CODE
CRITICAL…lsar/broker/loadbalance/SimpleLoadManagerImplTest.java296 new org.apache.pulsar.policies.data.loadbalancer.LoadReport();CODE
CRITICAL…lsar/broker/loadbalance/SimpleLoadManagerImplTest.java373 new org.apache.pulsar.policies.data.loadbalancer.LoadReport();CODE
CRITICAL…lsar/broker/loadbalance/SimpleLoadManagerImplTest.java426 new org.apache.pulsar.policies.data.loadbalancer.LoadReport();CODE
CRITICAL…lsar/broker/loadbalance/SimpleLoadManagerImplTest.java430 new org.apache.pulsar.policies.data.loadbalancer.LoadReport();CODE
CRITICAL…xtensions/AntiAffinityNamespaceGroupExtensionTest.java99 org.apache.commons.lang3.reflect.FieldUtils.readDeclaredField(antiAffinityGroupPolicyHelper,CODE
CRITICAL…sar/broker/resourcegroup/ResourceGroupServiceTest.java92 new org.apache.pulsar.common.policies.data.ResourceGroup();CODE
CRITICAL…sar/broker/resourcegroup/ResourceGroupServiceTest.java152 new org.apache.pulsar.common.policies.data.ResourceGroup();CODE
CRITICAL…sar/broker/resourcegroup/ResourceGroupServiceTest.java166 new org.apache.pulsar.common.policies.data.ResourceGroup();CODE
CRITICAL…sar/broker/resourcegroup/ResourceGroupServiceTest.java281 service.resourceGroupCreate(rg, new org.apache.pulsar.common.policies.data.ResourceGroup());CODE
CRITICAL…sar/broker/resourcegroup/ResourceGroupServiceTest.java350 rgs.resourceGroupCreate(rgName, new org.apache.pulsar.common.policies.data.ResourceGroup());CODE
CRITICAL…sar/broker/resourcegroup/ResourceGroupServiceTest.java430 rgs.resourceGroupCreate(rg, new org.apache.pulsar.common.policies.data.ResourceGroup());CODE
CRITICAL…sar/broker/resourcegroup/ResourceGroupServiceTest.java471 rgs.resourceGroupCreate(rg, new org.apache.pulsar.common.policies.data.ResourceGroup());CODE
CRITICAL…sar/broker/resourcegroup/ResourceGroupServiceTest.java507 rgs.resourceGroupCreate(rg, new org.apache.pulsar.common.policies.data.ResourceGroup());CODE
CRITICAL…r/resourcegroup/ResourceGroupUsageAggregationTest.java252 new org.apache.pulsar.common.policies.data.ResourceGroup();CODE
CRITICAL…broker/resourcegroup/ResourceGroupRateLimiterTest.java44 new org.apache.pulsar.common.policies.data.ResourceGroup();CODE
CRITICAL…ker/resourcegroup/RGUsageMTAggrWaitForAllMsgsTest.java783 new org.apache.pulsar.common.policies.data.ResourceGroup();CODE
CRITICAL…/org/apache/pulsar/broker/admin/TopicPoliciesTest.java4753 org.apache.pulsar.common.util.ObjectMapperFactory.getThreadLocal().writeValueAsBytes(policies),CODE
CRITICAL…che/pulsar/broker/intercept/BrokerInterceptorTest.java281 jakarta.ws.rs.core.Response.noContent().build().getStatus());CODE
CRITICAL…roker/service/OpenTelemetryTracingIntegrationTest.java149 io.opentelemetry.api.common.AttributeKey.stringKey("messaging.system")), "pulsar");CODE
CRITICAL…roker/service/OpenTelemetryTracingIntegrationTest.java158 io.opentelemetry.api.common.AttributeKey.stringKey("messaging.system")), "pulsar");CODE
CRITICAL…roker/service/OpenTelemetryTracingIntegrationTest.java160 io.opentelemetry.api.common.AttributeKey.stringKey("messaging.pulsar.acknowledgment.type")),CODE
CRITICAL…roker/service/OpenTelemetryTracingIntegrationTest.java267 io.opentelemetry.api.common.AttributeKey.stringKey("messaging.pulsar.acknowledgment.type")),CODE
CRITICAL…roker/service/OpenTelemetryTracingIntegrationTest.java315 io.opentelemetry.api.common.AttributeKey.stringKey(CODE
CRITICAL…roker/service/OpenTelemetryTracingIntegrationTest.java369 io.opentelemetry.api.common.AttributeKey.stringKey(CODE
CRITICAL…roker/service/OpenTelemetryTracingIntegrationTest.java519 io.opentelemetry.api.common.AttributeKey.stringKey(CODE
CRITICAL…roker/service/OpenTelemetryTracingIntegrationTest.java624 io.opentelemetry.api.common.AttributeKey.stringKey(CODE
CRITICAL…roker/service/OpenTelemetryTracingIntegrationTest.java678 io.opentelemetry.api.common.AttributeKey.stringKey(CODE
CRITICAL…roker/service/OpenTelemetryTracingIntegrationTest.java750 io.opentelemetry.api.common.AttributeKey.stringKey(CODE
CRITICAL…roker/service/OpenTelemetryTracingIntegrationTest.java814 io.opentelemetry.api.common.AttributeKey.stringKey("messaging.system")));CODE
CRITICAL…roker/service/OpenTelemetryTracingIntegrationTest.java816 io.opentelemetry.api.common.AttributeKey.stringKey("messaging.system")), "pulsar");CODE
CRITICAL…schema/ProtobufNativeSchemaCompatibilityCheckTest.java33 getSchemaData(org.apache.pulsar.client.api.schema.proto.Test.TestMessage.getDescriptor());CODE
CRITICAL…schema/ProtobufNativeSchemaCompatibilityCheckTest.java36 getSchemaData(org.apache.pulsar.client.api.schema.proto.Test.SubMessage.getDescriptor());CODE
CRITICAL…ulsar/broker/service/scalable/AutoScaleConfigTest.java62 org.apache.pulsar.common.policies.data.AutoScalePolicyOverride.builder()CODE
CRITICAL…ulsar/broker/service/scalable/AutoScaleConfigTest.java67 org.apache.pulsar.common.policies.data.AutoScalePolicyOverride.builder()CODE
CRITICAL…ulsar/broker/service/scalable/AutoScaleConfigTest.java97 org.apache.pulsar.common.policies.data.AutoScalePolicyOverride.builder()CODE
CRITICAL…/broker/service/scalable/ScalableTopicServiceTest.java335 new org.apache.pulsar.common.scalable.SegmentLoadStats(1, 1, 1, 1)).get();CODE
CRITICAL…oker/service/scalable/ScalableTopicControllerTest.java537 org.apache.pulsar.common.scalable.SegmentInfo seg0 = new org.apache.pulsar.common.scalable.SegmentInfo(CODE
CRITICAL…oker/service/scalable/ScalableTopicControllerTest.java539 org.apache.pulsar.common.scalable.HashRange.of(0x0000, 0x3FFF),CODE
CRITICAL…oker/service/scalable/ScalableTopicControllerTest.java544 org.apache.pulsar.common.scalable.SegmentInfo seg1 = new org.apache.pulsar.common.scalable.SegmentInfo(CODE
CRITICAL…oker/service/scalable/ScalableTopicControllerTest.java546 org.apache.pulsar.common.scalable.HashRange.of(0x4000, 0x7FFF),CODE
CRITICAL…oker/service/scalable/ScalableTopicControllerTest.java550 org.apache.pulsar.common.scalable.SegmentInfo seg2 = new org.apache.pulsar.common.scalable.SegmentInfo(CODE
CRITICAL…oker/service/scalable/ScalableTopicControllerTest.java552 org.apache.pulsar.common.scalable.HashRange.of(0x8000, 0xFFFF),CODE
CRITICAL…oker/service/scalable/ScalableTopicControllerTest.java617 new org.apache.pulsar.client.admin.PulsarAdminException.NotFoundException(CODE
CRITICAL…oker/service/scalable/ScalableTopicControllerTest.java634 new org.apache.pulsar.client.admin.PulsarAdminException(CODE
CRITICAL…oker/service/scalable/ScalableTopicControllerTest.java654 new org.apache.pulsar.client.admin.PulsarAdminException(CODE
CRITICAL…oker/service/scalable/ScalableTopicControllerTest.java699 new org.apache.pulsar.common.scalable.SegmentLoadStats(1, 1, 1, 1)).get();CODE
CRITICAL…oker/service/scalable/ScalableTopicControllerTest.java707 clock.set(startMs + java.util.concurrent.TimeUnit.MINUTES.toMillis(1) + 1_000L);CODE
CRITICAL…oker/service/scalable/ScalableTopicControllerTest.java796 new org.apache.pulsar.common.policies.data.Policies();CODE
CRITICAL…oker/service/scalable/ScalableTopicControllerTest.java798 new org.apache.pulsar.common.policies.data.RetentionPolicies(CODE
CRITICAL…che/pulsar/broker/stats/MetricsAuthenticationTest.java57 Client client = jakarta.ws.rs.client.ClientBuilder.newClient(new ClientConfig().register(LoggingFeature.class));CODE
183 more matches not shown…
Over-Commented Block260 hits · 260 pts
SeverityFileLineSnippetContext
LOW.asf.yaml1#COMMENT
LOWcodecov.yml1#COMMENT
LOWdocker/get-version.sh1#!/usr/bin/env bashCOMMENT
LOWdocker/publish.sh1#!/usr/bin/env bashCOMMENT
LOWdocker/build.sh1#!/usr/bin/env bashCOMMENT
LOWdocker/pulsar/scripts/apply-config-from-env.py1#!/usr/bin/env python3COMMENT
LOWdocker/pulsar/scripts/gen-yml-from-env.py1#!/usr/bin/env python3COMMENT
LOWdocker/pulsar/scripts/update-ini-from-env.py1#!/usr/bin/env python3COMMENT
LOWdocker/pulsar/scripts/generate-zookeeper-config.sh1#!/usr/bin/env bashCOMMENT
LOWdocker/pulsar/scripts/update-rocksdb-conf-from-env.py1#!/usr/bin/env python3COMMENT
LOW…er/pulsar/scripts/apply-config-from-env-with-prefix.py1#!/usr/bin/env bashCOMMENT
LOW…er/pulsar/scripts/apply-config-from-env-with-prefix.py21############################################################COMMENT
LOWdocker/pulsar/scripts/watch-znode.py1#!/usr/bin/env python3COMMENT
LOWdocker/pulsar/scripts/pulsar-zookeeper-ruok.sh1#!/usr/bin/env bashCOMMENT
LOW…ar/build-scripts/remove-unnecessary-native-binaries.sh1#!/usr/bin/env shCOMMENT
LOW…saction/buffer/impl/MetadataTransactionBufferTest.java221 // visible — orphans are eliminated by the publish-path ordering reversal (op-recordCOMMENT
LOW…saction/buffer/impl/MetadataTransactionBufferTest.java341 assertThat(tb.getOngoingTxnCount()).isOne();COMMENT
LOW…ance/extensions/ExtensibleLoadManagerImplBaseTest.java201 protected void initializeState() throws Exception {COMMENT
LOW…dbalance/extensions/ExtensibleLoadManagerImplTest.java1581 // After a test churns leader election, the channel-topic bundle can be transientlyCOMMENT
LOW…ce/extensions/channel/ServiceUnitStateChannelTest.java2021 // targeting this broker to Owned, simulating the broker-restart recovery scenario.COMMENT
LOW…/service/SystemTopicBasedTopicPoliciesServiceTest.java561 // The reader.close() above drives readMorePoliciesAsync() into cleanPoliciesCacheInitMap(), which logsCOMMENT
LOW…apache/pulsar/broker/service/OneWayReplicatorTest.java2021 });COMMENT
LOW…e/persistent/PersistentReplicatorInflightTaskTest.java361 // Rewind the cursor exactly as a failed publish to the remote cluster does. The in-flight readCOMMENT
LOW…va/org/apache/pulsar/broker/service/BrokerService.java4041 return CompletableFuture.completedFuture(false);COMMENT
LOW…ar/broker/service/persistent/PersistentReplicator.java361 // rewound while this read was in flight (e.g. after a failed publish or a schema change).COMMENT
LOW…ar/broker/service/persistent/PersistentReplicator.java381 // re-read. This makes the recovery at-least-once, with duplicates bounded to theCOMMENT
LOW…/pulsar/broker/service/persistent/PersistentTopic.java1421 // Unsubscribe compaction cursor and delete compacted ledger. Normally we wait for any in-flight compactionCOMMENT
LOW…istentStickyKeyDispatcherMultipleConsumersClassic.java461 // when consumer1 get message 2,3, the broker will not dispatch messages to consumer1COMMENT
LOW…stats/prometheus/metrics/PrometheusTextFormatUtil.java61 // quantile="0.75"} NaNCOMMENT
LOWpulsar-function-go/golangci.yml1#COMMENT
LOWpulsar-function-go/pb/Request.pb.go1//COMMENT
LOWpulsar-function-go/pb/Function.pb.go1//COMMENT
LOWpulsar-function-go/pb/InstanceCommunication_grpc.pb.go1//COMMENT
LOWpulsar-function-go/pb/doc.go1//COMMENT
LOWpulsar-function-go/pb/doc.go21// uses for the client/broker wire protocol.COMMENT
LOWpulsar-function-go/pb/generate.sh1#!/usr/bin/env bashCOMMENT
LOWpulsar-function-go/pb/generate.sh21# Bash script to automate the generation of the api package using Docker.COMMENT
LOWpulsar-function-go/pb/generate.sh101// distributed with this work for additional informationCOMMENT
LOWpulsar-function-go/pb/generate.sh161cat <<EOF >"${outDir}/doc.go"COMMENT
LOWpulsar-function-go/pb/generate.sh181// Package ${pkg} provides the protocol buffer messages that PulsarCOMMENT
LOWpulsar-function-go/pb/InstanceCommunication.pb.go1//COMMENT
LOWpulsar-function-go/pb/InstanceCommunication.pb.go61 //COMMENT
LOWpulsar-function-go/pf/function_test.go1//COMMENT
LOWpulsar-function-go/pf/instanceConf.go1//COMMENT
LOWpulsar-function-go/pf/topicName.go1//COMMENT
LOWpulsar-function-go/pf/instance.go1//COMMENT
LOWpulsar-function-go/pf/util_test.go1//COMMENT
LOWpulsar-function-go/pf/topicName_test.go1//COMMENT
LOWpulsar-function-go/pf/mockMessage_test.go1//COMMENT
LOWpulsar-function-go/pf/util.go1//COMMENT
LOWpulsar-function-go/pf/logAppender.go1//COMMENT
LOWpulsar-function-go/pf/context_test.go1//COMMENT
LOWpulsar-function-go/pf/stats.go1//COMMENT
LOWpulsar-function-go/pf/instance_test.go1//COMMENT
LOWpulsar-function-go/pf/instanceConf_test.go1//COMMENT
LOWpulsar-function-go/pf/context.go1//COMMENT
LOWpulsar-function-go/pf/instanceControlServicer_test.go1//COMMENT
LOWpulsar-function-go/pf/instanceControlServicer.go1//COMMENT
LOWpulsar-function-go/pf/function.go1//COMMENT
LOWpulsar-function-go/pf/function.go141 return val, errCOMMENT
200 more matches not shown…
Structural Annotation Overuse31 hits · 51 pts
SeverityFileLineSnippetContext
LOW…apache/pulsar/broker/service/OneWayReplicatorTest.java1695 // Step 1: Inject an error to make the replicator is not able to work.STRING
LOW…apache/pulsar/broker/service/OneWayReplicatorTest.java1699 // Step 2: Send one message, since the replicator does not work anymore, this message will not be replicated.STRING
LOW…apache/pulsar/broker/service/OneWayReplicatorTest.java1709 // Step 3: Unload topic, the replicator will be re-created.STRING
LOW…lsar/client/api/v5/V5MultiBrokerScalableTopicTest.java345 // Step 1: force controller materialization + leader election on every broker.COMMENT
LOW…lsar/client/api/v5/V5MultiBrokerScalableTopicTest.java350 // Step 2: wait until each broker's metadata store sees the controller-lock znode.COMMENT
LOW…sar/broker/service/schema/BookkeeperSchemaStorage.java350 // Step 1: Store the schema data into a new BookKeeper ledgerCOMMENT
LOW…sar/broker/service/schema/BookkeeperSchemaStorage.java360 // Step 2: Create the schema locator z-node pointing to the ledgerCOMMENT
LOW…sar/broker/service/schema/BookkeeperSchemaStorage.java368 // Step 3: Handle failure by cleaning up the orphan ledgerCOMMENT
LOW…r/broker/service/scalable/ScalableTopicController.java696 // Step 3: Terminate the parent segment topic so producers get TopicTerminatedCOMMENT
LOW…r/broker/service/scalable/ScalableTopicController.java699 // Step 4: Atomic metadata update (only after topics + cursors are ready + parent terminated)COMMENT
LOW…r/broker/service/scalable/ScalableTopicController.java738 // Step 1: Read the scalable topic's subscriptions from metadata (single source ofCOMMENT
LOW…r/broker/service/scalable/ScalableTopicController.java744 // Step 2: Terminate both parent segment topicsCOMMENT
LOW…r/broker/service/scalable/ScalableTopicController.java748 // Step 3: Atomic metadata update (only after topic + cursors are ready + parents terminated)COMMENT
LOW…r/broker/service/scalable/ScalableTopicController.java685 // Step 1: Read the scalable topic's subscriptions from metadata (the single sourceCOMMENT
LOW…r/broker/service/scalable/ScalableTopicController.java712 // Step 5: Notify subscriptions of layout change (triggers consumer reassignment)COMMENT
LOW…broker/authentication/ProxySaslAuthenticationTest.java227 // Step 1: Create Admin ClientCOMMENT
LOW…broker/authentication/ProxySaslAuthenticationTest.java269 // Step 3: Pass correct client paramsCOMMENT
LOW…ache/pulsar/proxy/server/ProxyForwardAuthDataTest.java88 // Step 1: Create Admin ClientCOMMENT
LOW…ache/pulsar/proxy/server/ProxyForwardAuthDataTest.java102 // Step 2: Run Pulsar Proxy without forwarding authData - expect ExceptionCOMMENT
LOW…ache/pulsar/proxy/server/ProxyForwardAuthDataTest.java136 // Step 3: Create proxy with forwardAuthData enabledCOMMENT
LOW…che/pulsar/proxy/server/ProxyRolesEnforcementTest.java186 // Step 1: Create Admin ClientCOMMENT
LOW…che/pulsar/proxy/server/ProxyRolesEnforcementTest.java202 // Step 2: Try to use proxy Client as a normal Client - expect exceptionCOMMENT
LOW…che/pulsar/proxy/server/ProxyRolesEnforcementTest.java212 // Step 3: Run Pulsar Proxy and pass proxy params as client params - expect exceptionCOMMENT
LOW…che/pulsar/proxy/server/ProxyRolesEnforcementTest.java252 // Step 4: Pass correct client paramsCOMMENT
LOW…pache/pulsar/proxy/server/ProxyAuthenticationTest.java272 // Step 1: Create Admin ClientCOMMENT
LOW…pache/pulsar/proxy/server/ProxyAuthenticationTest.java288 // Step 2: Try to use proxy Client as a normal Client - expect exceptionCOMMENT
LOW…pache/pulsar/proxy/server/ProxyAuthenticationTest.java317 // Step 3: Pass correct client params and use multiple connectionsCOMMENT
LOW…pache/pulsar/proxy/server/ProxyAuthenticationTest.java324 // Step 4: Ensure that all client contexts share the same auth providerCOMMENT
LOWwireshark/README.md26## Step 1: prepare PulsarApi.proto fileCOMMENT
LOWwireshark/README.md38## Step 2: add pulsar.lua to pluginsCOMMENT
LOWwireshark/README.md46## Step 3: start to useCOMMENT
Verbosity Indicators29 hits · 48 pts
SeverityFileLineSnippetContext
LOW…apache/pulsar/broker/service/OneWayReplicatorTest.java1695 // Step 1: Inject an error to make the replicator is not able to work.STRING
LOW…apache/pulsar/broker/service/OneWayReplicatorTest.java1699 // Step 2: Send one message, since the replicator does not work anymore, this message will not be replicated.STRING
LOW…apache/pulsar/broker/service/OneWayReplicatorTest.java1709 // Step 3: Unload topic, the replicator will be re-created.STRING
LOW…lsar/client/api/v5/V5MultiBrokerScalableTopicTest.java345 // Step 1: force controller materialization + leader election on every broker.COMMENT
LOW…lsar/client/api/v5/V5MultiBrokerScalableTopicTest.java350 // Step 2: wait until each broker's metadata store sees the controller-lock znode.COMMENT
LOW…org/apache/pulsar/broker/namespace/OwnershipCache.java169 // If we're not the owner, we need to check if anybody else isCOMMENT
LOW…sar/broker/service/schema/BookkeeperSchemaStorage.java350 // Step 1: Store the schema data into a new BookKeeper ledgerCOMMENT
LOW…sar/broker/service/schema/BookkeeperSchemaStorage.java360 // Step 2: Create the schema locator z-node pointing to the ledgerCOMMENT
LOW…sar/broker/service/schema/BookkeeperSchemaStorage.java368 // Step 3: Handle failure by cleaning up the orphan ledgerCOMMENT
LOW…r/broker/service/scalable/ScalableTopicController.java696 // Step 3: Terminate the parent segment topic so producers get TopicTerminatedCOMMENT
LOW…r/broker/service/scalable/ScalableTopicController.java699 // Step 4: Atomic metadata update (only after topics + cursors are ready + parent terminated)COMMENT
LOW…r/broker/service/scalable/ScalableTopicController.java738 // Step 1: Read the scalable topic's subscriptions from metadata (single source ofCOMMENT
LOW…r/broker/service/scalable/ScalableTopicController.java744 // Step 2: Terminate both parent segment topicsCOMMENT
LOW…r/broker/service/scalable/ScalableTopicController.java748 // Step 3: Atomic metadata update (only after topic + cursors are ready + parents terminated)COMMENT
LOW…r/broker/service/scalable/ScalableTopicController.java685 // Step 1: Read the scalable topic's subscriptions from metadata (the single sourceCOMMENT
LOW…r/broker/service/scalable/ScalableTopicController.java712 // Step 5: Notify subscriptions of layout change (triggers consumer reassignment)COMMENT
LOW…broker/authentication/ProxySaslAuthenticationTest.java227 // Step 1: Create Admin ClientCOMMENT
LOW…broker/authentication/ProxySaslAuthenticationTest.java269 // Step 3: Pass correct client paramsCOMMENT
LOW…ache/pulsar/proxy/server/ProxyForwardAuthDataTest.java88 // Step 1: Create Admin ClientCOMMENT
LOW…ache/pulsar/proxy/server/ProxyForwardAuthDataTest.java102 // Step 2: Run Pulsar Proxy without forwarding authData - expect ExceptionCOMMENT
LOW…ache/pulsar/proxy/server/ProxyForwardAuthDataTest.java136 // Step 3: Create proxy with forwardAuthData enabledCOMMENT
LOW…che/pulsar/proxy/server/ProxyRolesEnforcementTest.java186 // Step 1: Create Admin ClientCOMMENT
LOW…che/pulsar/proxy/server/ProxyRolesEnforcementTest.java202 // Step 2: Try to use proxy Client as a normal Client - expect exceptionCOMMENT
LOW…che/pulsar/proxy/server/ProxyRolesEnforcementTest.java212 // Step 3: Run Pulsar Proxy and pass proxy params as client params - expect exceptionCOMMENT
LOW…che/pulsar/proxy/server/ProxyRolesEnforcementTest.java252 // Step 4: Pass correct client paramsCOMMENT
LOW…pache/pulsar/proxy/server/ProxyAuthenticationTest.java272 // Step 1: Create Admin ClientCOMMENT
LOW…pache/pulsar/proxy/server/ProxyAuthenticationTest.java288 // Step 2: Try to use proxy Client as a normal Client - expect exceptionCOMMENT
LOW…pache/pulsar/proxy/server/ProxyAuthenticationTest.java317 // Step 3: Pass correct client params and use multiple connectionsCOMMENT
LOW…pache/pulsar/proxy/server/ProxyAuthenticationTest.java324 // Step 4: Ensure that all client contexts share the same auth providerCOMMENT
Unused Imports24 hits · 24 pts
SeverityFileLineSnippetContext
LOW…atest-version-image/python-examples/producer_schema.py22CODE
LOW…atest-version-image/python-examples/consumer_schema.py22CODE
LOW…functions/python-examples/avro_schema_test_function.py22CODE
LOW…tions/instance/src/test/python/test_python_instance.py28CODE
LOW…tions/instance/src/main/python/python_instance_main.py34CODE
LOW…ions/instance/src/main/python/prometheus_client_fix.py20CODE
LOW…ions/instance/src/main/python/prometheus_client_fix.py28CODE
LOW…ions/instance/src/main/python/prometheus_client_fix.py30CODE
LOW…ions/instance/src/main/python/prometheus_client_fix.py30CODE
LOW…ions/instance/src/main/python/prometheus_client_fix.py30CODE
LOW…ions/instance/src/main/python/prometheus_client_fix.py31CODE
LOW…ions/instance/src/main/python/prometheus_client_fix.py32CODE
LOW…ions/instance/src/main/python/prometheus_client_fix.py32CODE
LOW…ions/instance/src/main/python/prometheus_client_fix.py35CODE
LOW…ions/instance/src/main/python/prometheus_client_fix.py37CODE
LOW…ions/instance/src/main/python/prometheus_client_fix.py37CODE
LOW…ions/instance/src/main/python/prometheus_client_fix.py37CODE
LOW…ions/instance/src/main/python/prometheus_client_fix.py38CODE
LOW…ions/instance/src/main/python/prometheus_client_fix.py38CODE
LOW…ions/instance/src/main/python/prometheus_client_fix.py38CODE
LOW…sar-functions/instance/src/main/python/Function_pb2.py9CODE
LOW…ance/src/main/python/InstanceCommunication_pb2_grpc.py4CODE
LOW…/instance/src/main/python/InstanceCommunication_pb2.py9CODE
LOW…/instance/src/main/python/InstanceCommunication_pb2.py17CODE
Hyper-Verbose Identifiers21 hits · 22 pts
SeverityFileLineSnippetContext
LOW…pache/pulsar/socks5/handler/CommandRequestHandler.java40public class CommandRequestHandler extends SimpleChannelInboundHandler<DefaultSocks5CommandRequest> {CODE
LOW…/pulsar/socks5/handler/PasswordAuthRequestHandler.java32public class PasswordAuthRequestHandler extends SimpleChannelInboundHandler<DefaultSocks5PasswordAuthRequest> {CODE
LOW…pache/pulsar/socks5/handler/InitialRequestHandler.java31public class InitialRequestHandler extends SimpleChannelInboundHandler<DefaultSocks5InitialRequest> {CODE
LOW…va/org/apache/pulsar/client/api/MockBrokerService.java86 private class GenericResponseHandler extends AbstractHandler {CODE
LOW…tions/instance/src/test/python/test_python_instance.py75 def test_context_ack_partitionedtopic(self):CODE
LOW…tions/instance/src/test/python/test_secretsprovider.py35 def test_cleartext_secretsprovider(self):CODE
LOW…tions/instance/src/test/python/test_secretsprovider.py44 def test_environment_secretsprovider(self):CODE
LOW…tions/instance/src/main/python/python_instance_main.py59def generate_arguments_parser():CODE
LOW…r-functions/instance/src/main/python/function_stats.py111 def get_total_processed_successfully(self):CODE
LOW…r-functions/instance/src/main/python/function_stats.py117 def get_total_user_exceptions(self):CODE
LOW…r-functions/instance/src/main/python/function_stats.py149 def incr_total_processed_successfully(self):CODE
LOW…r-functions/instance/src/main/python/function_stats.py153 def incr_total_sys_exceptions(self, exception):CODE
LOW…r-functions/instance/src/main/python/function_stats.py158 def incr_total_user_exceptions(self, exception):CODE
LOW…r-functions/instance/src/main/python/function_stats.py193 def report_user_exception_prometheus(self, exception):CODE
LOW…r-functions/instance/src/main/python/function_stats.py211 def report_system_exception_prometheus(self, exception):CODE
LOW…lsar-functions/instance/src/main/python/contextimpl.py73 def set_current_message_context(self, message, topic):CODE
LOW…lsar-functions/instance/src/main/python/contextimpl.py89 def get_current_message_topic_name(self):CODE
LOW…lsar-functions/instance/src/main/python/contextimpl.py100 def get_message_partition_index(self):CODE
LOW…lsar-functions/instance/src/main/python/contextimpl.py156 def get_output_serde_class_name(self):CODE
LOW…-functions/instance/src/main/python/python_instance.py132 def process_spawner_health_check_timer(self):CODE
LOW…e/pulsar/functions/worker/FunctionMetaDataManager.java61public class FunctionMetaDataManager implements AutoCloseable {CODE
AI Slop Vocabulary5 hits · 15 pts
SeverityFileLineSnippetContext
MEDIUM…va/org/apache/pulsar/broker/service/ServerCnxTest.java1367 // This test is an example of https://github.com/apache/pulsar/issues/19332. Essentially, we're passingCOMMENT
MEDIUMbin/pulsar-admin-common.sh140# Netty cannot utilize resources from the memory pool and must frequently allocate native memory.COMMENT
MEDIUM…e/pulsar/common/util/collections/BitSetRecyclable.java32 * Provides {@link BitSetRecyclable#resetWords(long[])} method and leverage with netty recycler.COMMENT
MEDIUM…tor/NameAndConfigBasedSecretsProviderConfigurator.java50 // environment variables way. Essentially the secretName/secretPath isCOMMENT
MEDIUM…onfigurator/KubernetesSecretsProviderConfigurator.java69 // environment variables way. Essentially the secretName/secretPathCOMMENT
Cross-File Repetition3 hits · 15 pts
SeverityFileLineSnippetContext
HIGHpip/pip-259.md0the maximum size in bytes of the request header. larger headers will allow for more and/or larger cookies plus larger foSTRING
HIGH…org/apache/pulsar/proxy/server/ProxyConfiguration.java0the maximum size in bytes of the request header. larger headers will allow for more and/or larger cookies plus larger foSTRING
HIGH…ava/org/apache/pulsar/broker/ServiceConfiguration.java0the maximum size in bytes of the request header. larger headers will allow for more and/or larger cookies plus larger foSTRING
Self-Referential Comments4 hits · 12 pts
SeverityFileLineSnippetContext
MEDIUMpulsar-functions/instance/src/main/python/log.py31# Create the loggerCOMMENT
MEDIUM…ance/src/main/python/InstanceCommunication_pb2_grpc.py117 # This class is part of an EXPERIMENTAL API.COMMENT
MEDIUMsrc/update_python_protobuf_stubs_with_docker.sh23# Create an inline docker container with alpine:3.23 base image and mount the current directory to it as theCOMMENT
MEDIUMsrc/update_python_protobuf_stubs.sh29# Create a temporary virtual environment to avoid polluting the global Python environmentCOMMENT
Modern AI Meta-Vocabulary3 hits · 9 pts
SeverityFileLineSnippetContext
MEDIUMAGENTS.md46## Agent guardrailsCOMMENT
MEDIUMCLAUDE.md46## Agent guardrailsCOMMENT
MEDIUM.github/copilot-instructions.md46## Agent guardrailsCOMMENT
AI Response Leakage1 hit · 8 pts
SeverityFileLineSnippetContext
HIGH…buffer/impl/SingleSnapshotAbortedTxnProcessorImpl.java73 //In this implementation we clear the invalid aborted txn ID one by one.COMMENT
Deep Nesting6 hits · 6 pts
SeverityFileLineSnippetContext
LOWdocker/pulsar/scripts/update-ini-from-env.py30CODE
LOWdocker/pulsar/scripts/update-rocksdb-conf-from-env.py34CODE
LOW…tions/instance/src/main/python/python_instance_main.py149CODE
LOW…-functions/instance/src/main/python/python_instance.py247CODE
LOW…-functions/instance/src/main/python/python_instance.py367CODE
LOW…-functions/instance/src/main/python/python_instance.py543CODE
Cross-Language Confusion1 hit · 5 pts
SeverityFileLineSnippetContext
HIGH…er/pulsar/scripts/apply-config-from-env-with-prefix.py38SCRIPT_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")" >/dev/null 2>&1 && pwd)"CODE
Fake / Example Data5 hits · 5 pts
SeverityFileLineSnippetContext
LOW…-auth-oidc/src/test/java/resources/fakeKubeConfig.yaml37 token: fake-tokenCODE
LOW…mon/compression/CompressorCodecBackwardCompatTest.java34 "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Cras id massa odio. Duis commodo ligula sed "CODE
LOW…mon/compression/CompressorCodecBackwardCompatTest.java34 "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Cras id massa odio. Duis commodo ligula sed "CODE
LOW…che/pulsar/common/compression/CompressorCodecTest.java35 private static final String text = "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Cras id massa odio. "CODE
LOW…che/pulsar/common/compression/CompressorCodecTest.java35 private static final String text = "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Cras id massa odio. "CODE
Excessive Try-Catch Wrapping5 hits · 5 pts
SeverityFileLineSnippetContext
LOWpulsar-functions/instance/src/main/python/util.py44 except Exception as e:CODE
LOWpulsar-functions/instance/src/main/python/util.py49 except Exception as e:CODE
LOW…-functions/instance/src/main/python/python_instance.py282 except Exception as e:CODE
LOW…-functions/instance/src/main/python/python_instance.py295 except Exception as e:CODE
LOW…-functions/instance/src/main/python/python_instance.py593 except Exception as e:CODE
AI Structural Patterns5 hits · 5 pts
SeverityFileLineSnippetContext
LOW…ance/src/main/python/InstanceCommunication_pb2_grpc.py122CODE
LOW…ance/src/main/python/InstanceCommunication_pb2_grpc.py149CODE
LOW…ance/src/main/python/InstanceCommunication_pb2_grpc.py176CODE
LOW…ance/src/main/python/InstanceCommunication_pb2_grpc.py203CODE
LOW…ance/src/main/python/InstanceCommunication_pb2_grpc.py230CODE
Slop Phrases3 hits · 4 pts
SeverityFileLineSnippetContext
LOW.github/workflows/pulsar-ci.yaml31 # if cron expression is changed, make sure to update the expression in jdk_major_version step in preconditions jobCOMMENT
LOW.github/workflows/pulsar-ci-flaky.yaml31 # if cron expression is changed, make sure to update the expression in jdk_major_version step in preconditions jobCOMMENT
LOW…tions/instance/src/main/python/python_instance_main.py314 # make sure to close all non-daemon threads before this!COMMENT
Example Usage Blocks1 hit · 2 pts
SeverityFileLineSnippetContext
LOWgradle/setup-test-gpg.sh24# Usage:COMMENT