diff --git a/app/lib/kafka.server.ts b/app/lib/kafka.server.ts index dbaa4c5b5..0943877d8 100644 --- a/app/lib/kafka.server.ts +++ b/app/lib/kafka.server.ts @@ -288,14 +288,6 @@ export async function deleteKafkaACL(user: User, aclIds: string[]) { ) } -export async function updateBrokersFromDb(user: User) { - const dbDefinedAcls = await getKafkaACLsFromDynamoDB(user) - const adminClient = adminKafka.admin() - await adminClient.connect() - await adminClient.createAcls({ acl: dbDefinedAcls }) - await adminClient.disconnect() -} - export async function updateDbFromBrokers(user: User) { const kafkaDefinedAcls = await getAclsFromBrokers() const db = await tables() diff --git a/app/routes/admin.kafka._index.tsx b/app/routes/admin.kafka._index.tsx index 0685fcd23..b4329b1c4 100644 --- a/app/routes/admin.kafka._index.tsx +++ b/app/routes/admin.kafka._index.tsx @@ -34,7 +34,6 @@ import { deleteKafkaACL, getKafkaACLsFromDynamoDB, getLastSyncDate, - updateBrokersFromDb, updateDbFromBrokers, } from '~/lib/kafka.server' import { getFormDataString } from '~/lib/utils' @@ -67,11 +66,6 @@ export async function action({ request }: ActionFunctionArgs) { return null } - if (intent === 'migrateFromDB') { - await updateBrokersFromDb(user) - return null - } - const promises = [] switch (intent) { @@ -130,7 +124,6 @@ export default function Index() { const updateFetcher = useFetcher() const aclFetcher = useFetcher() const brokerFromDbFetcher = useFetcher() - const ref = useRef(null) useEffect(() => { setAclData(aclFetcher.data?.dynamoDbAclData ?? aclData) @@ -175,16 +168,6 @@ export default function Index() { ) : (
)} - - Update Broker from DB - {brokerFromDbFetcher.state !== 'idle' && ( Updating... @@ -224,37 +207,6 @@ export default function Index() { )} - - - Confirm Update - -

This action cannot be undone.

- - - Cancel - - - -
-
) }