@@ -41,7 +41,6 @@ import org.springframework.util.CollectionUtils;
|
||||
* An administration class that delegates to {@link PulsarAdmin} to create and manage
|
||||
* topics defined in the application context.
|
||||
*
|
||||
* @author Chris Bono
|
||||
* @author Alexander Preuß
|
||||
*/
|
||||
public class PulsarAdministration
|
||||
|
||||
@@ -19,7 +19,6 @@ package org.springframework.pulsar.core;
|
||||
/**
|
||||
* The Pulsar administration contract.
|
||||
*
|
||||
* @author Chris Bono
|
||||
* @author Alexander Preuß
|
||||
*/
|
||||
public interface PulsarAdministrationOperations {
|
||||
|
||||
@@ -29,7 +29,6 @@ import org.apache.pulsar.common.naming.TopicDomain;
|
||||
* @param topicName the topic name
|
||||
* @param numberOfPartitions the number of partitions, or 0 for non-partitioned topics
|
||||
*
|
||||
* @author Chris Bono
|
||||
* @author Alexander Preuß
|
||||
*/
|
||||
public record PulsarTopic(String topicName, int numberOfPartitions) {
|
||||
|
||||
@@ -19,7 +19,6 @@ package org.springframework.pulsar.core;
|
||||
/**
|
||||
* Builder class to create {@link PulsarTopic} instances.
|
||||
*
|
||||
* @author Chris Bono
|
||||
* @author Alexander Preuß
|
||||
*/
|
||||
public class PulsarTopicBuilder {
|
||||
|
||||
@@ -39,7 +39,6 @@ import org.springframework.test.context.junit.jupiter.SpringExtension;
|
||||
/**
|
||||
* Tests for {@link PulsarAdministration}.
|
||||
*
|
||||
* @author Chris Bono
|
||||
* @author Alexander Preuß
|
||||
*/
|
||||
@ExtendWith(SpringExtension.class)
|
||||
|
||||
@@ -29,7 +29,6 @@ import org.junit.jupiter.params.provider.MethodSource;
|
||||
/**
|
||||
* Tests for {@link PulsarTopic}.
|
||||
*
|
||||
* @author Chris Bono
|
||||
* @author Alexander Preuß
|
||||
*/
|
||||
public class PulsarTopicTests {
|
||||
|
||||
Reference in New Issue
Block a user