Raghav
01/20/2023, 8:20 AMWARN [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? Is there a guide on which versions of kafka are compatible with the versions of kop+pulsarOneeb
03/06/2023, 8:24 AM/pulsar/protocols
which is a mounted volume. I get a permission error here. What is the super user password for Pulsar here?
And am I approaching this in a different manner than other people?Brad
04/17/2023, 7:33 AMRaghav
04/28/2023, 10:09 AMAlex
06/22/2023, 12:51 PMDhinesh Thiruppathi
06/27/2023, 1:07 PMOneeb
06/27/2023, 1:41 PMkey.converter: io.confluent.connect.avro.AvroConverter
key.converter.schema.registry.url: <http://pulsar-broker.pulsar.svc.cluster.local:8080/admin/v2/schemas/public/default/sample-schema/schema>
value.converter: io.confluent.connect.avro.AvroConverter
value.converter.schema.registry.url: <http://pulsar-broker.pulsar.svc.cluster.local:8080/admin/v2/schemas/public/default/sample-schema/schema>
And Im currently getting this in the logs:
org.apache.kafka.connect.errors.ConnectException: Tolerance exceeded in error handler
Caused by: io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException: Unexpected character ('<' (code 60)):
Can I get some help on how I can go about integrating these two things?Ken
01/02/2024, 3:08 PMMuni Chada
03/14/2024, 4:43 PM