IBM Sterling Transformation Extender

Sterling Transformation Extender

Come for answers, stay for best practices. All we're missing is you.


#Sterling
#Supplychain
 View Only
Back to discussions
Expand all | Collapse all

ITX outbound KAFKA Connection

  • 1.  ITX outbound KAFKA Connection

    Posted 11/17/20 01:37 PM
    Building a map on Linux to connect to KAFKA and encountering issues. The error is happening while the producer is being created.

    The ITX launcher command
    -SRV 172.29.89.246:9093 -TP B2bKafkaIntegrationTest -SP SASL_SSL -SM GSSAPI -LCFL /home/b2badmin/kafka_kerberos/login.conf -KCFL /home/b2badmin/kafka_kerberos/krb5.poc.conf -TSL /home/b2badmin/kafka_kerberos/kafka.jks -TSP kafaPOC -TV

    The m4kafa trace file created.

    <28148-27176-11/13/20 16:26:04>:         [MAdapterImpl.MAdapterImpl]

    <28148-27176-11/13/20 16:26:04>:         |              Created adapter instance: com.hcl.hip.adapters.m4kafka.MAdapterImpl@7a0343e0, command line: -SRV 172.29.89.246:9093 -TP B2bKafkaIntegrationTest -SP SSL -TV

    <28148-27176-11/13/20 16:26:04>:         [MAdapterImpl.MAdapterImpl: com.hcl.hip.adapters.m4kafka.MAdapterImpl@7a0343e0] (rc = 0) OK

    <28148-27176-11/13/20 16:26:04>:         [MAdapterImpl.validateProperties]

    <28148-27176-11/13/20 16:26:04>:         [MAdapterImpl.validateProperties] (rc = 0) OK

    <28148-168-11/13/20 16:26:04>:              [MConnectionImpl.connect]

    <28148-168-11/13/20 16:26:04>:              |              connect() connection instance: com.hcl.hip.adapters.m4kafka.MConnectionImpl@673bc743

    <28148-168-11/13/20 16:26:04>:              |              Connecting to the cluster: 172.29.89.246:9093

    <28148-168-11/13/20 16:26:04>:              |              Using security protocol: SSL

    <28148-168-11/13/20 16:26:04>:              |              Using SASL mechanism: GSSAPI

    <28148-168-11/13/20 16:26:04>:              |              [MConnectionImpl.createProducer]

    <28148-168-11/13/20 16:26:04>:              |              |              Producer settings:

    {security.protocol=SSL, bootstrap.servers=172.29.89.246:9093, value.serializer=org.apache.kafka.common.serialization.ByteArraySerializer, buffer.memory=33554432, retries=0, client.id=, key.serializer=org.apache.kafka.common.serialization.ByteArraySerializer, linger.ms=0, sasl.mechanism=GSSAPI, enable.idempotence=false, batch.size=16384, compression.type=none, acks=all}

    <28148-168-11/13/20 16:26:04>:              |              |              Setting new context class loader.

    <28148-168-11/13/20 16:26:04>:              |              |              Creating producer...

    <28148-27176-11/13/20 16:26:04>:         [MAdapterImpl.onNotify]

    <28148-27176-11/13/20 16:26:04>:         |              Notification: Adapter[com.hcl.hip.adapters.m4kafka.MAdapterImpl@7a0343e0] ID[MPIN_OBJECT_PREPARE_DESTROY] intParam[0] objParam[null]

    <28148-27176-11/13/20 16:26:04>:         [MAdapterImpl.onNotify] (rc = 0) OK



    ------------------------------
    Raj Chetty
    ------------------------------

    #IBMSterlingTransformationExtender
    #DataExchange


Related Content