Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Some tweaks for pulsarmq-connector #4060

Merged
merged 8 commits into from
May 13, 2022
Merged

Commits on Feb 10, 2022

  1. 1. Add the com.alibaba.otter.canal.connector.core.spi.CanalMsgConsume…

    …r file to the META-INF/canal directory under the pulsarmq-connector project
    
    2. Introduce pulsar-client-admin for Canal to automatically create multi-partition topics
    3. Add the judgment that roleToken is null
    4. The disconnect method in CanalPulsarMQConsumer removes this.pulsarMQConsumer.unsubscribe();, this code will cause data loss during stop
    5. When getting Pulsar messages, they are all processed as flat messages, because CanalMessageSerializerUtil.deserializer(data) will deserialize exceptions
    6. Use groupId as subscriptName, without the pulsarmq.subscriptName parameter, the entire adapter will be the same subscriber name using pulsarmq.subscriptName
    zhangjukai committed Feb 10, 2022
    Configuration menu
    Copy the full SHA
    8a78728 View commit details
    Browse the repository at this point in the history
  2. 逻辑优化

    zhangjukai committed Feb 10, 2022
    Configuration menu
    Copy the full SHA
    49bf352 View commit details
    Browse the repository at this point in the history
  3. 代码优化

    zhangjukai committed Feb 10, 2022
    Configuration menu
    Copy the full SHA
    81de668 View commit details
    Browse the repository at this point in the history

Commits on Feb 11, 2022

  1. 针对pulsar的调整

    zhangjukai committed Feb 11, 2022
    Configuration menu
    Copy the full SHA
    4cf1765 View commit details
    Browse the repository at this point in the history
  2. 恢复代码

    zhangjukai committed Feb 11, 2022
    Configuration menu
    Copy the full SHA
    b18a98b View commit details
    Browse the repository at this point in the history
  3. 恢复代码

    zhangjukai committed Feb 11, 2022
    Configuration menu
    Copy the full SHA
    c229f2e View commit details
    Browse the repository at this point in the history
  4. Configuration menu
    Copy the full SHA
    b2916fc View commit details
    Browse the repository at this point in the history

Commits on Feb 28, 2022

  1. Configuration menu
    Copy the full SHA
    7bc024f View commit details
    Browse the repository at this point in the history