Slackbot
04/18/2022, 9:11 PMSlackbot
05/04/2022, 12:35 PMSlackbot
05/18/2022, 4:24 PMSlackbot
07/10/2022, 5:14 PMSlackbot
07/15/2022, 10:15 PMSlackbot
07/21/2022, 6:25 PMSlackbot
10/12/2022, 9:43 AMSlackbot
12/14/2022, 10:09 AMSlackbot
12/29/2022, 3:35 AMSlackbot
01/13/2023, 9:19 PMSlackbot
02/13/2023, 11:43 AMSimi Ily
03/08/2023, 2:28 AMJacek Wiślicki
04/25/2023, 1:27 PMYu Wei Sung
05/01/2023, 7:48 PMbhasvij
07/10/2023, 2:13 PMbhasvij
07/10/2023, 2:14 PMbhasvij
07/10/2023, 2:16 PMbhasvij
07/20/2023, 4:17 PMbhasvij
07/20/2023, 4:17 PMbhasvij
07/20/2023, 4:22 PMSlackbot
07/20/2023, 4:29 PMSlackbot
07/21/2023, 6:13 PMSlackbot
08/16/2023, 6:27 PMRafał Trójczak
11/27/2023, 9:18 AMSébastien
12/05/2023, 8:48 AMSchema<CustomTypeClass> schema =
AvroSchema.of(
SchemaDefinition.<CustomTypeClass>builder()
.withPojo(CustomTypeClass.class)
.withJSR310ConversionEnabled(true)
.build());
PulsarSink.<KeyValue<String, CustomTypeClass>>builder()
.setServiceUrl(pulsarServiceURL)
.setAdminUrl(pulsarAdminURL)
.setProducerName("flink-producer")
.setTopics(topicName)
.setSerializationSchema(Schema.KeyValue(Schema.STRING, schema, KeyValueEncodingType.SEPARATED))
But on the consumer side, I see all messages are consumed by all consumers. I'm wondering if I might have a problem with the schema declaration.
PulsarWriter seems to add a key based on the key message (https://github.com/apache/flink-connector-pulsar/blob/main/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/PulsarWriter.java#L198),
but I have the feeling that it doesn't because the schema context is incorrect (https://github.com/apache/flink-connector-pulsar/blob/main/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/PulsarWriter.java#L143C83-L143C83).
So I would like to know If KeyValueSchemaFactory or KeyValueSchemaImpl.of ( ... ) is the correct way or if I'm missing something...
Thanks !Ruturaj
02/06/2024, 12:09 PMRami Youssef
02/11/2024, 7:34 PMmonicadeshmukh99
09/11/2024, 1:50 PMHenry
10/11/2024, 3:07 AMKimB
04/04/2025, 10:54 AM