[jira] [Resolved] (KAFKA-17336) Add IT to make sure the production MV does not use unstable version of LIST_OFFSET

["Chia-Ping Tsai (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/KAFKA-17336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Chia-Ping Tsai resolved KAFKA-17336.
------------------------------------
    Resolution: Fixed

> Add IT to make sure the production MV does not use unstable version of LIST_OFFSET 
> -----------------------------------------------------------------------------------
>
>                 Key: KAFKA-17336
>                 URL: https://issues.apache.org/jira/browse/KAFKA-17336
>             Project: Kafka
>          Issue Type: Sub-task
>            Reporter: Chia-Ping Tsai
>            Assignee: 黃竣陽
>            Priority: Blocker
>             Fix For: 3.9.0
>
>
> see https://github.com/apache/kafka/pull/16841#discussion_r1715730246
> the sample code:
> {code:java}
>   @ParameterizedTest
>   @ValueSource(strings = Array("kraft"))
>   def test(quorum: String): Unit = {
>     client = createAdminClient
>     client.createTopics(Collections.singletonList(new NewTopic("ikea", 1, 1.toShort))).all().get()
>     TimeUnit.SECONDS.sleep(1)
>     val producer = new KafkaProducer(Collections.singletonMap(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,
>       plaintextBootstrapServers(brokers).asInstanceOf[Object]), new ByteArraySerializer, new ByteArraySerializer)
>     try {
>       (0 until 100).foreach { i =>
>         producer.send(new ProducerRecord[Array[Byte], Array[Byte]]("ikea", new Array[Byte](10), new Array[Byte](10)))
>       }
>       producer.flush()
>     } finally producer.close()
>     client.alterPartitionReassignments(util.Collections.singletonMap(new TopicPartition("ikea", 0), Optional.of(new NewPartitionReassignment(util.Arrays.asList(0, 1)))))
>       .all().get()
>     client.deleteRecords(util.Collections.singletonMap(new TopicPartition("ikea", 0), RecordsToDelete.beforeOffset(3))).all().get()
>     TimeUnit.SECONDS.sleep(5)
>     assertEquals(2, client.describeTopics(util.Collections.singletonList("ikea")).topicNameValues().get("ikea").get().partitions()
>       .get(0).isr().size())
>   }
> {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)