apache/pulsar-client-go

Issues

• [Bug] DLQ producer name conflicts when same name consumer sends messages to DLQ

  #1297 opened 23 days ago by geniusjoe
  0

• [bug] Schema validation not working: producing messages that are non-compliant with the schema is allowed

  #1296 opened 3 months ago by calindima
  2

• Seek fails on non-partitioned topics due to partition check in Go client

  #1298 opened 2 months ago by hegelwin
  0

• Use pulsar-client-go-test docker to test TestBlueGreenMigrationTestSuite case

  #1282 opened 3 months ago by geniusjoe
  0

• Got " Failed to create consumer at reconnect" when stop pulsar broker first and restart it later

  #1290 opened 3 months ago by zhangbiao2009
  3

• Flaky test `TestCloseFlushWithTimer`

  #1291 opened 3 months ago by RobertIndie
  0

• [BUG] Reconnection logic and Backoff policy doesn't work correctly

  #1187 opened 3 months ago by RobertIndie
  2

• [BUG] publish function is blocked

  #1285 opened 4 months ago by iceh09
  0

• CommandAck parse failed Some required fields are missing

  #1284 opened 4 months ago by hanmz
  0

• Deadlock in connection pool

  #1272 opened 4 months ago by Gilthoniel
  2

• Race during reconnect

  #1274 opened 4 months ago by Gilthoniel
  0

• Readers leak timers when closed

  #1262 opened 4 months ago by MishimaPorte
  1

• EnableZeroQueueConsumer Setting Not Functioning Correctly

  #1276 opened 4 months ago by gkhnoztrk
  4

• [doc] Please provide an example of enabling transaction consumption at the production environment level

  #1222 opened 4 months ago by zcola
  2

• The default backoff policy does not have mandatory stop, which could cause unexpected send timeout

  #1270 opened 5 months ago by BewareMyPower
  5

• Ability for a Consumer to bypass retries and DLQ a terminally failing message

  #1167 opened a year ago by jcass8695
  3

• Incorrect sequence of messages while reading dataChan after closing

  #1257 opened 5 months ago by Gilthoniel
  3

• InitialSubscriptionName for DLQPolicy

  #1239 opened 5 months ago by justinrixx
  0

• Possible data race in internalFlush

  #1258 opened 5 months ago by Gilthoniel
  2

• Panic when calling Flush after Close

  #1259 opened 5 months ago by Gilthoniel
  0

• Add namespaces subscriptionExpirationTime commands

  #1253 opened 5 months ago by klevy-toast
  0

• Set `client_credentials` as the default OAuth2 grant type.

  #1238 opened 6 months ago by RobertIndie
  1

• [BUG] The process will block if close client or producer when pulsar server is down.

  #1190 opened 5 months ago by asddongmen
  1

• failTimeoutMessages() cannot delete outdated messages

  #1236 opened 5 months ago by geniusjoe
  5

• [BUG] calling `NewTransaction` always fails after reconnection happens

  #1227 opened 6 months ago by itgram
  2

• ackReq Variable Assignment in Code

  #1233 opened 6 months ago by zhangweiii
  1

• [Question]Zero value of ReceiverQueueSize

  #1223 opened 6 months ago by g41797
  3

• How is pulsaradmin initialized with username and password

  #1224 opened 6 months ago by li-zeyuan
  4

• Closed reader does not return in Next

  #1218 opened 7 months ago by Gilthoniel
  3

• golang adds a batch fetch message API

  #1201 opened 9 months ago by wangrenyi
  1

• [Mocks] Add Mock Server Implementation

  #1166 opened a year ago by jayshrivastava
  3

• allow override the Schema Creator by a consumer

  #1191 opened 10 months ago by adrianiacobghiula
  2

• Pulsar Client Go Schema Registry to save scheme use for both Producer and Consumer

  #1188 opened 10 months ago by ThinhLe30
  2

• Reader HasNext() enters infinite loop

  #1171 opened 10 months ago by shadygrove
  0

• [Bug] Cannot receive txn message after previous message be aborted

  #1186 opened 10 months ago by SmileYun
  1

• Pulsar Producer send Avro message schema

  #1183 opened 10 months ago by ThinhLe30
  2

• `FunctionState` should omit empty fields to match the Java nullable fields

  #1184 opened 10 months ago by freeznet
  0

• Consumers can't keep on consuming messages while Pulsar Broker restarting even the consumer has been reconnected to the broker

  #1180 opened 10 months ago by panszobe
  0

• Using pulsar-admin golang pkg, but can not create tenant

  #1179 opened 10 months ago by ThinhLe30
  4

• Multi-topics reader support

  #1177 opened 10 months ago by RobertIndie
  0

• Fix NewBytesSchema

  #1175 opened 10 months ago by petermnhull
  0

• Enable accessing Message in TableView

  #1176 opened a year ago by petermnhull
  0

• [client] add ability to list topic names which exist on the server

  #1168 opened a year ago by jayshrivastava
  3

• [all] support contexts

  #1170 opened a year ago by jayshrivastava
  1

• how to handle a forvever reader for a client unless the client is closed by program

  #1148 opened a year ago by someview
  1

• SIGSEGV in 0.12.0 with zstd compression enabled, when producer is shared between multiple goroutines

  #1163 opened a year ago by 0x4500
  3

• Incorrect ledgerID and entryID logged when producer receives unexpected ack

  #1160 opened a year ago by RobertIndie
  0

• Error trying to do a linux build on a Mac

  #1159 opened a year ago by trevordowdle
  0

• dependency dvsekhvalnov/jose2go v1.5.0 is vulnerable

  #1149 opened a year ago by richelieu-yang
  2

• pulsar_client_consumer_processing_time_seconds metric records incorrect values

  #1154 opened a year ago by ojcm
  1