Debezium에서 table_name => kafka 토픽 매핑을 구성하는 것이 가능합니까?

로버트 판 코웨 키

http://debezium.io/docs/connectors/mysql/을 읽었 지만 debezium을 구성하여 2 개 (또는 그 이상) 테이블의 변경 사항을 동일한 단일 kafka에 기록 할 수 있는지 여부에 대한 정보를 찾을 수 없습니다. 이야기? 항상 1 개의 테이블-> 1 개의 주제 인 것 같습니다.

로빈 모팻

예, 식별 한 링크 별로 단일 메시지 변환을 사용 합니다. 정규식 (정규식)을 사용하여 테이블을 필요한 주제에 매핑 할 수 있습니다. 둘 다 또는 트릭을 수행해야합니다. 이 게시물 에는 후자의 예가 있습니다 .io.debezium.transforms.ByLogicalTableRouterorg.apache.kafka.connect.transforms.RegexRouter

"transforms":"dropPrefix",  
"transforms.dropPrefix.type":"org.apache.kafka.connect.transforms.RegexRouter",  
"transforms.dropPrefix.regex":"DC1-TEST-(.*)",  
"transforms.dropPrefix.replacement":"$1"

이 기사는 인터넷에서 수집됩니다. 재 인쇄 할 때 출처를 알려주십시오.

침해가 발생한 경우 연락 주시기 바랍니다[email protected] 삭제

에서 수정
0

몇 마디 만하겠습니다

0리뷰
로그인참여 후 검토

관련 기사

분류에서Dev

Logstash 구성에 더 많은 Kafka 토픽을 동적으로 추가하는 방법

분류에서Dev

어떻게 문자열을 문자열로 매핑하는 것이 Groovy의 문자열 목록에 대한 문자열 매핑으로 가능합니까?

분류에서Dev

"PLS-00302 : 구성 요소 'TABLE_NAME'을 선언해야합니다."라는 메시지가 나타나는 이유는 무엇입니까?

분류에서Dev

토픽 문자열을 버전 화하는 것이 합리적입니까?

분류에서Dev

소비자 그룹이 여러 토픽 파티션을 구독하는 경우 kafka는 먼저 읽을 항목을 어떻게 결정합니까?

분류에서Dev

Spring-Kafka : application.yml에서 kafka 토픽을 전달하는 방법

분류에서Dev

KafkaJS에 이미 존재하는 토픽을 생성해도 괜찮습니까?

분류에서Dev

flink에서 kafka 토픽 데이터에 액세스 / 읽는 방법은 무엇입니까?

분류에서Dev

이 소비자 (서블릿에서 실행)가 kafka 토픽에서 메시지를 수신하지 않는 이유는 무엇입니까?

분류에서Dev

URL에서 배열을 매핑 할 가능성이 있습니까?

분류에서Dev

동일한 클러스터에 다른 kafka 브로커를 추가하는 것이 가능합니까?

분류에서Dev

C의 비트 필드에서 유니온을 형성하는 것이 가능하고 정확합니까?

분류에서Dev

LEFT OUTER JOIN에서 NULL 값을 계산하는 것이 가능합니까?

분류에서Dev

테이블을 만들 때 "오류 1031 (HY000) 줄 ### : '<table_name>'에 대한 테이블 스토리지 엔진에이 옵션이 없습니다."

분류에서Dev

구현이 HashMap을 래핑하는 특성에서 수명 매개 변수를 제거 하시겠습니까?

분류에서Dev

debezium kafka connect에서받은 CDC 이벤트에서 테이블 이름과 데이터베이스 이름을 가져 오는 방법

분류에서Dev

직접 매핑 (선형 매핑) 영역에서 가능한 한 많은 RAM을 매핑하는 Linux 커널의 합리성은 무엇입니까?

분류에서Dev

컨테이너에서 사용하기 위해 구성 중에 매핑 표현식을 결합하는 방법

분류에서Dev

Alpakka-kafka가 토픽 분할에서 라운드 로빈을 읽도록 강제하는 방법은 무엇입니까?

분류에서Dev

Angular에서 AAD access_token을 얻는 것이 가능합니까?

분류에서Dev

Swift에서 뉴 모픽 소프트 UI를 만드는 것이 불가능합니까?

분류에서Dev

상호 연결된 엔티티 스키마를 RDMS 및 그래프와 같은 데이터베이스에서 이벤트 형태로 사용할 수 있도록 Kafka 토픽을 구성하는 방법

분류에서Dev

Null 허용이 가능한 C # 환경에서 여전히 NotNull 특성을 사용하는 것이 유용합니까? 아니면 차이가 없습니까?

분류에서Dev

파이썬의 사전 매핑 내에서 함수가 실행되는 것을 방지 할 수 있습니까?

분류에서Dev

하이퍼 레저 패브릭에서 두 구성 프로토 버프 간의 델타를 계산한다는 것은 무엇을 의미합니까?

분류에서Dev

sqlalchemy에서 테이블을 선택하고 열을 선택하지 않는 것이 가능합니까?

분류에서Dev

UUID 유형에 대한 기본 유형 매핑을 구성하는 방법이 있습니까?

분류에서Dev

메모리 매핑 파일이 여러 앱 인스턴스에서 성능을 향상합니까?

분류에서Dev

구독 내에서 오류를 포착하는 것이 불가능합니까?

Related 관련 기사

  1. 1

    Logstash 구성에 더 많은 Kafka 토픽을 동적으로 추가하는 방법

  2. 2

    어떻게 문자열을 문자열로 매핑하는 것이 Groovy의 문자열 목록에 대한 문자열 매핑으로 가능합니까?

  3. 3

    "PLS-00302 : 구성 요소 'TABLE_NAME'을 선언해야합니다."라는 메시지가 나타나는 이유는 무엇입니까?

  4. 4

    토픽 문자열을 버전 화하는 것이 합리적입니까?

  5. 5

    소비자 그룹이 여러 토픽 파티션을 구독하는 경우 kafka는 먼저 읽을 항목을 어떻게 결정합니까?

  6. 6

    Spring-Kafka : application.yml에서 kafka 토픽을 전달하는 방법

  7. 7

    KafkaJS에 이미 존재하는 토픽을 생성해도 괜찮습니까?

  8. 8

    flink에서 kafka 토픽 데이터에 액세스 / 읽는 방법은 무엇입니까?

  9. 9

    이 소비자 (서블릿에서 실행)가 kafka 토픽에서 메시지를 수신하지 않는 이유는 무엇입니까?

  10. 10

    URL에서 배열을 매핑 할 가능성이 있습니까?

  11. 11

    동일한 클러스터에 다른 kafka 브로커를 추가하는 것이 가능합니까?

  12. 12

    C의 비트 필드에서 유니온을 형성하는 것이 가능하고 정확합니까?

  13. 13

    LEFT OUTER JOIN에서 NULL 값을 계산하는 것이 가능합니까?

  14. 14

    테이블을 만들 때 "오류 1031 (HY000) 줄 ### : '<table_name>'에 대한 테이블 스토리지 엔진에이 옵션이 없습니다."

  15. 15

    구현이 HashMap을 래핑하는 특성에서 수명 매개 변수를 제거 하시겠습니까?

  16. 16

    debezium kafka connect에서받은 CDC 이벤트에서 테이블 이름과 데이터베이스 이름을 가져 오는 방법

  17. 17

    직접 매핑 (선형 매핑) 영역에서 가능한 한 많은 RAM을 매핑하는 Linux 커널의 합리성은 무엇입니까?

  18. 18

    컨테이너에서 사용하기 위해 구성 중에 매핑 표현식을 결합하는 방법

  19. 19

    Alpakka-kafka가 토픽 분할에서 라운드 로빈을 읽도록 강제하는 방법은 무엇입니까?

  20. 20

    Angular에서 AAD access_token을 얻는 것이 가능합니까?

  21. 21

    Swift에서 뉴 모픽 소프트 UI를 만드는 것이 불가능합니까?

  22. 22

    상호 연결된 엔티티 스키마를 RDMS 및 그래프와 같은 데이터베이스에서 이벤트 형태로 사용할 수 있도록 Kafka 토픽을 구성하는 방법

  23. 23

    Null 허용이 가능한 C # 환경에서 여전히 NotNull 특성을 사용하는 것이 유용합니까? 아니면 차이가 없습니까?

  24. 24

    파이썬의 사전 매핑 내에서 함수가 실행되는 것을 방지 할 수 있습니까?

  25. 25

    하이퍼 레저 패브릭에서 두 구성 프로토 버프 간의 델타를 계산한다는 것은 무엇을 의미합니까?

  26. 26

    sqlalchemy에서 테이블을 선택하고 열을 선택하지 않는 것이 가능합니까?

  27. 27

    UUID 유형에 대한 기본 유형 매핑을 구성하는 방법이 있습니까?

  28. 28

    메모리 매핑 파일이 여러 앱 인스턴스에서 성능을 향상합니까?

  29. 29

    구독 내에서 오류를 포착하는 것이 불가능합니까?

뜨겁다태그

보관