confluent-kafka

1열

2답변

리더가 없습니다. Console의 카프카 (ssl + acl 구성이있는 프로듀서)

kska 0.11.0.1을 ssl + acls과 함께 사용하려고합니다. 내 구성은 다음과 같습니다. 다음으로 제조자가 subject=/C=in/ST=maha/L=mum/O=atos/OU=atos/CN=kafka issuer=/C=in/ST=maha/L=mum/O=atos/OU=atos/CN=kafka/[email protected] CN 상 : se

apache-kafka kafka-producer-api confluent-kafka 2017-11-29

---

0열

1답변

0.9 Apache Kafka 클러스터에서 Conluent Kafka로

현재 Apache Kafka 클러스터를 Confluent Kafka 기반으로 업그레이드/마이그레이션 할 계획입니다. 현재 클러스터는 0.9 이며 0.10입니다. 단순히 이전 브로커를 폐기하고 동일한 브로커 아이디로 현재 업그레이드 된 합류 브로커를 다시 도입 할 수 있습니까? 이전 및 ew 브로커 모두에 이미 설정된 프로토콜 버전 설정을 알고 있습니다. 감

apache-kafka confluent-kafka 2017-11-29

---

0열

1답변

Confluent Kafka : 소비자가 주제의 모든 파티션을 처음부터 읽지 않습니다.

40 개의 파티션이있는 주제가 있습니다. 설정은 다음과 같습니다. def on_assign (c,ps): for p in ps: p.offset=0 print ps c.assign(ps) conf = {'bootstrap.servers': 'localhost:9092' 'enable.auto.commit' : False,

apache-kafka kafka-consumer-api confluent-kafka kafka-python 2017-12-06

---

-1열

1답변

카프카 스트림에서 null을 제거해야합니다.

--property print.key=true을 제거하면 kafka-cosole-consumer 명령이 console ...에 null을 표시하지 않기 때문에 작동하지만, 실제로 사용하고있는 디스플레이 용도 만이 아닙니다. ... 카프카에서 내 출력이을 받아 들일 수 없다 ..... 내 스트림 반응이 훨씬에만 {"timestamp":"2017-10-04T1

apache-kafka apache-kafka-streams confluent-kafka 2017-12-07

---

3열

2답변

한 카프카 클러스터에서 다른 카프카 클러스터로 메시지 스트리밍

현재 한 카프카 클러스터의 토픽에서 다른 토픽으로 메시지를 쉽게 스트리밍하려고합니다 (원격 -> 로컬 클러스터). 아이디어는 Kafka-Streams를 즉시 사용하여 로컬 클러스터의 실제 메시지를 복제 할 필요가 없지만 Kafka-Streams 처리의 "결과"만 Kafka-Topics에 가져올 수 있습니다. WordCount 데모가 다른 PC의 Kafka-

apache-kafka apache-kafka-streams confluent-kafka 2017-12-15

---

1열

1답변

카프카에서 최신 값을 얻으십시오

카프카 주제는 A입니다. 주제 의 데이터 형식은 다음과 같습니다이 { id : 1, name:stackoverflow, created_at:2017-09-28 22:30:00.000} { id : 2, name:confluent, created_at:2017-09-28 22:00:00.000} { id : 3, name:kafka, created_at:

apache-kafka apache-kafka-streams confluent-kafka ksql 2017-12-15

---

0열

1답변

는

나는 카프카의 토폴로지 다음과 같은 정의 Operation 1 : input_stream ----> filter ----> window_processing ----> write_to_topic Operation 2 : input_stream ----> write_to_topic 나는 두 작업은 동일한 스레드 (내가 스레딩에 대한 StreamsConfi

apache-kafka apache-kafka-streams confluent-kafka confluent 2017-12-18

---

0열

1답변

파이썬은 여기 내 코드의 일부입니다 confluent_kafka

의 KafkaException를 잡을 수 없습니다. 두 개의 서버를 하나씩 다시 시작하면 KafkaProducer.send()가 KafkaException (아마도 confluent_kafka의 일부 버그)을 throw하고 일부 예외 로그가 발생합니다. 이상한 점은 scan_new_application에서 예외가 계속 나오고 run_scan_new_appl

python apache-kafka confluent-kafka 2017-12-22

---

0열

1답변

Confluent.Kafka.Producer <TKey, TValue> .ProduceAsync는 스레드로부터 안전한가요?

// // Summary: // Asynchronously send a single message to the broker. Refer to Confluent.Kafka.Producer`2.ProduceAsync(System.String,`0,`1,System.Int32,System.Boolean) // for more inf

kafka-producer-api confluent-kafka 2017-12-25

---

0열

1답변

카프카 스트림은 GenericAvroSerde

에 알 수없는 마법 바이트는 카프카 스트림과 브로 데이터를 스트리밍 할 때,이 오류를 건너 왔어요 거기에 언급 된 해결책 중 어느 것도 문제를 해결하지 못했습니다. 바라건대 여기서 해결책을 찾을 수 있습니다. 다음과 같이 내 설정은 같습니다 StreamsConfig.KEY_SERDE_CLASS_CONFIG, Serdes.String.getClass.getN

apache-kafka apache-kafka-streams confluent-kafka confluent-schema-registry 2017-12-26

---