This message was deleted.

This message was deleted.

I see quite a bit off traffic about Apache Arrow Flight, but nothing on the Pulsar channels. Is there none or am I just looking in the wrong places?

While following the instructions to setup IntelliJ for pulsar development I got the below error

Could not find artifact org.apache.pulsar:pulsar-broker:pom:2.12.0-SNAPSHOT in apache.snapshots (<https://repository.apache.org/snapshots>)

Digging deeper into the snapshots, I don't see pulsar-broker at 2.12.0 either: https://repository.apache.org/content/groups/snapshots/org/apache/pulsar/pulsar-broker/ Is there some configuration step missing? See SO: https://stackoverflow.com/questions/75064447/could-not-find-artifact-org-apache-pulsarpulsar-brokerpom2-12-0-snapshot-in-a

This message was deleted.

This message was deleted.

This message was deleted.

This message was deleted.

This message was deleted.

This message was deleted.

This message was deleted.

This message was deleted.

This message was deleted.

This message was deleted.

This message was deleted.

This message was deleted.

This message was deleted.

Hi All, I am new to pulsar and I am creating a pulsar cluster in aws EKS stack using helm charts

This message was deleted.

is it done via config maps?

TIA

This message was deleted.

This message was deleted.

on the other hand when we created one producer object per message(which is bad and wrong), we surprisingly saw better performance. any reasons why it couldnt have performed well.

Note: we did not use batching in this scenario and we are using m5 instance type in aws

This message was deleted.

Hi I am trying to explore KoP on pulsar, I have made the config changes following the documentation, but when I am trying to produce to the topics(created from pulsar-admin tool) I am getting the following exception in kafka client

WARN [Producer clientId=console-producer] Bootstrap broker <ip>:9092 (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient)

Logs from broker don't have much info and all I can see is this

13:09:21.931 [pulsar-io-4-2] DEBUG io.streamnative.pulsar.handlers.kop.KafkaCommandDecoder - [/<ip>:42816] Received kafka cmd RequestHeader(apiKey=API_VERSIONS, apiVersion=3, clientId=console-producer, correlationId=23), the request content is: KafkaHeaderAndRequest(header=RequestHeader(apiKey=API_VERSIONS, apiVersion=3, clientId=console-producer, correlationId=23), request={}, remoteAddress=/<ip>:42816)
13:09:21.931 [send-response-OrderedScheduler-0-0] DEBUG io.streamnative.pulsar.handlers.kop.KafkaCommandDecoder - Write kafka cmd to client. request content: KafkaHeaderAndRequest(header=RequestHeader(apiKey=API_VERSIONS, apiVersion=3, clientId=console-producer, correlationId=23), request={}, remoteAddress=/<ip>:42816) responseAndRequest content: {error_code=35,api_versions=[]}

command used to produce

./bin/kafka-console-producer.sh --topic viesti/ns1/k1 --bootstrap-server <ip>:9092

pulsar and kop version used: 2.9.3.19, kafka_client version:

kafka_2.12-2.8.2 and kafka_2.13-3.3.1

Tried both versions and none of them worked. Anyone else has seen similar issues?

Any errors in the Broker logs at 130921.931 ? Not sure what error_code 35 is, but I would investigate

UNSUPPORTED_VERSION 35 False The version of API is not supported.

^^^ meaning an incompatible Kafka client version?