Alexander-ac opened a new issue, #1514:
URL: https://github.com/apache/camel-kafka-connector/issues/1514
Hi all,
we currently use the following packages:
amqp-kafka-connector-0.11.5
and
apache-qpid-jms-0.56
The sink connector (over amqp 1.0) itself works, but extremely slowly.
What is immediately noticeable in the log is that the sink connector
reestablishes the connection with the **ActiveMQ** broker after each message is
delivered!!!!
for example:
[2023-03-06 20:09:48,222] INFO [AMQPSinkConnector|task-0] Connection
ID:a7733de7-20c9-4a09-9314-98aab25f976f:2 connected to server:
amqps://192.168.1.12:5671 (org.apache.qpid.jms.JmsConnection:1353)
[2023-03-06 20:09:48,572] INFO [AMQPSinkConnector|task-0] Connection
ID:c5780863-215f-4539-beb6-b1ef70b3f759:3 connected to server:
amqps://192.168.1.12:5671 (org.apache.qpid.jms.JmsConnection:1353)
[2023-03-06 20:09:48,759] INFO [AMQPSinkConnector|task-0] Connection
ID:36c069ae-00b6-4719-9362-4bd7021ae75d:4 connected to server:
amqps://192.168.1.12:5671 (org.apache.qpid.jms.JmsConnection:1353)
Here I am sending three messages and we see three connection structures.
This slows down the spread of the messages.
Anyone have similar experiences?
Here is the property file of the sink connector:
name=AMQPSinkConnector
tasks.max=1
# JMS Queue
connector.class=org.apache.camel.kafkaconnector.amqp.CamelAmqpSinkConnector
camel.component.amqp.testConnectionOnStartup=true
camel.component.amqp.includeAmqpAnnotations=false
camel.component.amqp.connectionFactory.remoteURI=amqps://192.168.1.12:5671
camel.component.amqp.connectionFactory=#class:org.apache.qpid.jms.JmsConnectionFactory
camel.component.amqp.username=admin
camel.component.amqp.password=admin
camel.sink.path.destinationType=queue
camel.sink.path.destinationName=Output.SinkConnector_2
# KAFKA TOPIC
topics=TEST_TOPIC
# use the kafka converters that better suit your needs, these are just
defaults:
key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=org.apache.kafka.connect.storage.StringConverter
I am grateful for every tip!
Thanks in advance
Alex
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
