Integration / Apache Pulsar Interview questions

What happens when a broker crashes in Pulsar?

The metadata store detects the broker's session has expired (it stops renewing its ephemeral registration), and the cluster's load manager recognizes every topic the crashed broker owned now has no active owner.

Those orphaned topics are reassigned to healthy brokers based on current load; because no message data lived on the crashed broker, the new owning broker simply opens the same BookKeeper ledgers the topic was already using - there's no data recovery or replica catch-up step required.

Clients using the Pulsar client library detect the ownership change via a lookup and automatically reconnect to the new owning broker, typically resuming within seconds with no message loss for already-acknowledged data.

Take quiz

After a broker crash, topic ownership is: reassigned to a healthy broker with no data movement

✓ Correct! Well done.

permanently lost along with all data

✗ Try again if not.

manually reassigned with required downtime

✗ Try again if not.

Clients detect broker failover through: editing configuration files

✗ Try again if not.

an automatic lookup and reconnect

✓ Correct! Well done.

a manual restart of the client application

✗ Try again if not.

More Related questions...

What is AppDynamics? Explain about Apache Pulsar. What is Apache Pulsar? What is a Pulsar broker? What is Application Performance Monitoring (APM)? What is Apache BookKeeper? What are the core components of the AppDynamics platform? What is the Controller in AppDynamics? What are tenants and namespaces in Pulsar? What is an App Agent in AppDynamics? What is a topic in Pulsar? What are the types of agents available in AppDynamics? What is a producer in Pulsar? What is a Business Transaction in AppDynamics? What is a consumer in Pulsar? What is a subscription in Pulsar? What is a Tier in AppDynamics? What is a Node in AppDynamics? Define a partitioned topic in Pulsar? What is Pulsar's metadata store used for? What is a Business Application in AppDynamics? What is the Application Flow Map? What are Pulsar Functions? What is a Health Rule? What is Pulsar IO? Describe geo-replication in Pulsar? What is a Policy in AppDynamics? What is tiered storage in Pulsar? What is a Transaction Snapshot? What is a non-persistent topic in Pulsar? Define baseline in AppDynamics? What is the Machine Agent used for? What are the subscription types in Pulsar? What is End User Monitoring (EUM)? What is message retention in Pulsar? What is Database Visibility in AppDynamics? What is schema registry in Pulsar? List the core components of a Pulsar cluster? What are Backends in AppDynamics? Describe the Metric Browser in AppDynamics? How do you create a topic in Pulsar? What is the difference between a Tier and a Node in AppDynamics? What is the difference between Pulsar and Kafka's storage architecture? How does Pulsar separate compute and storage? How does AppDynamics automatically discover Business Transactions? What is the difference between automatic and custom Business Transaction match rules? Why is Pulsar considered multi-tenant by design? What is the difference between Shared and Exclusive subscriptions? How does AppDynamics correlate a transaction across multiple tiers? Why is the singularityheader important in transaction correlation? How does Key_Shared subscription maintain ordering? How does AppDynamics decide when to capture a transaction snapshot? When should you use Failover subscription instead of Exclusive? What is the difference between a ledger and a segment in BookKeeper? What is dynamic baselining and how does it work? Why does the Java Agent use byte-code instrumentation? How does Pulsar achieve message deduplication? Explain the internal working of AppDynamics' byte-code instrumentation? Why do brokers in Pulsar not store data locally? What happens when a broker crashes in Pulsar? What is a Service Endpoint in AppDynamics? What is an Information Point? How does namespace bundle splitting work? What is a Data Collector in AppDynamics? What is the difference between backlog quota and retention policy? When should you use custom match rules instead of automatic discovery? When should you use a Reader instead of a Consumer? What is the difference between Slow, Very Slow, and Stalled transactions? How does topic compaction work in Pulsar? How does AppDynamics calculate Average Response Time (ART)? Why is ensemble size different from write quorum in BookKeeper? What is the difference between persistent and non-persistent topics? What is the difference between the Machine Agent and the Network Agent? What is an Adaptive Session in AppDynamics? How does Pulsar handle delayed message delivery? What is a thread dump and when does AppDynamics capture one automatically? What happens when a consumer negatively acknowledges a message? Explain the lifecycle of a message in Pulsar from produce to acknowledge? How would you troubleshoot a suspected memory leak using AppDynamics? How can you optimize Pulsar for high-throughput workloads? What are custom extensions for the Machine Agent? How do you troubleshoot a growing backlog in Pulsar? How does the Cluster Agent monitor Kubernetes environments? What is the difference between SaaS and On-Premises Controller deployments? Explain the execution flow of topic ownership failover in Pulsar? How can you optimize BookKeeper storage costs using tiered storage? How can you reduce AppDynamics agent overhead in a production environment? What is Business iQ / Analytics in AppDynamics? Explain the internal working of Pulsar transactions? Which is better for exactly-once processing: idempotent producers or transactions, and why? How does AppDynamics integrate with ITSM tools like ServiceNow or PagerDuty? How do you troubleshoot unbalanced load across brokers? What is the AppDynamics REST API used for? Explain the lifecycle of a namespace bundle from creation to split? Explain the lifecycle of an alert from health rule violation to notification? What is the difference between Warning and Critical health rule severities? How can you optimize consumer throughput with Key_Shared subscriptions? What are Instrumentation exclude rules and why would you use them? Explain the execution flow of a Pulsar Function processing a message? Explain the execution flow of a distributed transaction across microservices in AppDynamics? How do you troubleshoot message duplication in a Pulsar producer?

Show more question and Answers...

Apache Camel Interview Questions

Comments & Discussions

Mule ESB Interview Questions 16 Apache Kafka Interview questions 58 Akka interview questions 23 IBM Integration Bus (IIB) Interview questions 25 IBM MQ Interview Questions 14 Apache Pulsar Interview questions 1 Apache Camel Interview Questions 45 Apache NiFi Interview Questions 45 RabbitMQ Interview Questions 45 ActiveMQ Interview Questions Basics 18 ActiveMQ Interview Questions Intermediate 15 ActiveMQ Interview Questions Advanced 12 D Bus Interview Questions 50 BullMQ Interview questions

Recently added questions

How does class loading follow the delegation model? Why does the JVM use generational garbage collection? What is bytecode in Java? Why is the Metaspace stored in native memory instead of the heap? What happens when a NoClassDefFoundError occurs versus ClassNotFoundException? What is the difference between Young Generation and Old Generation in heap memory? What are the main components of JVM architecture? What is the JVM Stack? What is the purpose of the Just-In-Time (JIT) compiler? What is Metaspace, and how does it differ from PermGen? Why do we use the parent delegation model in class loading? What is the difference between Class.forName() and ClassLoader.loadClass()? Explain the lifecycle of a class in JVM (loading, linking, initialization)? Explain the internal working of the linking phase (verification, preparation, resolution)? How does escape analysis enable stack allocation optimizations? Explain the internal working of safepoints and why the JVM needs them? What is the Class Loader subsystem in JVM? What are the types of class loaders in JVM? What is the purpose of the Java Native Interface (JNI)? Explain the execution flow of a Minor GC vs Major GC?

	Interviews Questions Java Spring Hibernate DevOps Testing API BigData Web Erlang AI Database Integration Cloud Python Scala Tools Golang SAP	About Javapedia.net Javapedia.net is for Java and J2EE developers, technologist and college students who prepare of interview. Also this site includes many practical examples. This site is developed using J2EE technologies by Steve Antony, a senior Developer/lead at one of the logistics based company. Follow Javapedia updates
	contact: javatutorials2016[at]gmail[dot]com
Kindly consider donating for maintaining this website. Thanks.
	Copyright © 2026, javapedia.net, all rights reserved. Privacy Policy · Terms of Service.