您现在要做的是根据一个条件仅将一部分记录发送到一个主题，而放弃其他主题。如果要将一部分发送到一个主题，将另一部分发送到另一个主题，则应使用分支运算符。
像这样：

KStream<K, Long>[] branches = builder.stream("Customer")
        .groupByKey()
        .count()
        .toStream()
        .branch((k, v) -> v > 20),
                (k, v) -> v <= 20);
branches[0].to("topicB");
branches[1].to("topicA");

另一件事你应该注意的是比较必须在数字之间，而不是字符串之间，因为当你对字符串使用更大的比较器时，你是在比较字符串的长度和字典顺序

简单的解决方案是创建一个producer，一次从输入的csv文件中读取一行，并根据计数条件将其发送到特定的主题。

psuedo code:
while no row left in csv:
    row = readrow()
    if row.counts<20
       producer.send(topicA,row)
    else
       producer.send(topicB,row)

你可以跟着https://towardsdatascience.com/kafka-python-explained-in-10-lines-of-code-800e3e07dad1 为了便于理解Kafka和python

StreamsBuilder builder=new StreamsBuilder();

    KStream<String, String> inputTopic = builder.stream("Trans_Topic");

            inputTopic
                   .filter((k,v)->{
                       return Long.parseLong(v.split(",")[6]) < 20L; //6 is the column id.
                   }).to("trans_topic_result_1");
    inputTopic
            .filter((k,v)->{
                return Long.parseLong(v.split(",")[6]) > 20L;
            }).to("trans_topic_result_2");