webMethods

 View Only
Expand all | Collapse all

Consumer Kafka adapter is not working

  • 1.  Consumer Kafka adapter is not working

    Posted Mon October 19, 2020 04:19 AM

    Hi all,

    we are trying to implement kafka adapter 9.6 in our IS 10.5.
    I tried to configure publisher and consumer by follow software AG documentation.
    publisher connection is working fine but not form the consumer.
    is there any body can help me on this?

    this is the error :

    imagehttps://higherlogicdownload.s3.amazonaws.com/IMWUC/webMethods/Files3/6646c400387c2bfd539519c43721ad9fa6bbef3d_2_1035x166.png 1.5x, https://higherlogicdownload.s3.amazonaws.com/IMWUC/webMethods/Files/6646c400387c2bfd539519c43721ad9fa6bbef3d.png 2x" data-dominant-color="D7E6EE">
    image1314×213 14.4 KB

    and this is the configuration

    imagehttps://higherlogicdownload.s3.amazonaws.com/IMWUC/webMethods/Files3/5320a59706dd04564a8b32280a7069cb8f5f5534_2_1035x655.png 1.5x, https://higherlogicdownload.s3.amazonaws.com/IMWUC/webMethods/Files/5320a59706dd04564a8b32280a7069cb8f5f5534.png 2x" data-dominant-color="F3F3F3">
    image1116×707 38.4 KB

    thanks.


    #webMethods
    #kafka-adapter
    #kafka
    #Integration-Server-and-ESB


  • 2.  RE: Consumer Kafka adapter is not working

    Posted Mon October 19, 2020 07:31 AM

    Hi Junedi,

    I advised you to apply KAF_9.6_Fix3 or the latest fix to see your issue is happening again or not. Also you might want to fine tune all the timeout values in case the fix doesn’t help to solve your problem.


    #kafka
    #webMethods
    #Integration-Server-and-ESB
    #kafka-adapter


  • 3.  RE: Consumer Kafka adapter is not working

    Posted Mon October 19, 2020 07:53 AM

    Hi @Junedi_Hutagaol, we have similar settings for kafka consumer connection in v9.12 (with kafka 9.6 with fix level WAK_9.6_Fix4.
    Its working as expected.

    in our settings, we have autocommit set to false.

    Key Deserializer Class org.apache.kafka.common.serialization.StringDeserializer
    Value Deserializer Class org.apache.kafka.common.serialization.StringDeserializer
    Enable Auto Commit false
    Auto Commit Interval(ms)
    Session Timeout(ms) 30000
    Auto Offset Reset earliest
    Kafka Version v11+

    #webMethods
    #Integration-Server-and-ESB
    #kafka
    #kafka-adapter