package com.trendyol.stove.testing.e2e.standalone.kafka

Get desktop application:
View/edit binary Protocol Buffers messages

• rpc healthCheck (HealthCheckRequest, HealthCheckResponse)

  messages.proto:59

  message HealthCheckRequest

  messages.proto:44

  • string service = 1

  message HealthCheckResponse

  messages.proto:48

  • HealthCheckResponse.ServingStatus status = 1

• rpc onConsumedMessage (ConsumedMessage, Reply)

  messages.proto:62

  buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE

  message ConsumedMessage

  messages.proto:6

  • string id = 1

  • bytes message = 2

  • string topic = 3

  • int32 partition = 4

  • int64 offset = 5

  • string key = 6

  • map<string, string> headers = 8

• rpc onPublishedMessage (PublishedMessage, Reply)

  messages.proto:65

  buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE

  message PublishedMessage

  messages.proto:16

  • string id = 1

  • bytes message = 2

  • string topic = 3

  • string key = 4

  • map<string, string> headers = 5

• rpc onCommittedMessage (CommittedMessage, Reply)

  messages.proto:68

  buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE

  message CommittedMessage

  messages.proto:24

  • string id = 1

  • string topic = 2

  • int32 partition = 3

  • int64 offset = 4

  • string metadata = 5

• rpc onAcknowledgedMessage (AcknowledgedMessage, Reply)

  messages.proto:71

  buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE

  message AcknowledgedMessage

  messages.proto:32

  • string id = 1

  • string topic = 2

  • int32 partition = 3

  • int64 offset = 4

  • string exception = 5

Used in: HealthCheckResponse

• UNKNOWN = 0

• SERVING = 1

• NOT_SERVING = 2

• SERVICE_UNKNOWN = 3

  Used only by the Watch method.

Used as response type in: StoveKafkaObserverService.onAcknowledgedMessage, StoveKafkaObserverService.onCommittedMessage, StoveKafkaObserverService.onConsumedMessage, StoveKafkaObserverService.onPublishedMessage

• int32 status = 3