GitHub user jmhublar deleted a comment on the discussion: Replication broken after upgrade from 2.11.2 to 3.0.2
In the following exercise, I connect to our us-east-1 cluster, rewrite the client.conf to point to us-west-2, and use pulsar-client to write to a topic directly via the toolset workload. output sanitized: ``` ➜ kubectl exec -it -n pulsar pulsar-toolset-0 -- cat conf/client.conf | grep pulsar-proxy webServiceUrl=http://pulsar-proxy:8080/ brokerServiceUrl=pulsar://pulsar-proxy:6650/ ➜ pulsar-admin-cli sed -i 's|http://pulsar-proxy:8080/|http://pulsar-proxy.apps-01.sbx.us-west-2.example.net:8080/|; s|pulsar://pulsar-proxy:6650/|pulsar+ssl://pulsar-proxy. apps-01.sbx.us-west-2.example.net:6651/|' conf/client.conf ➜ kubectl exec -it -n pulsar pulsar-toolset-0 -- cat conf/client.conf | grep pulsar-proxy webServiceUrl=http://pulsar-proxy.apps-01.sbx.us-west-2.example.net:8080/ brokerServiceUrl=pulsar+ssl://pulsar-proxy.apps-01.sbx.us-west-2.example.net:6651/ ➜ ubectl exec -it -n pulsar pulsar-toolset-0 -- bin/pulsar-client produce persistent://tenant-one/testns/usw2-topic -m '"Hello Pulsar!"' 2024-11-06T22:03:01,028+0000 [pulsar-client-io-1-3] INFO org.apache.pulsar.client.impl.ConnectionPool - [[id: 0x6bb5d564, L:/10.191.107.168:35338 - R:pulsar-proxy.apps-01.sbx.us -west-2.example.net/10.191.238.210:6651]] Connected to server 2024-11-06T22:03:01,350+0000 [pulsar-client-io-1-3] INFO org.apache.pulsar.client.impl.ProducerStatsRecorderImpl - Starting Pulsar producer perf with config: {"topicName":"persi stent://tenant-one/testns/usw2-topic","producerName":null,"sendTimeoutMs":30000,"blockIfQueueFull":false,"maxPendingMessages":1000,"maxPendingMessagesAcrossPartitions":50000,"mes sageRoutingMode":"RoundRobinPartition","hashingScheme":"JavaStringHash","cryptoFailureAction":"FAIL","batchingMaxPublishDelayMicros":1000,"batchingPartitionSwitchFrequencyByPubli shDelay":10,"batchingMaxMessages":1000,"batchingMaxBytes":131072,"batchingEnabled":true,"chunkingEnabled":false,"chunkMaxMessageSize":-1,"encryptionKeys":[],"compressionType":"NO NE","initialSequenceId":null,"autoUpdatePartitions":true,"autoUpdatePartitionsIntervalSeconds":60,"multiSchema":true,"accessMode":"Shared","lazyStartPartitionedProducers":false," properties":{},"initialSubscriptionName":null,"nonPartitionedTopicExpected":false} 2024-11-06T22:03:01,358+0000 [pulsar-client-io-1-3] INFO org.apache.pulsar.client.impl.ProducerStatsRecorderImpl - Pulsar client config: {"serviceUrl":"pulsar+ssl://pulsar-proxy .apps-01.sbx.us-west-2.example.net:6651/","authPluginClassName":null,"authParams":null,"authParamMap":null,"operationTimeoutMs":30000,"lookupTimeoutMs":30000,"statsIntervalS econds":60,"numIoThreads":16,"numListenerThreads":16,"connectionsPerBroker":1,"connectionMaxIdleSeconds":25,"useTcpNoDelay":true,"useTls":true,"tlsKeyFilePath":"","tlsCertificateFilePath":"","tlsTrustCertsFilePath":"","tlsAllowInsecureConnection":false,"tlsHostnameVerificationEnable":false,"concurrentLookupRequest":5000,"maxLookupRequest":50000,"maxLookupRedirects":20,"maxNumberOfRejectedRequestPerConnection":50,"keepAliveIntervalSeconds":30,"connectionTimeoutMs":10000,"requestTimeoutMs":60000,"readTimeoutMs":60000,"autoCertRefreshSeconds":300,"initialBackoffIntervalNanos":100000000,"maxBackoffIntervalNanos":60000000000,"enableBusyWait":false,"listenerName":null,"useKeyStoreTls":false,"sslProvider":null,"tlsKeyStoreType":"JKS","tlsKeyStorePath":"","tlsKeyStorePassword":"*****","tlsTrustStoreType":"JKS","tlsTrustStorePath":"","tlsTrustStorePassword":"*****","tlsCiphers":[],"tlsProtocols":[],"memoryLimitBytes":0,"proxyServiceUrl":null,"proxyProtocol":null,"enableTransaction":false,"dns LookupBindAddress":null,"dnsLookupBindPort":0,"socks5ProxyAddress":null,"socks5ProxyUsername":null,"socks5ProxyPassword":null,"description":null} 2024-11-06T22:03:01,497+0000 [pulsar-client-io-1-5] INFO org.apache.pulsar.client.impl.ConnectionPool - [[id: 0x8ab36920, L:/10.191.107.168:46454 - R:pulsar-proxy.apps-01.sbx.us-west-2.example.net/10.191.231.155:6651]] Connected to server 2024-11-06T22:03:01,500+0000 [pulsar-client-io-1-5] INFO org.apache.pulsar.client.impl.ClientCnx - [id: 0x8ab36920, L:/10.191.107.168:46454 - R:pulsar-proxy.apps-01.sbx.us-west-2.example.net/10.191.231.155:6651] Connected through proxy to target broker at pulsar-broker-1.pulsar-broker.pulsar.svc.cluster.local:6650 2024-11-06T22:03:01,703+0000 [pulsar-client-io-1-5] INFO org.apache.pulsar.client.impl.ProducerImpl - [persistent://tenant-one/testns/usw2-topic] [null] Creating producer on cnx [id: 0x8ab36920, L:/10.191.107.168:46454 - R:pulsar-proxy.apps-01.sbx.us-west-2.example.net/10.191.231.155:6651] 2024-11-06T22:03:01,775+0000 [pulsar-client-io-1-5] INFO org.apache.pulsar.client.impl.ProducerImpl - [persistent://tenant-one/testns/usw2-topic] [sandbox-usw2-111-13022] Created producer on cnx [id: 0x8ab36920, L:/10.191.107.168:46454 - R:pulsar-proxy.apps-01.sbx.us-west-2.example.net/10.191.231.155:6651] 2024-11-06T22:03:01,863+0000 [main] INFO org.apache.pulsar.client.impl.ProducerStatsRecorderImpl - [persistent://tenant-one/testns/usw2-topic] [sandbox-usw2-111-13022] --- Publish throughput: 1.98 msg/s --- 0.00 Mbit/s --- Latency: med: 81.000 ms - 95pct: 81.000 ms - 99pct: 81.000 ms - 99.9pct: 81.000 ms - max: 81.000 ms --- BatchSize: med: 1.000 - 95pct: 1.000 - 99pct: 1.000 - 99.9pct: 1.000 - max: 1.000 --- MsgSize: med: 15.000 bytes - 95pct: 15.000 bytes - 99pct: 15.000 bytes - 99.9pct: 15.000 bytes - max: 15.000 bytes --- Ack received rate: 1.98 ack/s --- Failed messages: 0 --- Pending messages: 0 2024-11-06T22:03:01,932+0000 [pulsar-client-io-1-5] INFO org.apache.pulsar.client.impl.ProducerImpl - [persistent://tenant-one/testns/usw2-topic] [sandbox-usw2-111-13022] Closed Producer 2024-11-06T22:03:01,933+0000 [main] INFO org.apache.pulsar.client.impl.PulsarClientImpl - Client closing. URL: pulsar+ssl://pulsar-proxy.apps-01.sbx.us-west-2.example.net:6651/ 2024-11-06T22:03:01,944+0000 [pulsar-client-io-1-5] INFO org.apache.pulsar.client.impl.ClientCnx - [id: 0x8ab36920, L:/10.191.107.168:46454 ! R:pulsar-proxy.apps-01.sbx.us-west-2.example.net/10.191.231.155:6651] Disconnected 2024-11-06T22:03:01,945+0000 [pulsar-client-io-1-3] INFO org.apache.pulsar.client.impl.ClientCnx - [id: 0x6bb5d564, L:/10.191.107.168:35338 ! R:pulsar-proxy.apps-01.sbx.us-west-2.example.net/10.191.238.210:6651] Disconnected 2024-11-06T22:03:03,954+0000 [main] INFO org.apache.pulsar.client.cli.PulsarClientTool - 1 messages successfully produced ``` GitHub link: https://github.com/apache/pulsar/discussions/23558#discussioncomment-11171399 ---- This is an automatically sent email for [email protected]. To unsubscribe, please send an email to: [email protected]
